Amazon SNS内联Java订阅用于测试

<dependency>
    <groupId>software.amazon.awssdk</groupId>
    <artifactId>sns</artifactId>
    <version>2.17.43</version>
</dependency>

SnsClient snsClient = SnsClient.builder()
                .region(Region.US_EAST_1)
                .credentialsProvider(DefaultCredentialsProvider.create())
                .build();

CreateTopicRequest createTopicRequest = CreateTopicRequest.builder()
                .name("MyTopic")
                .build();

CreateTopicResponse createTopicResponse = snsClient.createTopic(createTopicRequest);
String topicArn = createTopicResponse.topicArn();

SubscribeRequest subscribeRequest = SubscribeRequest.builder()
                .topicArn(topicArn)
                .protocol("email")
                .endpoint("test@example.com")
                .build();

SubscribeResponse subscribeResponse = snsClient.subscribe(subscribeRequest);
String subscriptionArn = subscribeResponse.subscriptionArn();

PublishRequest publishRequest = PublishRequest.builder()
                .topicArn(topicArn)
                .message("Hello, world!")
                .build();

PublishResponse publishResponse = snsClient.publish(publishRequest);