C++ RabbitMQ生产者消息确认

Question

有偿提问(¥100)，求一份C++ 写的，RabbitMQ生产者的消息确认代码，最好是调用rabbitmq.4.dll的，谢谢。

Answer 1

让 “紫雾凌寒” 来帮你回答,本回答结合 DeepSeek

如果还有问题，请评论或点击头像私信，如果有帮助到您, 请关注、采纳、点赞

1. 关键点分析：
   - 了解RabbitMQ的基本概念，特别是消息确认机制。
   - 熟悉C++ 语言以及如何调用动态链接库（.dll）。
   - 掌握使用RabbitMQ C++ 客户端库（通过rabbitmq.4.dll）来实现生产者消息确认功能。
2. 解决方案：
   - 首先，确保你已经安装了RabbitMQ C++ 客户端库并能正确链接到rabbitmq.4.dll。
   - 以下是一个简单的C++ 生产者代码示例，包含消息确认功能：

#include <iostream>
#include <rabbitmq-c/amqp.h>
#include <rabbitmq-c/amqp_tcp_socket.h>

int main() {
    amqp_connection_state_t conn;
    amqp_channel_t channel;
    amqp_bytes_t exchange_name = amqp_cstring_bytes("my_exchange");
    amqp_bytes_t routing_key = amqp_cstring_bytes("my_routing_key");
    amqp_bytes_t message_body = amqp_cstring_bytes("Hello, RabbitMQ!");

    // 创建连接
    conn = amqp_new_connection();
    amqp_socket_t *socket = amqp_tcp_socket_new(conn);
    if (!socket) {
        std::cerr << "Failed to create TCP socket" << std::endl;
        return 1;
    }
    if (amqp_socket_open(socket, "localhost", 5672) != 0) {
        std::cerr << "Failed to open socket" << std::endl;
        return 1;
    }

    // 登录
    amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN, "guest", "guest");

    // 创建通道
    channel = amqp_channel_open(conn, 1);
    if (channel < 0) {
        std::cerr << "Failed to open channel" << std::endl;
        return 1;
    }

    // 声明交换器
    amqp_exchange_declare(
        conn,
        channel,
        exchange_name,
        amqp_cstring_bytes("direct"),
        0, 1, 0,
        amqp_empty_table
    );

    // 发布消息
    amqp_basic_properties_t props;
    props._flags = AMQP_BASIC_CONTENT_TYPE_FLAG | AMQP_BASIC_DELIVERY_MODE_FLAG;
    props.content_type = amqp_cstring_bytes("text/plain");
    props.delivery_mode = 2; // 持久化消息

    amqp_basic_publish(
        conn,
        channel,
        exchange_name,
        routing_key,
        0,  // mandatory
        0,  // immediate
        &props,
        message_body
    );

    // 等待确认
    amqp_basic_ack(conn, channel, amqp_get_rpc_reply(conn).reply_type == AMQP_RESPONSE_NORMAL);

    // 关闭通道和连接
    amqp_channel_close(conn, channel, AMQP_REPLY_SUCCESS);
    amqp_connection_close(conn, AMQP_REPLY_SUCCESS);
    amqp_destroy_connection(conn);

    return 0;
}

1. 方案优缺点：
   - 优点：
   • 代码结构清晰，按照RabbitMQ的操作流程逐步实现，包括连接、登录、创建通道、声明交换器、发布消息和确认消息等步骤。
   • 使用了RabbitMQ C++ 客户端库的标准接口，具有较好的兼容性和可维护性。
   • 缺点：
   • 代码中硬编码了一些配置信息，如用户名、密码、交换器名称、路由键等，不够灵活，实际应用中可能需要从配置文件读取。
   • 错误处理相对简单，仅打印了错误信息，没有更详细的错误处理逻辑。
2. 总结：
   这段代码展示了如何使用RabbitMQ C++ 客户端库通过rabbitmq.4.dll实现一个简单的生产者，并启用了消息确认功能。通过连接到RabbitMQ服务器，创建通道，声明交换器，发布消息并等待确认，最后关闭连接，完成了一个基本的消息生产流程。在实际应用中，可根据需求进一步优化配置读取和错误处理等部分。

希望以上解答对您有所帮助。如果您有任何疑问，欢迎在评论区提出。