使循环在C中工作并在RabbitMQ中对消息进行排队

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <amqp.h>
#include <amqp_tcp_socket.h>

int main() {
    // 连接到RabbitMQ服务器
    amqp_connection_state_t 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_get_rpc_reply(conn);

    // 声明队列
    amqp_queue_declare(conn, 1, amqp_cstring_bytes("my_queue"), 0, 0, 0, 1, amqp_empty_table);
    amqp_get_rpc_reply(conn);

    // 发送消息
    int message_count = 10;
    for (int i = 0; i < message_count; i++) {
        char message[256];
        sprintf(message, "Message %d", i);
        amqp_basic_publish(conn, 1, amqp_cstring_bytes(""), amqp_cstring_bytes("my_queue"), 0, 0, NULL, amqp_cstring_bytes(message));
    }

    // 接收消息
    for (int i = 0; i < message_count; i++) {
        amqp_frame_t frame;
        amqp_basic_get(conn, 1, amqp_cstring_bytes("my_queue"), 1);
        amqp_simple_wait_frame(conn, &frame);
        if (frame.payload.method.id == AMQP_BASIC_GET_EMPTY_METHOD) {
            break;
        }
        amqp_basic_get_ok_t *get_ok = (amqp_basic_get_ok_t *) frame.payload.method.decoded;
        amqp_message_t message;
        amqp_simple_wait_frame(conn, &frame);
        if (frame.payload.method.id != AMQP_BASIC_DELIVER_METHOD) {
            break;
        }
        amqp_basic_deliver_t *deliver = (amqp_basic_deliver_t *) frame.payload.method.decoded;
        amqp_simple_wait_frame(conn, &frame);
        if (frame.payload.properties.body_size > sizeof(message.body)) {
            break;
        }
        message.body.len = frame.payload.properties.body_size;
        memcpy(message.body.bytes, frame.payload.properties.body_fragment.bytes, frame.payload.properties.body_size);
        printf("Received message: %.*s\n", (int) message.body.len, (char *) message.body.bytes);
        amqp_basic_ack(conn, 1, deliver->delivery_tag, 0);
    }

    // 关闭连接
    amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS);
    amqp_connection_close(conn, AMQP_REPLY_SUCCESS);
    amqp_destroy_connection(conn);

    return 0;
}