天翼云分布式消息服务RocketMQ c++ sdk示例

分布式消息服务RocketMQ

简介/价格/文档

天翼云分布式消息服务RocketMQ c++ sdk示例

文档简介：

RocketMQ中，提供SDK供应用使用。SDK包括JAVA与C++版本。需要注意的是，C++相比于JAVA，不提供以下功能： namesrv不支持http方式不提供自动创建Topic功能在生产者功能上，不提供事务消息、SendByGroupID(按Hash值发送)的功能在消息者功能上，不提供PUSH消费功能参见：天翼云-分布式消息服务-RocketMQ-API说明文档（C++）.pdf

*产品来源：中国电信天翼云。免费试用咨询热线：400-826-7010，为您提供专业的售前咨询，让您快速了解云产品，助您轻松上云！微信咨询

免费试用、价格特惠

文档详情

RocketMQ中，提供SDK供应用使用。SDK包括JAVA与C++版本。

需要注意的是，C++相比于JAVA，不提供以下功能：

namesrv不支持http方式

不提供自动创建Topic功能

在生产者功能上，不提供事务消息、SendByGroupID(按Hash值发送)的功能

在消息者功能上，不提供PUSH消费功能

参见：天翼云-分布式消息服务-RocketMQ-API说明文档（C++）.pdf

相似文档

天翼云分布式消息服务RocketMQ生产者应用进程、生产组、生产实例的关系
同一进程内，同一生产组不能有相同的实例，如图：
天翼云分布式消息服务RocketMQ生产者实例的创建和销毁
使用CTGFactory进行创建Producer实例【强制规范】； Prouder是重量级的实例，每次创建、销毁都会消耗系统资源，建议系统启动的时候创建，系统退出的时候关闭，禁止每次发送消息创建新的实例【强制规范】。
天翼云分布式消息服务RocketMQ生产者客户端参数建议
常量字段说明 CompressMsgBodyOverHowmuch 消息体多大时开始压缩，默认4k SendMaxRetryTime 发送失败默认重试次数，默认2 SendMsgTimeout 发送超时时间，默认3s MaxMessageSize 消息最大字节数，默认1024 * 128，消息体超过该值，消息发送失败，该值需根据具体的业务估算消息体大小设置
天翼云分布式消息服务RocketMQ消费者应用进程、消费组、消费者实例的关系
消费组可以有多个消费者实例，如图：
天翼云分布式消息服务RocketMQ消费者同组Consumer订阅关系一致
RocketMQ 里的一个 Consumer Group 代表一个 Consumer 群组。对于大多数分布式应用来说，一个 Consumer Group 下通常会有多个 Consumer 实例。订阅关系一致指的是同一个 Consumer Group 下所有 Consumer 实例的处理逻辑必须完全一致，一旦订阅关系不一致，消息消费的逻辑就会混乱，甚至导致消息丢失。

文档中心

全民上云·上云补贴申领

免费试用（限企业）