在 Ubuntu 下使用 rabbitmq-c 库进行 RabbitMQ 消息收发的完整示例代码如下

本文主要是介绍在 Ubuntu 下使用 rabbitmq-c 库进行 RabbitMQ 消息收发的完整示例代码如下，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

在 Ubuntu 下使用 rabbitmq-c 库进行 RabbitMQ 消息收发的完整示例代码如下。这个示例将包括声明队列、绑定路由键、发送消息、消费消息等步骤，并且会包含错误处理。
安装 rabbitmq-c 库
首先确保已经安装了 rabbitmq-c 库。可以通过以下命令在 Ubuntu 上安装：
sudo apt-get install librabbitmq-dev
示例代码
以下是一个简单的 C++ 程序，展示了如何使用 rabbitmq-c 库连接到 RabbitMQ 服务器，并进行消息收发。

#include <iostream>
#include <cstring>
#include <cstdlib>
#include <cstdio>
#include <unistd.h>
#include <amqp.h>
#include <amqp_tcp_socket.h>// RabbitMQ 服务器连接信息
#define RABBITMQ_HOSTNAME   "localhost"
#define RABBITMQ_PORT       5672
#define RABBITMQ_USERNAME   "guest"
#define RABBITMQ_PASSWORD   "guest"// 队列和交换机名称
#define QUEUE_NAME          "test_queue"
#define EXCHANGE_NAME       "test_exchange"
#define ROUTING_KEY         "test_routing_key"// 错误处理宏
#define die(message) \do { \std::cerr << (message) << std::endl; \std::exit(1); \} while (0)int main() {amqp_socket_t *socket = NULL;amqp_connection_state_t conn;// 初始化连接conn = amqp_new_connection();// 建立 TCP 连接socket = amqp_tcp_socket_new(conn);if (!socket) {die("创建 TCP socket 失败");}int status = amqp_socket_open(socket, RABBITMQ_HOSTNAME, RABBITMQ_PORT);if (status) {die("打开 RabbitMQ 连接失败");}// 登录到 RabbitMQ 服务器amqp_rpc_reply_t login_reply = amqp_log

这篇关于在 Ubuntu 下使用 rabbitmq-c 库进行 RabbitMQ 消息收发的完整示例代码如下的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---