全部产品
云市场

接口和参数说明

更新时间:2019-07-18 16:31:31

消息队列 RocketMQ 提供 Java SDK 实现消息发送与订阅,您可通过本文了解消息发送和订阅相关接口的参数说明。

通用参数

参数名 参数说明
NAMESRV_ADDR 设置 TCP 协议接入点,从消息队列 RocketMQ 控制台的实例详情页面获取
AccessKey 您在阿里云账号管理控制台中创建的 AccessKeyId,用于身份认证
SecretKey 您在阿里云账号管理控制台中创建的 AccessKeySecret,用于身份认证
OnsChannel 用户渠道,默认值为:ALIYUN,聚石塔用户为:CLOUD

消息发送接口

Java SDK 发布接口使用说明

消息发送参数

参数名 参数说明
SendMsgTimeoutMillis 设置消息发送的超时时间,单位:毫秒,默认值:3000
CheckImmunityTimeInSeconds(事务消息) 设置事务消息第一次回查的最快时间,单位:秒
shardingKey(顺序消息) 顺序消息中用来计算不同分区的值

消息订阅接口

Java SDK 订阅接口使用说明

消息订阅参数

参数名 参数说明
GROUP_ID 您在消息队列 RocketMQ 控制台上创建的 Group ID,详情参见名词解释
MessageModel 设置 Consumer 实例的消费模式,取值说明如下:
  • CLUSTERING(默认值):表示集群消费
  • BROADCASTING:表示广播消费
ConsumeThreadNums 设置 Consumer 实例的消费线程数,默认值:20
MaxReconsumeTimes 设置消息消费失败的最大重试次数,默认值:16
ConsumeTimeout 设置每条消息消费的最大超时时间,超过设置时间则被视为消费失败,等下次重新投递再次消费。每个业务需要设置一个合理的值,单位:分钟。 默认值:15
suspendTimeMillis(顺序消息) 只适用于顺序消息,设置消息消费失败的重试间隔时间
maxCachedMessageAmount 客户端本地的最大缓存消息数据,默认值:1000;单位:条
maxCachedMessageSizeInMiB 客户端本地的最大缓存消息大小,取值范围:16 MB ~ 2 GB;默认值:512 MB

更多信息

消息收发代码示例