参数说明

本文介绍您在使用社区版Java SDK接入阿里云云消息队列 RocketMQ 版时,需要配置的参数。

通用参数

参数名

参数说明

NAMESRV_ADDR

设置TCP协议接入点,从云消息队列 RocketMQ 版控制台实例详情页面获取。

AccessKey

AccessKey ID,阿里云身份验证标识。获取方式,请参见创建AccessKey

SecretKey

AccessKey Secret,阿里云身份验证密钥。获取方式,请参见创建AccessKey

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]。

更多信息