要使用AWS JDK 2创建队列并订阅主题,可以按照以下步骤:
software.amazon.awssdk
sns
2.x.x
确保将2.x.x替换为最新版本。
import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.sns.SnsClient;
import software.amazon.awssdk.services.sns.model.CreateTopicRequest;
import software.amazon.awssdk.services.sns.model.CreateTopicResponse;
import software.amazon.awssdk.services.sns.model.SubscribeRequest;
import software.amazon.awssdk.services.sns.model.SubscribeResponse;
Region region = Region.US_EAST_1;
SnsClient snsClient = SnsClient.builder().region(region).build();
确保将US_EAST_1替换为您要使用的AWS区域。
String topicName = "your-topic-name";
CreateTopicRequest createTopicRequest = CreateTopicRequest.builder()
.name(topicName)
.build();
CreateTopicResponse createTopicResponse = snsClient.createTopic(createTopicRequest);
String topicArn = createTopicResponse.topicArn();
将your-topic-name替换为您想要的主题名称。
String queueUrl = "your-queue-url";
SubscribeRequest subscribeRequest = SubscribeRequest.builder()
.topicArn(topicArn)
.protocol("sqs")
.endpoint(queueUrl)
.build();
SubscribeResponse subscribeResponse = snsClient.subscribe(subscribeRequest);
String subscriptionArn = subscribeResponse.subscriptionArn();
将your-queue-url替换为您要订阅的队列URL。
现在,您已成功创建了一个主题并将其订阅到队列中。请确保在使用完SNS客户端后关闭它:
snsClient.close();
请注意,这只是一个示例代码,您可能需要根据您的实际需求进行调整。
下一篇:AWS 基岩模型评估失败。