8. 第7节 如何使用C++接入RocketMQ
本教程将演示如何使用C++发送、消费消息。
本教程将简单演示如何发送和消费消息。当前环境已经安装了一个1Namesrv + 1Broker的集群, 演示代码路径:
cd /data/demos
安装cpp动态库以及gcc相关环境 (实验环境均安装, 可以忽略)
1.1 安装g++,gcc等
yum install gcc gcc-c++ make -y
1.2 安装cpp 动态库
wget https://github.com/apache/rocketmq-client-cpp/releases/download/2.0.0/rocketmq-client-cpp-2.0.0-centos7.x86_64.rpm sudo rpm -ivh rocketmq-client-cpp-2.0.0-centos7.x86_64.rpm
2. 下载RocketMQ C++ 代码demo
git clone https://github.com/ApacheRocketMQ/05-cpp-demo.git cd 05-cpp-demo
3. 执行生产者demo代码
如下图,找到当前实验环境的公网ip
启动命令添加正确的namesrv地址,可以看到正常生产和消费输出
// 打包 make clean && make // 执行代码demo ./main xxx.xxx.xxx.xxx:9876
3. Demo代码说明
RocketMQ C++ Client中生产者、消费者使用的套路和golang client十分相似, 只是生产者、消费者属性是初始化的时候直接设置。
比如生产者代码demo如下:
全部代码可以查看实验本地或者github