RabbitMQ-c 使用教程

RabbitMQ-c是一个C语言的客户端库，用于与RabbitMQ通信。以下是RabbitMQ-c的使用教程：

1. 下载和安装RabbitMQ-c库
可以从RabbitMQ-c的官方网站下载RabbitMQ-c库，下载完后解压缩即可。接着，打开终端窗口，进入解压缩后的目录，输入如下命令进行安装：

   $ mkdir build && cd build
   $ cmake .. && make && sudo make install

2. 创建连接并声明队列
首先，我们需要创建一个连接对象，并声明需要使用的队列。这可以通过以下代码实现：

   amqp_connection_state_t conn;
   conn = amqp_new_connection();
   amqp_socket_t *socket = amqp_tcp_socket_new(conn);
   amqp_socket_open(socket, "localhost", 5672);
   amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN, "guest", "guest");
   amqp_channel_open(conn, 1);
   amqp_queue_declare(conn, 1, amqp_cstring_bytes("hello"), 0, 0, 0, 1, amqp_empty_table);

3. 发送和接收消息
发送和接收消息需要使用basic_publish和basic_consume方法。以下是发送和接收消息的示例代码：

   // 发送消息
   char message[] = "Hello World!";
   amqp_bytes_t message_bytes = amqp_cstring_bytes(message);
   amqp_basic_publish(conn, 1, amqp_empty_bytes, amqp_cstring_bytes("hello"), 0, 0, NULL, message_bytes);

   // 接收消息
   amqp_basic_consume(conn, 1, amqp_cstring_bytes("hello"), amqp_empty_bytes, 0, 1, 0, amqp_empty_table);
   amqp_frame_t frame;
   int result = amqp_simple_wait_frame(conn, &frame);
   if (result < 0) {
       return -1;
   }
   if (frame.payload.method.id != AMQP_BASIC_DELIVER_METHOD) {
       return -1;
   }
   amqp_message_t message;
   result = amqp_read_message(conn, frame.channel, &message, NULL);
   if (result < 0) {
       return -1;
   }
   printf("Received message: %.*s\n", (int)message.body.len, (char*)message.body.bytes);
   amqp_destroy_message(&message);

4. 关闭连接
在使用完RabbitMQ-c之后，需要关闭连接。可以通过以下代码实现：

   amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS);
   amqp_connection_close(conn, AMQP_REPLY_SUCCESS);
   amqp_destroy_connection(conn);