申请资源__快速入门_消息队列 MQ-阿里云
在 MQ 消息系统中,消息发布者将消息发送到某个指定的消息主题(Topic) ,而消息订阅者则通过订阅该指定的 Topic 来获取和消费消息。因此一个新的应用接入 MQ 需要先申请相关的 MQ 资源,包括消息主题(Topic)的创建,以及为 Topic 建立消息生产关系(Producer ID)和消息消费关系(Consumer ID)。
创建 Topic
消息主题(Topic)是 MQ 里对消息进行的一级归类,比如可以创建“Topic_Trade”这一主题用来识别交易类消息。使用MQ的第一步需要先为您的应用申请 Topic 资源,即创建 Topic。
您可以按照以下步骤创建 Topic:
登录 MQ 控制台,默认进入发布订阅管理>Topic 管理页面:https://ons.console.aliyun.com/
在页面左上方选择相应的域(比如公网测试域),然后单击页面右上角的发布 Topic 按钮。
注意:
- 如果只是测试,或者需要在本地(非阿里云 ECS 服务器)使用 MQ 服务,请将 Topic 创建在公网环境,并且本地服务器需要能够访问公网。
- 如果在生产环境使用 MQ 服务,需要将应用部署在阿里云 ECS 上。请在应用程序所在的的域创建 Topic。
- Topic 不能跨域使用。比如 Topic 创建在“华北1”这个域,那么消息生产端和消费端也必须运行在“华北1”的 ECS 上。
- 有关域的详细介绍请参见阿里云 ECS 文档地域选择说明。
在发布 Topic 对话框输入 Topic 名称及备注,单击确定。您创建的 Topic 将出现在 Topic 列表中。
注意: Topic 名称必须全局唯一。如果名称已经被其他用户使用,您将无法创建相同名称的 Topic。
创建 Producer ID
创建好 Topic 后,要为这个 Topic 申请消息生产端的资源,即创建 Producer ID。一个 Topic 只能对应一个 Producer ID。
请按照以下步骤为您的 Topic 创建 Producer ID:
在 MQ 控制台左侧菜单栏依次单击发布订阅管理>Topic 管理。
在 Topic 列表中找到您刚刚创建的 Topic,单击操作选项中的申请发布。
在申请发布对话框输入 Producer ID,单击确定。
注意:
- Producer ID 必须全局唯一。如果名称已存在,您将无法创建相同名称的 Producer ID。
- Topic对应的生产端必须和这个 Topic 在同一个域,比如您在“公网测试”域创建了“Topic_open”,那么和“Topic_open”对应的 Producer ID 也必须在同一个域。
- Producer ID 和 Topic 的关系是 1:N,即一个 Topic 只能绑定一个 Producer ID, 但是同一个 Producer ID 可以对应多个 Topic。
创建 Consumer ID
创建好消息生产关系后,您需要为 Topic 申请相应的消息消费资源,即创建 Consumer ID。
请按以下步骤创建 Consumer ID:
在 MQ 控制台左侧菜单栏依次单击发布订阅管理>Topic 管理。
找到您创建的 Topic,单击右侧操作选项里的申请订阅。
在订阅 Topic对话框输入 Consumer ID,单击确定。
注意:
- Consumer ID 必须全局唯一。如果名称已存在,您将无法创建相同名称的 Consumer ID。
- Consumer ID 必须和对应的 Topic 在同一个域,比如给“公网测试”域的“Topic_open”绑定 Consumer ID “CID_123”后,“华北1”域内的“Topic_huabei1”将不能绑定同一个 Consumer ID。
- Consumer ID 和 Topic 的关系是 N:N。同一个 Consumer ID 可以订阅多个 Topic,同一个 Topic 也可以对应多个 Consumer ID。
创建阿里云 AccessKey,SecretKey
在调用 SDK/API 进行消息发送和订阅的时候,除了需要指定创建的 Topic, Producer ID 以及 Consumer ID 以外,还需输入您在阿里云服务器管理控制台创建的身份验证信息,即 AccessKey 和 SecretKey。
请登录阿里云服务器管理控制台创建密钥。如果您已经创建了 AccessKey 和 SecrectKey,也可以返回此页面查看密钥。
完成以上准备工作后,您就可以运行示例代码,用 MQ 进行消息发送和订阅了。
最后更新:2016-11-23 18:53:32
上一篇:
开通服务__快速入门_消息队列 MQ-阿里云
下一篇:
订阅消息__快速入门_消息队列 MQ-阿里云
SetLoadBalancerUDPListenerAttribute__Listener相关API_API 参考_负载均衡-阿里云
ForwardEntrySetType__数据类型_API 参考_云服务器 ECS-阿里云
数加控制台帮助__平台介绍_数加平台介绍-阿里云
获取应用操作记录__应用管理类 API_Open API 参考_企业级分布式应用服务 EDAS-阿里云
CNAME回源___产品功能说明_产品常见问题_DDoS 高防IP-阿里云
MaxCompute数据源配置__数据源配置_数据同步手册_用户操作指南_大数据开发套件-阿里云
磁盘种类表__附录_API 参考_云服务器 ECS-阿里云
ECS Windows系统抓包工具Wireshark的安装使用__网络连接问题_网络问题_Windows操作运维问题_云服务器 ECS-阿里云
指定宽高缩略__图片缩放_老版图片服务手册_对象存储 OSS-阿里云
查询媒体-使用OSS文件地址__媒体接口_API使用手册_视频点播-阿里云
相关内容
常见错误说明__附录_大数据计算服务-阿里云
发送短信接口__API使用手册_短信服务-阿里云
接口文档__Android_安全组件教程_移动安全-阿里云
运营商错误码(联通)__常见问题_短信服务-阿里云
设置短信模板__使用手册_短信服务-阿里云
OSS 权限问题及排查__常见错误及排除_最佳实践_对象存储 OSS-阿里云
消息通知__操作指南_批量计算-阿里云
设备端快速接入(MQTT)__快速开始_阿里云物联网套件-阿里云
查询API调用流量数据__API管理相关接口_API_API 网关-阿里云
使用STS访问__JavaScript-SDK_SDK 参考_对象存储 OSS-阿里云