在 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