示例工程教程后端【免费下载链接】aws-doc-sdk-examplesWelcome to the AWS Code Examples Repository. This repo contains code examples used in the AWS documentation, AWS SDK Developer Guides, and more. For more information, see the Readme.md file below.项目地址https://gitcode.com/gh_mirrors/aw/aws-doc-sdk-examples点击查看免费下载本文基于 aws-doc-sdk-examples 仓库中 javav2/example_code/sns/README.md 整理与扩写完整覆盖 Amazon SNS 在 Java 2.x SDK 下的入门示例、全部单接口操作、多接口组合场景与本地运行/测试方式并结合 源码实现 深入讲解 FIFO 主题、消息过滤策略与 SQS 队列订阅等关键细节。读完本文你可以独立完成从创建主题、订阅端点、发布消息到清理资源的完整 SNS 工作流并理解每个示例背后的 SDK 调用方式。一、示例集合定位与工程结构Amazon SNSSimple Notification Service简单通知服务是允许应用、终端用户和设备从云端即时收发通知的 Web 服务。本目录中的示例展示了如何使用 AWS SDK for Java 2.x 操作 SNS 的各类 API示例分为三类入门示例Get startedHelloSNS.java通过ListTopics列出账号下的所有主题作为第一个跑通的 SNS 程序单接口示例Single actions15 个独立示例每个对应一次服务 API 调用多接口场景Scenarios跨多个 API 完成完整任务的组合示例例如创建并投递 FIFO 主题消息、向队列发布消息等。从目录结构看所有 Java 源文件位于包com.example.sns下src/main/java/com/example/sns测试位于 src/test/java/com/example/sns构建配置由 pom.xml、Makefile 和 run_example.sh 共同支撑。计费与权限提醒来自原文档的 Important 章节运行这些代码可能对你的 AWS 账户产生费用运行测试同样可能产生费用建议遵循最小权限原则只授予代码完成任务所需的最小 IAM 权限这些代码并非在每一个 AWS Region 都经过测试使用前请确认你的 Region 支持相应服务。二、前置条件与构建环境2.1 运行前提按照 javav2 根目录 README 的要求运行本目录示例需要Apache Maven3.0所有 Java 2.x 示例都假设 SDK 能通过默认凭据提供器链获取 AWS 凭据例如~/.aws/config中的 SSO 配置或~/.aws/credentials中的临时凭据默认 Region 配置若未显式设置默认 Region 为us-east-1。本目录所有示例在构造SnsClient时也都显式指定了Region.US_EAST_1例如 HelloSNS.java 第 14–16 行。2.2 关键依赖来自 pom.xml依赖版本/说明software.amazon.awssdk:bom2.35.10统一管理 SDK 各模块版本software.amazon.awssdk:snsSNS 服务客户端software.amazon.awssdk:sqsSQS 服务客户端FIFO 场景与队列扇出场景使用software.amazon.sns:sns-extended-client2.1.0SNS 扩展客户端software.amazon.awssdk:iam-policy-builder用于在代码中构建 IAM 策略 JSON见 4.2 节software.amazon.awssdk:sts用于获取当前账号 IDgetCallerIdentitycom.google.code.gson:gson2.10.1交互场景中的 JSON 解析org.junit.jupiter:junit-jupiter5.11.4JUnit 5 测试log4j-core/slf4j-api日志支持工程目标 Java 版本为21pom.xml中java.version21maven-compiler-plugin 3.11.0。三、入门示例Hello Amazon SNSHelloSNS.java 是“第一个 SNS 程序”其核心逻辑是用**分页器paginator**遍历列出账号中的所有 SNS 主题并打印主题 ARNpublic static void listSNSTopics(SnsClient snsClient) { try { ListTopicsIterable listTopics snsClient.listTopicsPaginator(); listTopics.stream() .flatMap(r - r.topics().stream()) .forEach(content - System.out.println( Topic ARN: content.topicArn())); } catch (SnsException e) { System.err.println(e.awsErrorDetails().errorMessage()); System.exit(1); } }从源码结构看它使用的是listTopicsPaginator()返回ListTopicsIterable而非单次listTopics()——因为 SNS 的ListTopics是分页 API主题数量多时单次调用可能只返回一部分结果分页器会自动处理nextToken。错误处理遵循本目录所有示例的统一模式捕获SnsException打印awsErrorDetails().errorMessage()后以退出码 1 结束。四、单接口示例Single Actions逐类解析原文档列出的 15 个单接口示例如下表每一行对应一次独立的 SNS API 调用命令行参数均定义在各文件的usage文本块中示例类文件主要参数CheckIfPhoneNumberIsOptedOutCheckOptOut.java手机号码ConfirmSubscriptionConfirmSubscription.javasubscriptionToken、topicArnCreateTopicCreateTopic.javatopicNameDeleteTopicDeleteTopic.javatopicArnGetSMSAttributesGetSMSAtrributes.java手机号码GetTopicAttributesGetTopicAttributes.javatopicArnListPhoneNumbersOptedOutListOptOut.java无ListSubscriptionsListSubscriptions.java无ListTopicsListTopics.java无PublishPublishTopic.javamessage、topicArnSetSMSAttributesSetSMSAttributes.java手机号码及 SMS 属性SetSubscriptionAttributesUseMessageFilterPolicy.javasubscriptionArnSetTopicAttributesSetTopicAttributes.javaattribute、topicArn、valueTagResourceAddTags.java资源 ARN 与标签UnsubscribeUnsubscribe.javasubscriptionArn4.1 主题生命周期创建、查询与属性管理创建主题。CreateTopic.java 第 24–48 行 接收一个topicName参数如mytopic构造CreateTopicRequest后调用snsClient.createTopic(request)并将返回的主题 ARN 打印出来CreateTopicRequest request CreateTopicRequest.builder() .name(topicName) .build(); result snsClient.createTopic(request); return result.topicArn();这里体现的是 SDK 2.x 的Builder 模式请求对象通过CreateTopicRequest.builder().name(...).build()构造响应对象的字段通过topicArn()等 getter 方法读取。获取与设置主题属性。GetTopicAttributes.java 传入topicArn后调用getTopicAttributes并打印result.attributes()映射SetTopicAttributes.java 第 26–34 行 则接收三个参数其中属性名attribute的有效取值为Policy、DisplayName、DeliveryPolicy对应主题策略、显示名称与投递策略三种主题级属性。4.2 订阅管理ConfirmSubscription 与过滤策略确认订阅。对于需要确认的订阅类型如 emailSubscribe操作会向端点发送一个短生命周期 tokenConfirmSubscription.java 第 49–64 行 用token与topicArn调用confirmSubscription成功后返回正式的订阅 ARN。消息过滤策略Filter Policy是本目录最有深度的单接口示例。UseMessageFilterPolicy.java 通过SetSubscriptionAttributes将一条 JSON 过滤策略挂到指定订阅上演示了五种过滤条件SNSMessageFilterPolicy fp new SNSMessageFilterPolicy(); // 单值字符串匹配 fp.addAttribute(store, example_corp); fp.addAttribute(event, order_placed); // 前缀匹配 fp.addAttributePrefix(customer_interests, bas); // anything-but 匹配 fp.addAttributeAnythingBut(customer_interests, baseball); // 值列表匹配 ArrayListString attributeValues new ArrayList(); attributeValues.add(rugby); attributeValues.add(soccer); attributeValues.add(hockey); fp.addAttribute(customer_interests, attributeValues); // 数值等值与数值区间 fp.addAttribute(price_usd, , 0); fp.addAttributeRange(price_usd, , 0, , 100); // 应用到订阅 fp.apply(snsClient, subscriptionArn);辅助类 SNSMessageFilterPolicy.java 展示了过滤策略 JSON 是如何生成的内部用MapString, Attribute收集条件Attribute.toString()按类型String/Prefix/AnythingBut/List/Numeric序列化为{prefix:...}、{anything-but:...}、[0,,100]等片段formatFilterPolicy()将其拼接为完整的策略 JSON最后apply()方法构造SetSubscriptionAttributesRequest属性名固定为FilterPolicy属性值为拼好的 JSON 字符串第 71–80 行。也就是说这个类把“手写 FilterPolicy JSON”这件容易出错的活抽象成了类型安全的 API。4.3 发布消息主题发布与 SMS 文本消息主题发布。PublishTopic.java 第 48–63 行 接收message与topicArn两个参数PublishRequest request PublishRequest.builder() .message(message) .topicArn(topicArn) .build(); PublishResponse result snsClient.publish(request); System.out.println(result.messageId() Message sent. Status is result.sdkHttpResponse().statusCode());返回值中的messageId()是消息的全局唯一标识sdkHttpResponse().statusCode()是底层 HTTP 状态码两者一起可用于验证发布成功。直接发布 SMS 文本消息。PublishTextSMS.java 的参数为message与phoneNumber格式如1XXX5550100。与主题发布不同PublishRequest这里用的是.phoneNumber(...)而非.topicArn(...)——同一 API 的两种发布目标。配套地SubscribeTextSMS.java 演示了把手机号订阅到主题的完整写法protocol(sms)endpoint(phoneNumber)returnSubscriptionArn(true)注意returnSubscriptionArn(true)只在sms、sns、application协议下有效源码用result.subscriptionArn()直接打印订阅 ARN。SMS 属性读写则分别由 GetSMSAtrributes.java 与 SetSMSAttributes.java 覆盖例如国际启用状态SNS_OPT_OUT之外的开发者 SMS 属性CheckOptOut.java 与 ListOptOut.java 分别检查单个号码是否退订、列出账号内所有退订号码。4.4 推送通知创建平台端点RegistrationExample.java 演示为移动端推送创建平台端点platform endpoint参数为token设备令牌或注册 ID——由设备平台iOS 的 APNs、Android 的 FCM在应用注册推送时提供的唯一标识platformApplicationArn平台应用的 ARN需要先通过 AWS 管理控制台创建平台应用获得。核心调用为 第 60–74 行CreatePlatformEndpointRequest endpointRequest CreatePlatformEndpointRequest.builder() .token(token) .platformApplicationArn(platformApplicationArn) .build(); CreatePlatformEndpointResponse response snsClient.createPlatformEndpoint(endpointRequest); System.out.println(The ARN of the endpoint is response.endpointArn());源码注释明确指出若未先在控制台创建平台应用此示例无法工作后续向该endpointArn发布消息即可触达设备。五、多接口组合场景Scenarios5.1 创建并发布到 FIFO 主题PriceUpdateExamplePriceUpdateExample.java 是最完整的场景示例模拟“价格更新”业务创建两个 FIFO 队列wholesale、retail与一个标准队列analytics创建一个 FIFO 主题让三个队列订阅该主题发布一条带消息属性的价格更新最后清理全部资源。命令行用法来自源码中的usage文本Usage: topicName wholesaleQueueFifoName retailQueueFifoName analyticsQueueNameFIFO 主题的关键在创建时的一组属性第 90–114 行MapString, String topicAttributes Map.of( FifoTopic, true, ContentBasedDeduplication, false, FifoThroughputScope, MessageGroup); CreateTopicRequest topicRequest CreateTopicRequest.builder() .name(topicName) // FIFO 主题名必须以 .fifo 结尾 .attributes(topicAttributes) .build();FifoTopictrue声明这是一个 FIFO 主题主题名也需以.fifo结尾测试用例中即MyTestTopic.fifoContentBasedDeduplicationfalse表示不按消息内容自动去重而是显式提供去重 IDFifoThroughputScopeMessageGroup将吞吐量作用域限定在消息组级别。发布到 FIFO 主题时必须携带两个标识第 133–167 行MessageAttributeValue msgAttValue MessageAttributeValue.builder() .dataType(String) .stringValue(wholesale) .build(); attributes.put(business, msgAttValue); PublishRequest pubRequest PublishRequest.builder() .topicArn(topicArn) .subject(Price Update) .message(payload) // {product: 214, price: 79.99} .messageGroupId(groupId) // FIFO 必填消息组 ID同组内保序 .messageDeduplicationId(UUID.randomUUID().toString()) // FIFO 必填去重 ID .messageAttributes(attributes) .build();messageGroupId决定消息的保序分组messageDeduplicationId用于 5 分钟去重窗口内丢弃重复消息messageAttributes中的businesswholesale属性可供订阅端配合过滤策略使用。队列侧的访问策略是易被忽略的一步。FIFO 主题的消息只会被 SQS 队列消费源码注释明确说明“只有 SQS 队列可以接收来自 SNS FIFO 主题的通知”。addAccessPolicyToQueuesFINAL第 192–219 行用iam-policy-builder为每个队列生成两段策略允许本账号内的主体执行SQS:*便于测试轮询与删除允许任意主体对队列执行SQS:SendMessage但附加条件aws:SourceArn等于主题 ARNIamConditionOperator.ARN_LIKE——即只有这个新主题才有权向队列投递消息这是 SNS 到 SQS 集成安全模型的核心。生成的策略 JSON 通过setQueueAttributes写入队列的POLICY属性。自动化测试印证了完整链路。PriceUpdateExampleTest.java 是一个 JUnit 5 集成测试Tag(IntegrationTest)它依次调用createQueues→createFIFOTopic(MyTestTopic.fifo)→subscribeQueues→ 附加访问策略 →publishPriceUpdate随后对每个队列执行receiveMessage并断言消息非空最后依次deleteSubscriptions、deleteQueues、deleteTopic完成清理。这验证了“发布一条消息、三个订阅队列都能收到”的扇出fan-out行为。5.2 向主题发布 SMS 消息群发原文档描述的该场景包含三步创建一个 SNS 主题把若干手机号订阅到该主题向主题发布一条消息所有订阅手机号同时收到。对应实现即 4.3 节的 CreateTopic.java、SubscribeTextSMS.java 与 PublishTopic.java 的组合——先为每个号码调用一次subscribeprotocolsms再向主题发布一次即可实现“一次发布、批量送达”。5.3 向队列发布消息交互式 SNSWorkflowREADME 引用的第五个场景是 javav2/usecases/topics_and_queues 下的 SNSWorkflow.java这是一个控制台交互程序覆盖完整生命周期见其类注释给用户三个配置选项主题/队列类型等创建 SNS 主题创建 SQS 队列获取队列 ARN 属性为队列附加 IAM 策略将队列订阅到主题向主题发布消息显示队列中的消息删除已接收的消息取消订阅删除 SNS 主题。从源码看它与 PriceUpdateExample 的差异在于显式通过EnvironmentVariableCredentialsProvider.create()从环境变量读取凭据第 86–94 行支持在交互中选择 FIFO 或非 FIFO 主题、是否设置去重与过滤并用Gson处理消息内容 JSON。运行入口要求传入一个参数账户 ID。六、构建、运行与测试6.1 构建在 javav2/example_code/sns 目录下两种等价方式# 方式一直接 Maven mvn package # 方式二Makefile 包装make 会执行 mvn package makeMakefile 只有一条有效目标all: target/sdk-sns-examples-1.0.jar其依赖规则即mvn package另提供clean目标执行mvn clean。6.2 运行单个示例run_example.sh 是推荐的运行入口用法为# 第一个参数是类名其余参数加引号原样传给该类 ./run_example.sh PublishTopic Hello SNS arn:aws:sns:us-east-1:123456789012:mytopic脚本内部把类名拼成com.example.sns.className然后执行mvn exec:java -Dexec.mainClasscom.example.sns.$className -Dexec.args$也就是说实际运行由Maven exec 插件完成不需要手动维护 classpath。如果参数不符合示例的usage定义程序会打印用法说明并以退出码 1 结束——所有单接口示例都遵循这一参数校验模式。6.3 测试本目录提供两个测试类PriceUpdateExampleTest.java如 5.1 节所述端到端验证 FIFO 主题 SQS 扇出链路AWSSNSTest.java针对单接口示例的 JUnit 测试。按 javav2 根 README 的通用说明测试基于 JUnit 5在命令行执行mvn test或在 IntelliJ 等 IDE 中直接运行。原文档特别警告这些测试会操作真实的 AWS 资源并可能产生费用建议在专门的测试账号/测试资源中运行。七、小结这套示例给出的 SDK 2.x 编程模式综合全部源码可以归纳出本目录沉淀的四条可复用经验客户端构建SnsClient.builder().region(Region.US_EAST_1).build()用完后close()PriceUpdateExample 则用SnsClient.create()静态工厂并复用静态客户端适用于长流程请求构造一律使用请求对象的 Builder字段通过类型化 getter如topicArn()、messageId()读取统一错误处理捕获SnsException输出awsErrorDetails().errorMessage()安全与清理SNS 到 SQS 集成必须为队列附加带aws:SourceArn条件的SQS:SendMessage策略场景示例都在末尾主动执行取消订阅、删队列、删主题避免残留资源持续计费。配合 javav2 根 README 中的凭据与构建说明以及本目录 15 个单接口示例与 5 个场景示例这套代码可以作为在 Java 项目中集成 Amazon SNS 的完整参考起点。赞分享示例工程教程后端【免费下载链接】aws-doc-sdk-examplesWelcome to the AWS Code Examples Repository. This repo contains code examples used in the AWS documentation, AWS SDK Developer Guides, and more. For more information, see the Readme.md file below.项目地址https://gitcode.com/gh_mirrors/aw/aws-doc-sdk-examples点击查看免费下载相关推荐使用 AWS SDK for C 编写 Hello SNS通过 ListTopics 入门 Amazon SNS使用 AWS SDK for C 编写 Hello SNS通过 ListTopics 入门 Amazon SNS 导读 本文围绕仓库中的 Hello SN示例工程教程后端AWS SDK for Java 2.x 实现 Amazon SNS 消息通知服务实践指南AWS SDK for Java 2.x 实现 Amazon SNS 消息通知服务实践指南 概述 Amazon Simple Notification Serv示例工程教程后端AWS SDK for C 实战使用 SNS 主题与 SQS 队列实现带过滤与 FIFO 的发布订阅AWS SDK for C 实战使用 SNS 主题与 SQS 队列实现带过滤与 FIFO 的发布订阅 本篇文章基于 aws doc sdk example示例工程教程后端上一篇Browserslist 项目推荐下一篇Stylelint配置与自定义指南创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考 Amazon SNS 实战指南（AWS SDK for Java 2.x）：从 Hello SNS 到 FIFO 主题与 SNS 到 SQS 扇出
示例工程教程后端【免费下载链接】aws-doc-sdk-examplesWelcome to the AWS Code Examples Repository. This repo contains code examples used in the AWS documentation, AWS SDK Developer Guides, and more. For more information, see the Readme.md file below.项目地址https://gitcode.com/gh_mirrors/aw/aws-doc-sdk-examples点击查看免费下载本文基于 aws-doc-sdk-examples 仓库中 javav2/example_code/sns/README.md 整理与扩写完整覆盖 Amazon SNS 在 Java 2.x SDK 下的入门示例、全部单接口操作、多接口组合场景与本地运行/测试方式并结合 源码实现 深入讲解 FIFO 主题、消息过滤策略与 SQS 队列订阅等关键细节。读完本文你可以独立完成从创建主题、订阅端点、发布消息到清理资源的完整 SNS 工作流并理解每个示例背后的 SDK 调用方式。一、示例集合定位与工程结构Amazon SNSSimple Notification Service简单通知服务是允许应用、终端用户和设备从云端即时收发通知的 Web 服务。本目录中的示例展示了如何使用 AWS SDK for Java 2.x 操作 SNS 的各类 API示例分为三类入门示例Get startedHelloSNS.java通过ListTopics列出账号下的所有主题作为第一个跑通的 SNS 程序单接口示例Single actions15 个独立示例每个对应一次服务 API 调用多接口场景Scenarios跨多个 API 完成完整任务的组合示例例如创建并投递 FIFO 主题消息、向队列发布消息等。从目录结构看所有 Java 源文件位于包com.example.sns下src/main/java/com/example/sns测试位于 src/test/java/com/example/sns构建配置由 pom.xml、Makefile 和 run_example.sh 共同支撑。计费与权限提醒来自原文档的 Important 章节运行这些代码可能对你的 AWS 账户产生费用运行测试同样可能产生费用建议遵循最小权限原则只授予代码完成任务所需的最小 IAM 权限这些代码并非在每一个 AWS Region 都经过测试使用前请确认你的 Region 支持相应服务。二、前置条件与构建环境2.1 运行前提按照 javav2 根目录 README 的要求运行本目录示例需要Apache Maven3.0所有 Java 2.x 示例都假设 SDK 能通过默认凭据提供器链获取 AWS 凭据例如~/.aws/config中的 SSO 配置或~/.aws/credentials中的临时凭据默认 Region 配置若未显式设置默认 Region 为us-east-1。本目录所有示例在构造SnsClient时也都显式指定了Region.US_EAST_1例如 HelloSNS.java 第 14–16 行。2.2 关键依赖来自 pom.xml依赖版本/说明software.amazon.awssdk:bom2.35.10统一管理 SDK 各模块版本software.amazon.awssdk:snsSNS 服务客户端software.amazon.awssdk:sqsSQS 服务客户端FIFO 场景与队列扇出场景使用software.amazon.sns:sns-extended-client2.1.0SNS 扩展客户端software.amazon.awssdk:iam-policy-builder用于在代码中构建 IAM 策略 JSON见 4.2 节software.amazon.awssdk:sts用于获取当前账号 IDgetCallerIdentitycom.google.code.gson:gson2.10.1交互场景中的 JSON 解析org.junit.jupiter:junit-jupiter5.11.4JUnit 5 测试log4j-core/slf4j-api日志支持工程目标 Java 版本为21pom.xml中java.version21maven-compiler-plugin 3.11.0。三、入门示例Hello Amazon SNSHelloSNS.java 是“第一个 SNS 程序”其核心逻辑是用**分页器paginator**遍历列出账号中的所有 SNS 主题并打印主题 ARNpublic static void listSNSTopics(SnsClient snsClient) { try { ListTopicsIterable listTopics snsClient.listTopicsPaginator(); listTopics.stream() .flatMap(r - r.topics().stream()) .forEach(content - System.out.println( Topic ARN: content.topicArn())); } catch (SnsException e) { System.err.println(e.awsErrorDetails().errorMessage()); System.exit(1); } }从源码结构看它使用的是listTopicsPaginator()返回ListTopicsIterable而非单次listTopics()——因为 SNS 的ListTopics是分页 API主题数量多时单次调用可能只返回一部分结果分页器会自动处理nextToken。错误处理遵循本目录所有示例的统一模式捕获SnsException打印awsErrorDetails().errorMessage()后以退出码 1 结束。四、单接口示例Single Actions逐类解析原文档列出的 15 个单接口示例如下表每一行对应一次独立的 SNS API 调用命令行参数均定义在各文件的usage文本块中示例类文件主要参数CheckIfPhoneNumberIsOptedOutCheckOptOut.java手机号码ConfirmSubscriptionConfirmSubscription.javasubscriptionToken、topicArnCreateTopicCreateTopic.javatopicNameDeleteTopicDeleteTopic.javatopicArnGetSMSAttributesGetSMSAtrributes.java手机号码GetTopicAttributesGetTopicAttributes.javatopicArnListPhoneNumbersOptedOutListOptOut.java无ListSubscriptionsListSubscriptions.java无ListTopicsListTopics.java无PublishPublishTopic.javamessage、topicArnSetSMSAttributesSetSMSAttributes.java手机号码及 SMS 属性SetSubscriptionAttributesUseMessageFilterPolicy.javasubscriptionArnSetTopicAttributesSetTopicAttributes.javaattribute、topicArn、valueTagResourceAddTags.java资源 ARN 与标签UnsubscribeUnsubscribe.javasubscriptionArn4.1 主题生命周期创建、查询与属性管理创建主题。CreateTopic.java 第 24–48 行 接收一个topicName参数如mytopic构造CreateTopicRequest后调用snsClient.createTopic(request)并将返回的主题 ARN 打印出来CreateTopicRequest request CreateTopicRequest.builder() .name(topicName) .build(); result snsClient.createTopic(request); return result.topicArn();这里体现的是 SDK 2.x 的Builder 模式请求对象通过CreateTopicRequest.builder().name(...).build()构造响应对象的字段通过topicArn()等 getter 方法读取。获取与设置主题属性。GetTopicAttributes.java 传入topicArn后调用getTopicAttributes并打印result.attributes()映射SetTopicAttributes.java 第 26–34 行 则接收三个参数其中属性名attribute的有效取值为Policy、DisplayName、DeliveryPolicy对应主题策略、显示名称与投递策略三种主题级属性。4.2 订阅管理ConfirmSubscription 与过滤策略确认订阅。对于需要确认的订阅类型如 emailSubscribe操作会向端点发送一个短生命周期 tokenConfirmSubscription.java 第 49–64 行 用token与topicArn调用confirmSubscription成功后返回正式的订阅 ARN。消息过滤策略Filter Policy是本目录最有深度的单接口示例。UseMessageFilterPolicy.java 通过SetSubscriptionAttributes将一条 JSON 过滤策略挂到指定订阅上演示了五种过滤条件SNSMessageFilterPolicy fp new SNSMessageFilterPolicy(); // 单值字符串匹配 fp.addAttribute(store, example_corp); fp.addAttribute(event, order_placed); // 前缀匹配 fp.addAttributePrefix(customer_interests, bas); // anything-but 匹配 fp.addAttributeAnythingBut(customer_interests, baseball); // 值列表匹配 ArrayListString attributeValues new ArrayList(); attributeValues.add(rugby); attributeValues.add(soccer); attributeValues.add(hockey); fp.addAttribute(customer_interests, attributeValues); // 数值等值与数值区间 fp.addAttribute(price_usd, , 0); fp.addAttributeRange(price_usd, , 0, , 100); // 应用到订阅 fp.apply(snsClient, subscriptionArn);辅助类 SNSMessageFilterPolicy.java 展示了过滤策略 JSON 是如何生成的内部用MapString, Attribute收集条件Attribute.toString()按类型String/Prefix/AnythingBut/List/Numeric序列化为{prefix:...}、{anything-but:...}、[0,,100]等片段formatFilterPolicy()将其拼接为完整的策略 JSON最后apply()方法构造SetSubscriptionAttributesRequest属性名固定为FilterPolicy属性值为拼好的 JSON 字符串第 71–80 行。也就是说这个类把“手写 FilterPolicy JSON”这件容易出错的活抽象成了类型安全的 API。4.3 发布消息主题发布与 SMS 文本消息主题发布。PublishTopic.java 第 48–63 行 接收message与topicArn两个参数PublishRequest request PublishRequest.builder() .message(message) .topicArn(topicArn) .build(); PublishResponse result snsClient.publish(request); System.out.println(result.messageId() Message sent. Status is result.sdkHttpResponse().statusCode());返回值中的messageId()是消息的全局唯一标识sdkHttpResponse().statusCode()是底层 HTTP 状态码两者一起可用于验证发布成功。直接发布 SMS 文本消息。PublishTextSMS.java 的参数为message与phoneNumber格式如1XXX5550100。与主题发布不同PublishRequest这里用的是.phoneNumber(...)而非.topicArn(...)——同一 API 的两种发布目标。配套地SubscribeTextSMS.java 演示了把手机号订阅到主题的完整写法protocol(sms)endpoint(phoneNumber)returnSubscriptionArn(true)注意returnSubscriptionArn(true)只在sms、sns、application协议下有效源码用result.subscriptionArn()直接打印订阅 ARN。SMS 属性读写则分别由 GetSMSAtrributes.java 与 SetSMSAttributes.java 覆盖例如国际启用状态SNS_OPT_OUT之外的开发者 SMS 属性CheckOptOut.java 与 ListOptOut.java 分别检查单个号码是否退订、列出账号内所有退订号码。4.4 推送通知创建平台端点RegistrationExample.java 演示为移动端推送创建平台端点platform endpoint参数为token设备令牌或注册 ID——由设备平台iOS 的 APNs、Android 的 FCM在应用注册推送时提供的唯一标识platformApplicationArn平台应用的 ARN需要先通过 AWS 管理控制台创建平台应用获得。核心调用为 第 60–74 行CreatePlatformEndpointRequest endpointRequest CreatePlatformEndpointRequest.builder() .token(token) .platformApplicationArn(platformApplicationArn) .build(); CreatePlatformEndpointResponse response snsClient.createPlatformEndpoint(endpointRequest); System.out.println(The ARN of the endpoint is response.endpointArn());源码注释明确指出若未先在控制台创建平台应用此示例无法工作后续向该endpointArn发布消息即可触达设备。五、多接口组合场景Scenarios5.1 创建并发布到 FIFO 主题PriceUpdateExamplePriceUpdateExample.java 是最完整的场景示例模拟“价格更新”业务创建两个 FIFO 队列wholesale、retail与一个标准队列analytics创建一个 FIFO 主题让三个队列订阅该主题发布一条带消息属性的价格更新最后清理全部资源。命令行用法来自源码中的usage文本Usage: topicName wholesaleQueueFifoName retailQueueFifoName analyticsQueueNameFIFO 主题的关键在创建时的一组属性第 90–114 行MapString, String topicAttributes Map.of( FifoTopic, true, ContentBasedDeduplication, false, FifoThroughputScope, MessageGroup); CreateTopicRequest topicRequest CreateTopicRequest.builder() .name(topicName) // FIFO 主题名必须以 .fifo 结尾 .attributes(topicAttributes) .build();FifoTopictrue声明这是一个 FIFO 主题主题名也需以.fifo结尾测试用例中即MyTestTopic.fifoContentBasedDeduplicationfalse表示不按消息内容自动去重而是显式提供去重 IDFifoThroughputScopeMessageGroup将吞吐量作用域限定在消息组级别。发布到 FIFO 主题时必须携带两个标识第 133–167 行MessageAttributeValue msgAttValue MessageAttributeValue.builder() .dataType(String) .stringValue(wholesale) .build(); attributes.put(business, msgAttValue); PublishRequest pubRequest PublishRequest.builder() .topicArn(topicArn) .subject(Price Update) .message(payload) // {product: 214, price: 79.99} .messageGroupId(groupId) // FIFO 必填消息组 ID同组内保序 .messageDeduplicationId(UUID.randomUUID().toString()) // FIFO 必填去重 ID .messageAttributes(attributes) .build();messageGroupId决定消息的保序分组messageDeduplicationId用于 5 分钟去重窗口内丢弃重复消息messageAttributes中的businesswholesale属性可供订阅端配合过滤策略使用。队列侧的访问策略是易被忽略的一步。FIFO 主题的消息只会被 SQS 队列消费源码注释明确说明“只有 SQS 队列可以接收来自 SNS FIFO 主题的通知”。addAccessPolicyToQueuesFINAL第 192–219 行用iam-policy-builder为每个队列生成两段策略允许本账号内的主体执行SQS:*便于测试轮询与删除允许任意主体对队列执行SQS:SendMessage但附加条件aws:SourceArn等于主题 ARNIamConditionOperator.ARN_LIKE——即只有这个新主题才有权向队列投递消息这是 SNS 到 SQS 集成安全模型的核心。生成的策略 JSON 通过setQueueAttributes写入队列的POLICY属性。自动化测试印证了完整链路。PriceUpdateExampleTest.java 是一个 JUnit 5 集成测试Tag(IntegrationTest)它依次调用createQueues→createFIFOTopic(MyTestTopic.fifo)→subscribeQueues→ 附加访问策略 →publishPriceUpdate随后对每个队列执行receiveMessage并断言消息非空最后依次deleteSubscriptions、deleteQueues、deleteTopic完成清理。这验证了“发布一条消息、三个订阅队列都能收到”的扇出fan-out行为。5.2 向主题发布 SMS 消息群发原文档描述的该场景包含三步创建一个 SNS 主题把若干手机号订阅到该主题向主题发布一条消息所有订阅手机号同时收到。对应实现即 4.3 节的 CreateTopic.java、SubscribeTextSMS.java 与 PublishTopic.java 的组合——先为每个号码调用一次subscribeprotocolsms再向主题发布一次即可实现“一次发布、批量送达”。5.3 向队列发布消息交互式 SNSWorkflowREADME 引用的第五个场景是 javav2/usecases/topics_and_queues 下的 SNSWorkflow.java这是一个控制台交互程序覆盖完整生命周期见其类注释给用户三个配置选项主题/队列类型等创建 SNS 主题创建 SQS 队列获取队列 ARN 属性为队列附加 IAM 策略将队列订阅到主题向主题发布消息显示队列中的消息删除已接收的消息取消订阅删除 SNS 主题。从源码看它与 PriceUpdateExample 的差异在于显式通过EnvironmentVariableCredentialsProvider.create()从环境变量读取凭据第 86–94 行支持在交互中选择 FIFO 或非 FIFO 主题、是否设置去重与过滤并用Gson处理消息内容 JSON。运行入口要求传入一个参数账户 ID。六、构建、运行与测试6.1 构建在 javav2/example_code/sns 目录下两种等价方式# 方式一直接 Maven mvn package # 方式二Makefile 包装make 会执行 mvn package makeMakefile 只有一条有效目标all: target/sdk-sns-examples-1.0.jar其依赖规则即mvn package另提供clean目标执行mvn clean。6.2 运行单个示例run_example.sh 是推荐的运行入口用法为# 第一个参数是类名其余参数加引号原样传给该类 ./run_example.sh PublishTopic Hello SNS arn:aws:sns:us-east-1:123456789012:mytopic脚本内部把类名拼成com.example.sns.className然后执行mvn exec:java -Dexec.mainClasscom.example.sns.$className -Dexec.args$也就是说实际运行由Maven exec 插件完成不需要手动维护 classpath。如果参数不符合示例的usage定义程序会打印用法说明并以退出码 1 结束——所有单接口示例都遵循这一参数校验模式。6.3 测试本目录提供两个测试类PriceUpdateExampleTest.java如 5.1 节所述端到端验证 FIFO 主题 SQS 扇出链路AWSSNSTest.java针对单接口示例的 JUnit 测试。按 javav2 根 README 的通用说明测试基于 JUnit 5在命令行执行mvn test或在 IntelliJ 等 IDE 中直接运行。原文档特别警告这些测试会操作真实的 AWS 资源并可能产生费用建议在专门的测试账号/测试资源中运行。七、小结这套示例给出的 SDK 2.x 编程模式综合全部源码可以归纳出本目录沉淀的四条可复用经验客户端构建SnsClient.builder().region(Region.US_EAST_1).build()用完后close()PriceUpdateExample 则用SnsClient.create()静态工厂并复用静态客户端适用于长流程请求构造一律使用请求对象的 Builder字段通过类型化 getter如topicArn()、messageId()读取统一错误处理捕获SnsException输出awsErrorDetails().errorMessage()安全与清理SNS 到 SQS 集成必须为队列附加带aws:SourceArn条件的SQS:SendMessage策略场景示例都在末尾主动执行取消订阅、删队列、删主题避免残留资源持续计费。配合 javav2 根 README 中的凭据与构建说明以及本目录 15 个单接口示例与 5 个场景示例这套代码可以作为在 Java 项目中集成 Amazon SNS 的完整参考起点。赞分享示例工程教程后端【免费下载链接】aws-doc-sdk-examplesWelcome to the AWS Code Examples Repository. This repo contains code examples used in the AWS documentation, AWS SDK Developer Guides, and more. For more information, see the Readme.md file below.项目地址https://gitcode.com/gh_mirrors/aw/aws-doc-sdk-examples点击查看免费下载相关推荐使用 AWS SDK for C 编写 Hello SNS通过 ListTopics 入门 Amazon SNS使用 AWS SDK for C 编写 Hello SNS通过 ListTopics 入门 Amazon SNS 导读 本文围绕仓库中的 Hello SN示例工程教程后端AWS SDK for Java 2.x 实现 Amazon SNS 消息通知服务实践指南AWS SDK for Java 2.x 实现 Amazon SNS 消息通知服务实践指南 概述 Amazon Simple Notification Serv示例工程教程后端AWS SDK for C 实战使用 SNS 主题与 SQS 队列实现带过滤与 FIFO 的发布订阅AWS SDK for C 实战使用 SNS 主题与 SQS 队列实现带过滤与 FIFO 的发布订阅 本篇文章基于 aws doc sdk example示例工程教程后端上一篇Browserslist 项目推荐下一篇Stylelint配置与自定义指南创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考