C++ rocketmq-client-cpp-1.2.1简单使用

•  前言
•  下载
•  特征
•  编译
•  简单使用
• •  生产者
  •  消费者

RocketMQ-Client-CPP是Apache RocketMQ的C/C++客户端，是一个具有低延迟、高性能和高可靠性、万亿级容量和灵活可扩展性的分布式消息传递和流平台。

如有理解不对的地方，欢迎各位指出，大家共同交流和学习。 如有帮助，请点赞加支持！ 送人玫瑰手有余香！

https://github.com/apache/rocketmq-client-cpp

• 同步或异步生成消息，包括正常消息和延迟消息。
• 在集群或广播模型中，并发或有序地消费消息
• c 和 c++ 风格的 API。
• 跨平台，所有功能都支持 Windows、Linux 和 Mac OS。
• 在生产和消费过程中自动重新平衡。
• 可靠性，任何停机代理或名称服务器对客户端没有影响。

参考如下：
Linux 下 rocketmq-client-cpp 2.2.0 编译
https://blog.csdn.net/lang523493505/article/details/120823618

vi synProducer.cpp

#include 
#include 
#include 
#include 

using namespace std;
using namespace rocketmq;


void syncSendMessage();


// 测试main方法
int main() {
    syncSendMessage();
}



DefaultMQProducer initProducer() {
    // 初始化消息生产者，并设置生产者组名称
    DefaultMQProducer producer("group1");
    // 设置服务地址
    producer.setNamesrvAddr("192.168.159.5:9876");
    // 请确保参数设置完成在启动之前
    producer.start();
    return producer;
}


void syncSendMessage() {
    // 初始化消息生产者
    DefaultMQProducer producer = initProducer();
    // 记录时间
    auto start = std::chrono::system_clock::now();
    int count = 10;
    for (int i = 0; i < count; ++i) {
        string mess="Hello "+to_string(i);//消息内容
        // 初始化消息内容
        MQMessage msg(
                "topic1",  			//主题
                "TAG",     			//标签
                "keys",
                mess  // 消息内容
        );

        try {
            // 发送消息
            SendResult sendResult = producer.send(msg);
            std::cout << "发送结果:" << sendResult.getSendStatus() << ", 消息ID: " << sendResult.getMsgId()<<"消息: "<
            std::cout << "ErrorCode: " << e.GetError() << " Exception:" << e.what() << std::endl;
        }
    }  
    // 打印发送结果
    std::cout << "成功发送 " << count << " 个消息！"< 
编译
 
g++ -o ./bin/synProducer  synProducer.cpp -I ./include/ -L./bin/ -lrocketmq -lpthread -lz -ldl -lrt -std=c++11
 
执行
 
[root@localhost bin]# ./synProducer
发送结果:0, 消息ID: 0100007F0000CD4600004CD9FD7E0100消息: Hello 0
发送结果:0, 消息ID: 0100007F0000CD4600000AE5FD7E0200消息: Hello 1
发送结果:0, 消息ID: 0100007F0000CD4600000DE5FD7E0300消息: Hello 2
发送结果:0, 消息ID: 0100007F0000CD4600000FE5FD7E0400消息: Hello 3
发送结果:0, 消息ID: 0100007F0000CD46000013E5FD7E0500消息: Hello 4
发送结果:0, 消息ID: 0100007F0000CD46000015E5FD7E0600消息: Hello 5
发送结果:0, 消息ID: 0100007F0000CD46000016E5FD7E0700消息: Hello 6
发送结果:0, 消息ID: 0100007F0000CD46000017E5FD7E0800消息: Hello 7
发送结果:0, 消息ID: 0100007F0000CD46000018E5FD7E0900消息: Hello 8
发送结果:0, 消息ID: 0100007F0000CD46000019E5FD7E0A00消息: Hello 9
成功发送 10 个消息！
 
 消费者 
vi synConsumer.cpp
 
#include 
#include 
#include 
#include 
#include "CPushConsumer.h"
#include "CMessageExt.h"

using namespace std;

// 消费消息
int doConsumeMessage(struct CPushConsumer *consumer, CMessageExt *msgExt)
{
    cout << "[收到消息：] " << "消息主题:" << GetMessageTopic(msgExt) << ", 消息标签:" << GetMessageTags(msgExt)
        << ", 消息key值:" << GetMessageKeys(msgExt) << ",消息内容:" << GetMessageBody(msgExt) << endl;

    return E_CONSUME_SUCCESS;
}

int main(int argc, char *argv[])
{
    CPushConsumer *consumer = CreatePushConsumer("group1");
    SetPushConsumerNameServerAddress(consumer, "192.168.159.5:9876");
    Subscribe(consumer, "topic1", "*");
    // 注册消息回调函数
    RegisterMessageCallback(consumer, doConsumeMessage);
    // start push consumer
    StartPushConsumer(consumer);
    cout << "Push consumer start, and listening message within 1min..." << endl;
    for (int i = 0; i < 6; i++)
    {
        cout << "Already Running: " << (i * 10) << "S" << endl;
        usleep(1000);
    }
    // shutdown push consumer
    ShutdownPushConsumer(consumer);
    // destroy push consumer
    DestroyPushConsumer(consumer);
    cout << "PushConsumer Shutdown!" << endl;

    return 0;
}

 
编译
 
g++ -o ./bin/synConsumer synConsumer.cpp -I ./include/ -L./bin/ -lrocketmq -lpthread -lz -ldl -lrt -std=c++11
 
执行
 
[root@localhost bin]# ./synConsumer
[收到消息：] 消息主题:topic1, 消息标签:TAG, 消息key值:keys,消息内容:Hello 3
[收到消息：] 消息主题:topic1, 消息标签:TAG, 消息key值:keys,消息内容:Hello 7
[收到消息：] 消息主题:topic1, 消息标签:TAG, 消息key值:keys,消息内容:Hello 0
[收到消息：] 消息主题:topic1, 消息标签:TAG, 消息key值:keys,消息内容:Hello 4
[收到消息：] 消息主题:topic1, 消息标签:TAG, 消息key值:keys,消息内容:Hello 8
[收到消息：] 消息主题:topic1, 消息标签:TAG, 消息key值:keys,消息内容:Hello 1
[收到消息：] 消息主题:topic1, 消息标签:TAG, 消息key值:keys,消息内容:Hello 5
[收到消息：] 消息主题:topic1, 消息标签:TAG, 消息key值:keys,消息内容:Hello 9
[收到消息：] 消息主题:topic1, 消息标签:TAG, 消息key值:keys,消息内容:Hello 2
[收到消息：] 消息主题:topic1, 消息标签:TAG, 消息key值:keys,消息内容:Hello 6
Push consumer start, and listening message within 1min...
Already Running: 0S
Already Running: 10S
Already Running: 20S
Already Running: 30S
Already Running: 40S
Already Running: 50S
PushConsumer Shutdown