在控制台创建消息主题(Topic)后,用户可以通过控制台或者调用SDK来发布消息。 控制台主要用于调试和检验资源的可用性,生产环节建议使用SDK来进行消息的发送。
已经创建主题和订阅,并且状态处于服务中。
已经创建了用户的AK和SK。
在主题列表找到想要发布消息的主题,点击操作列的“发布消息”。
填写消息主题(可选),选择消息格式
填写消息属性,可以为消息设置一些消息属性方便订阅者通过筛选策略筛选消息,或者只是为不同消息分类。
选择”发布消息“,消息将发布到主题。
接收消息:订阅终端之后就会收到刚才发布到主题的消息,订阅者可以登陆订阅终端查看。
SDK推荐您使用AWS SNS SDK, 京东云队列服务支持了AWS SNS SDK的接口。在使用SDK的时候,您需要配置4个参数:Accesskey、Secretkey、Endpoint和Region。其中AK&SK您在之前AccessKey管理页面已经创建,Endpoint和Region您可以点击控制台“接入点地址”获取, Endopint为一个HTTP/S的地址,Region为所选地域的英文代号,如下图所示。
以Go SDK为例进行说明,其他方式及开发语言请参考其他章节。
1.安装AWS SDK for Go
go get github.com/aws/aws-sdk-go
2.初始化,将AK&SK、接入点地址和Region信息填入。
var ses *session.Session
regionId := Config().Region
accessKey := Config().AccountConfig.AccessKey
secretKey := Config().AccountConfig.SecretKey
endPoint := Config().JnsServerConfig.JnsServer
ses, _ = session.NewSession(&aws.Config{
Region: aws.String(regionId),
Credentials: credentials.NewStaticCredentials(accessKey, secretKey, ""),
Endpoint: aws.String(endPoint),
//DisableSSL: aws.Bool(true),
})
_, err := ses.Config.Credentials.Get()
if err != nil {
log.Fatal("凭据创建失败")
}
client := sns.New(ses)
我们的产品专家为您找到最合适的产品/解决⽅案
1v1线上咨询获取售前专业咨询
专业产品顾问,随时随地沟通