消息队列RocketMQ版是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式消息中间件。

参数说明

参数 描述 类型 是否必须 默认值
TCP接入点 TCP协议接入点，从消息队列RocketMQ控制台的实例详情页面获取。 String 是 无
AccessKey 您的AccessKey ID，用于身份认证。 String 是 无
AccessKey Secret 您的AccessKey Secret，用于身份认证。 String 是 无

订阅消息

参数 描述 类型 是否必须 默认值
Topic 订阅消息的主题名。 String 是 无
consumerGroup 消费者的Group ID，可在RocketMQ版控制台创建。 String 是 无
subExpression 消息过滤表达式，满足表达式的消息才会被订阅。
说明 仅支持或运算，如tag1 || tag2 || tag3，如果设置为空和星号（*），则表示全部订阅。
String 否 无
messageModel 消费模式。
  • CLUSTERING：集群消费模式。
  • BROADCASTING：广播消费模式。
String 是 CLUSTERING

发送消息

参数 描述 类型 是否必须 默认值
Topic 发送消息的主题名。 String 是 无
发送组（ProducerGroup） 发送消息的Group ID。 String 否 无
sendTag 可理解为Gmail中的标签，对消息进行再归类，方便消费者指定过滤条件在消息队列RocketMQ的服务器过滤。 String 否 无
sendKey 消息的业务标识，由消息生产者设置，唯一标识某个业务逻辑。 String 否 无
sendMsgTimeoutMillis 消息发送的超时时间，单位毫秒。 String 否 无