文章目錄

• 1. SNS概述
• 2. 代碼實現
• 3. SQS subscription

1. SNS概述

關于SNS的功能可以參考官網的介紹：SNS官方介紹

2. 代碼實現

官方提供了兩個版本的demo，下載源碼后可以很方便地找到example，至少大部分是可以的。
以下是總結使用javav2版本的SNS使用，AWS官網例子也有介紹，但是涉及到一些Client配置都是默認配置所以主要對這些部分需要作出小結。

首先導入依賴：

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

發(fā)送notification功能（完整代碼）：

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

現在涉及到一個需求就是，通過send notification到SNS的topic，然后SNS會把message發(fā)到SQS，也就是說Client直接從SQS的queue來取消息。

先進入到Aws console，直接輸入Topic Name就可以創(chuàng)建了。

創(chuàng)建完成后點右下方的“Create subscription”，創(chuàng)建訂閱者。

在Protocal那里選擇SQS，并且Endpoint選擇對應的queue的arn就可以了。

訂閱成功之后，Topic的Subscriptions如圖。

至此，只要通過#2的代碼發(fā)送notification到SNS，就能在SQS的queue poll messages了。

注：

關于MessageAttributeValue的配置如果不符合指定格式很容易導致異常，具體的參數配置參考：MessageAttributeValue Method Detail

關于PublishRequest的具體參數配置參考：PublishRequest Method Summary

附：
3. 關于java1版本的SNS官網例子比較全，可以參考：Amazon Simple Notification Service

總結

以上是生活随笔為你收集整理的关于Aws SNS的使用 小结的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。