关于Aws SNS的使用小结

冷不防 2022-12-16 06:19 285阅读 0赞

### 文章目录 ###

*  1. SNS概述
 *  2. 代码实现
 *  3. SQS subscription

# 1. SNS概述 #

关于SNS的功能可以参考官网的介绍：[SNS官方介绍][SNS]

# 2. 代码实现 #

官方提供了两个版本的demo，[下载源码][Link 1]后可以很方便地找到example，至少大部分是可以的。  
以下是总结使用javav2版本的SNS使用，[AWS官网例子][AWS]也有介绍，但是涉及到一些Client配置都是默认配置所以主要对这些部分需要作出小结。

1.  首先导入依赖：

<dependency>
      <groupId>software.amazon.awssdk</groupId>
      <artifactId>sns</artifactId>
    </dependency>
    <dependency>
      <groupId>software.amazon.awssdk</groupId>
      <artifactId>regions</artifactId>
    </dependency>

1.  发送notification功能（[完整代码][Link 2]）：

public static Boolean sendNotification(SnsClient snsClient, String message, String topicArn, String subject, Map<String, String> attributesMap) { 
            final Map<String, MessageAttributeValue> messageAttributes = new HashMap<>();
            attributesMap.forEach((key, value) -> messageAttributes.put(key, MessageAttributeValue.builder().dataType("String").stringValue(value).build()));
    
            PublishRequest request = PublishRequest.builder()
                    .message(message)
                    .messageAttributes(messageAttributes)
                    .topicArn(topicArn)
                    .subject(subject)
                    .build();
            PublishResponse result = snsClient.publish(request);
    
            return result.sdkHttpResponse().statusCode() == 200;
        }

**注**：关于详细的参数列表可以参考：[Request Parameters][]

# 3. SQS subscription #

1.  现在涉及到一个需求就是，通过send notification到SNS的topic，然后SNS会把message发到SQS，也就是说Client直接从SQS的queue来取消息。
2.  先进入到[Aws console][]，直接输入Topic Name就可以创建了。
3.  创建完成后点右下方的“Create subscription”，创建订阅者。  
    ![Create subscription][]
4.  在Protocal那里选择SQS，并且Endpoint选择对应的queue的arn就可以了。  
    ![Protocal][]
5.  订阅成功之后，Topic的Subscriptions如图。  
    ![Subscriptions][]
6.  至此，只要通过\#2的代码发送notification到SNS，就能在SQS的queue poll messages了。

**注**：

1.  关于MessageAttributeValue的配置如果不符合指定格式很容易导致异常，具体的参数配置参考：[MessageAttributeValue Method Detail][]
2.  关于PublishRequest的具体参数配置参考：[PublishRequest Method Summary][]

**附**：  
3. 关于java1版本的SNS官网例子比较全，可以参考：[Amazon Simple Notification Service][]

[SNS]: https://docs.aws.amazon.com/sns/latest/dg/welcome.html
[Link 1]: https://github.com/awsdocs/aws-doc-sdk-examples/tree/master/javav2
[AWS]: https://docs.aws.amazon.com/sdk-for-java/v2/developer-guide/examples-simple-notification-service.html
[Link 2]: https://download.csdn.net/download/BAStriver/12965841
[Request Parameters]: https://docs.aws.amazon.com/zh_cn/sns/latest/api/API_Publish.html
[Aws console]: https://console.aws.amazon.com/sns/v3/home?region=us-east-1#/create-topic
[Create subscription]: /images/20221123/ab2d5878b296469eb19cf4f602037ae9.png
[Protocal]: /images/20221123/690fb4e55554497e998877dbe6c6e8c9.png
[Subscriptions]: /images/20221123/30356fa8f0dd4158ab7a9d806218e575.png
[MessageAttributeValue Method Detail]: https://sdk.amazonaws.com/java/api/latest/software/amazon/awssdk/services/sns/model/MessageAttributeValue.html
[PublishRequest Method Summary]: https://sdk.amazonaws.com/java/api/latest/index.html?software/amazon/awssdk/services/sns/model/PublishRequest.html
[Amazon Simple Notification Service]: https://docs.amazonaws.cn/en_us/sns/latest/dg/sns-tutorial-publish-message-with-attributes.html