文档中心

消息队列 RocketMQ版

C++ SDK

参数说明

参数说明

本文介绍您在使用 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)

最近更新时间：2025.07.09 16:22:42

这个页面对您有帮助吗？

有用

有用

无用

无用