操作场景
本文以调用 C++ SDK 为例介绍通过开源 SDK 实现消息收发的操作过程，帮助您更好地理解消息收发的完整过程。
前提条件
操作步骤
步骤1：环境准备
1. 安装客户端相关的库 C and C++ 库， 本文以 AMQP-CPP 为例。
2. 导入动态库和头文件。
步骤2：生产消息
1. 建立连接。
auto evbase = event_base_new();LibEventHandlerMyError hndl(evbase);// 建立连接AMQP::TcpConnection connection(&hndl, AMQP::Address("amqp://admin:eyJrZXlJZC...@amqp-xxx.rabbitmq.ap-sh.public.tencenttdmq.com:5672/amqp-xxx|vhost-cpp"));// 服务地址格式为 amqp://username:password@host:port/vhost// 建立通道AMQP::TcpChannel channel(&connection);channel.onError([&evbase](const char *message) {std::cout << "Channel error: " << message << std::endl;event_base_loopbreak(evbase);});
参数 | 说明 |
host | 集群接入地址，在集群基本信息页面的客户端接入模块获取。  |
port | 集群接入地址中的端口号。 |
username | 用户名称，填写在控制台创建的用户名称。 |
password | 用户密码，填写在控制台创建用户时填写的密码。 |
vhost | Vhost 名称，在控制台 Vhost 列表获取。 |
2. 发送消息。
// 声明交换机channel.declareExchange(exchange_name, AMQP::ExchangeType::direct);// 发送消息到交换机channel.publish(exchange_name, routing_key, "Hello client this is a info message");event_base_dispatch(evbase);event_base_free(evbase);
参数 | 说明 |
exchange_name | Exchange 名称，可在控制台 Exchange 列表获取。 |
routing_key | 消息队列支持的routing key |
步骤3：消费消息
1. 建立连接。
ConnHandler handler;// 建立连接AMQP::TcpConnection connection(handler, AMQP::Address(host, part, AMQP::Login(username, password), vhost));// 建立通道AMQP::TcpChannel channel(&connection);channel.onError([&handler](const char *message) {std::cout << "Channel error: " << message << std::endl;handler.Stop();});
参数 | 说明 |
host | 集群接入地址，在集群基本信息页面的客户端接入模块获取。  |
port | 集群接入地址中的端口号。 |
username | 用户名称，填写在控制台创建的用户名称。 |
password | 用户密码，填写在控制台创建用户时填写的密码。 |
vhost | Vhost 名称，在控制台 Vhost 列表获取。 |
2. 声明交换机、消息队列，并将消息队列绑定到交换机。
// 声明交换机channel.declareExchange(exchange_name, AMQP::ExchangeType::direct);// 声明消息队列channel.declareQueue(queue_name, AMQP::durable);// 绑定消息队列到交换机channel.bindQueue(exchange_name, queue_name, routing_key);
参数 | 说明 |
exchange_name | Exchange 名称，可在控制台 Exchange 列表获取。 |
queue_name | 消息队列名称，可在控制台 Queue 列表获取。 |
routing_key | 消息队列支持的 routing key |
3. 订阅消息。
// 订阅消息channel.consume(queue_name).onReceived([&channel](const AMQP::Message &msg, uint64_t tag, bool redelivered) {// 处理消息std::cout << "Received: " << msg.body() << std::endl;// 回复ack， 消费失败可回复rejectchannel.ack(tag);});handler.Start();
参数 | 说明 |
queue_name | 消息队列名称，可在控制台 Queue 列表获取。 |
说明