阿里云消息队列使用教程

创建资源

在消息队列中,消息的生产和消费需要通过主题订阅的形式,故用户首先要创建消息主题(topic),发送消息到某个指定的消息主题,而消费者通过订阅该消费主题进行消息消费。
阿里云消息队列开通地址 https://www.aliyun.com/product/rocketmq
阿里云消息队列官方使用教程 https://help.aliyun.com/product/29530.html

注意事项
用户默认在一个region最多只能创建10个topic,如有需要可以提工单增加。
对于某个topic的订阅ConsumerGroup数量没有限制。

步骤一:创建消费主题

  • 进入阿里云控制台,菜单互联网中间件-消息队列-Topic管理。
  • 首先选择想要创建资源的区域(比如华北),然后点击“新建”按钮,创建topic。
  • 创建topic中需要填写“topic名称”、选择消息类型和填写备注。
  • 说明:

  • topic名称为全局唯一,如果有相同名称的topic被创建,则无法创建成功。并且topic只能包含字母、数字、连字符(-)、下划线(_)、波形符(~)或加号(+),长度为3-64个字符。
  • 消息类型为普通消息和全局顺序消息。
  • 普通消息:不保证先入先出(FIFO)的顺序消费,包含普通消息和延时消息。
  • 全局顺序消息:消息的生产和消费按照消息的发布顺序进行(FIFO)。

步骤二:添加订阅

  • 在Topic管理页面中,找到想要订阅的topic,在操作中可以选择订阅。
  • 在添加订阅者中需要新建/绑定已有ConsumerGroupID,选择传送类型。
  • 填写取出消息隐藏时长、死信队列设置和最大接收次数等参数,如果无特殊需求可保持默认配置不变。
  • 说明:

  • ConsumerGroupID为全局唯一,如果有相同名称的ConsumerGroupID被创建,则无法创建成功。并且ConsumerGroupID只能包含字母、数字、连字符(-)和下划线(_),长度7-64字符。
  • ConsumerGroupID和topic的关系是多对多关系(N:M),同一个ConsumerGroupID可以订阅多个topic,同一个topic可以对应多个ConsumerGroupID。
  • 取出消息隐藏时长为接收的消息对于其他消费者不可见的时间长度,范围:30秒-600秒。
  • 死信队列设置参数决定是否开启topic的死信队列。
  • 最大接收次数是将消息发送到死信队列之前允许接收该消息的最大次数,范围:0-16次。
  • 步骤三:创建AccessKey和SecretKey

在调用消息队列的SDK或者openAPI进行消息的发送消费和管理操作时候,还需要验证用户的身份信息,即需要在控制台创建AccessKey和SecretKey。

创建方法:

在阿里云用户中心账户管理下的AccessKey管理页面申请AccessKey和SecretKey密钥对(简称AK/SK)。AK/SK信息请妥善保管,如果遗失可能会造成非法用户使用此信息操作你在云上的资源,给你造成数据和财产损失。AK/SK密钥对允许启用、禁用,启用后可用其调用OpenAPI,禁用后不能用其调用OpenAPI。