本文介绍您在使用开源 Java SDK 接入阿里云 RocketMQ 时,需要配置的参数。

通用参数

参数名 参数说明
NAMESRV_ADDR 设置 TCP 协议接入点,从阿里云 RocketMQ 控制台的实例详情页面获取。
AccessKey 您在阿里云账号管理控制台中创建的 AccessKeyId,用于身份认证。
SecretKey 您在阿里云账号管理控制台中创建的 AccessKeySecret,用于身份认证。
AccessChannel 用于指定使用云上消息轨迹,上云设置为:AccessChannel:CLOUD。

消息发送参数

参数名 参数说明
producerGroup Producer 组名,多个 Producer 如果属于一个应用,发送同样的消息,则应该将它们归为同一组,即您在阿里云 RocketMQ 控制台上创建的 Group ID,详情请参见名词解释
sendMsgTimeout 发送消息超时时间,单位:毫秒。
compressMsgBodyOverHowmuch 消息 Body 超过多大开始压缩(Consumer 收到消息会自动解压缩),单位:字节,默认值:4 KB。
retryTimesWhenSendFailed 如果消息发送失败,最大重试次数,该参数只对同步发送模式起作用。
maxMessageSize 客户端限制的消息大小,超过报错,同时服务端也会限制,所以需要跟服务端配合使用, 默认值:4 MB,单位:字节。

消息订阅参数

参数名 参数说明
consumerGroup Consumer 组名,多个 Consumer 如果属于一个应用,订阅同样的消息,且消费逻辑一致,则应该将它们归为同一组,即您在阿里云 RocketMQ 控制台上创建的 Group ID,详情请参见名词解释
consumeFromWhere 新的 Consumer Group 启动后,用于确定从何处开始拉取,默认从最新位点拉取。
consumeThreadMin 消费线程池最小线程数,默认值:20。
consumeThreadMax 消费线程池最大线程数,默认值:20。请与最小线程数保持一致。
consumeConcurrentlyMaxSpan 单队列并行消费位点允许的最大跨度,默认值:2000,允许区间为 [1, 65535]。
pullThresholdForQueue 拉消息本地队列缓存消息最大数,默认值:1000,单位:条,允许区间为 [1, 65535]。
pullThresholdSizeForQueue 单队列本地最大缓存消息数量,默认值:100,单位:MB,允许区间为 [1,1024]。
maxReconsumeTimes 最大重试次数,默认值:16,单位:次。
suspendCurrentQueueTimeMillis 顺序消息最小重试间隔,默认值:1000,单位:毫秒,允许区间为[10,30000]。

更多信息