You need to enable JavaScript to run this app.
导航
参数说明
最近更新时间:2023.07.05 16:17:13首次发布时间:2023.07.04 21:17:30

本文介绍您在使用 C++ SDK 接入火山引擎消息队列 RocketMQ版时,需要配置的参数。

消息发送参数

参数

是否必选

说明

配置方式

setInstanceName

在单个进程启动多个客户端时必选

客户端标识(Client ID)。一个进程中需要创建多个 RocketMQ 客户端连接不同实例时,需要通过 InstanceName 区分客户端连接。

producer.setInstanceName("instance")

setSendMsgTimeout

可选

发送消息的超时时间,时间单位 ms,默认 3000 ms。

producer.setSendMsgTimeout(5 * 1000)

setRetryTimes

可选

重试次数。默认 5 次。

producer.setRetryTimes(3)

setMaxMessageSize

可选

单条消息大小,单位为 KB,默认 128KB。

primitive.Interceptor

setSessionCredentials

必选

RocketMQ实例的密钥,即您在火山引擎控制台中、RocketMQ实例的密钥管理页面创建的密钥,用于身份认证。
注意:此处的密钥并非火山引擎主账号AccessKey。

producer.setSessionCredentials("accessKey", "secretKey", "accessChannel")

setCompressMsgBodyOverHowmuch

可选

消息长度超过该数值将自动将消息进行压缩,默认为4 KB,单位为字节。

producer.setCompressMsgBodyOverHowmuch(4 * 1024)

setTransactionListener

可选

事务消息监听器,事务消息必须设置。

producer.setTransactionListener(new MyTransactionListener())

消息消费参数

参数

是否必选

说明

配置方式

setMessageModel

可选

消费模式。默认为 CLUSTERING,即集群模式。

  • BROADCASTING 广播模式
  • CLUSTERING 集群模式

consumer.setMessageModel(CLUSTERING)

setConsumeFromWhere

可选

新的 Consumer Group 启动后,用于确定从何处开始拉取,只有第一次设置才会生效。取值包括:

  • CONSUME_FROM_LAST_OFFSET:从上次消费位置继续消费。新建的Consumer Group选择此参数将从起始位置开始消费。
  • CONSUME_FROM_FIRST_OFFSET:从起始位置开始消费。选择此参数时,可能发生重复消费,请根据实际业务情况选择。
  • CONSUME_FROM_TIMESTAMP:从指定时间戳开始消费。小于指定时间戳的消息将不会被消费。

consumer.setConsumeFromWhere(CONSUME_FROM_LAST_OFFSET);

setConsumeThreadCount

可选

设置消费线程的数量。

consumer.setConsumeThreadCount(5)

setSessionCredentials

必选

RocketMQ实例的密钥,即您在火山引擎控制台中、RocketMQ实例的密钥管理页面创建的密钥,用于身份认证。
注意:此处的密钥并非火山引擎主账号AccessKey。

consumer.setSessionCredentials("ak", "sk", "VOLC");

setMaxReconsumeTimes

可选

消费最大重试次数,默认为 -1,即重试 16 次。

consumer.setMaxReconsumeTimes(10)

setMaxCacheMsgSizePerQueue

可选

每个队列可以缓存的数据大小,单位为字节,默认为 1KB。

consumer.setMaxCacheMsgSizePerQueue(1000)