【计算机网络通信 AMQP】使用 Qt 调用 qamqp 库进行 AMQP 通信

news2025/3/15 15:36:23

以下是一个使用 Qt 实现 AMQP 通信的代码示例。为了实现这个功能，我们可以使用 qamqp 库，它是一个基于 Qt 的 AMQP 客户端库。首先，你需要将 qamqp 库添加到你的 Qt 项目中，可以通过 qmake 或 CMake 进行配置。

#include <QCoreApplication>
#include <QDebug>
#include <qamqpclient.h>
#include <qamqpexchange.h>
#include <qamqpqueue.h>


int main(int argc, char *argv[])
{
    QCoreApplication a(argc, argv);


    // 创建 AMQP 客户端对象
    QAmqpClient amqpClient;


    // 连接到 AMQP 服务器
    amqpClient.connectToHost("localhost");


    // 当客户端连接成功时，触发 connected 信号
    QObject::connect(&amqpClient, &QAmqpClient::connected, [&]() {
        qDebug() << "Connected to AMQP server";


        // 创建交换器
        QAmqpExchange *exchange = amqpClient.createExchange("myExchange");


        // 当交换器创建成功时，触发 opened 信号
        QObject::connect(exchange, &QAmqpExchange::opened, [&]() {
            qDebug() << "Exchange opened";


            // 声明一个队列
            QAmqpQueue *queue = amqpClient.createQueue("myQueue");


            // 当队列创建成功时，触发 opened 信号
            QObject::connect(queue, &QAmqpQueue::opened, [&]() {
                qDebug() << "Queue opened";


                // 绑定队列到交换器
                queue->bind(exchange, "myRoutingKey");


                // 当队列收到消息时，触发 messageReceived 信号
                QObject::connect(queue, &QAmqpQueue::messageReceived, [&](const QAmqpMessage &message) {
                    qDebug() << "Received message:" << message.payload();


                    // 确认消息
                    queue->ack(message);
                });


                // 开始消费队列中的消息
                queue->consume(QAmqpQueue::coNoAck);


                // 发布消息
                QString payload = "Hello, AMQP!";
                exchange->publish(payload.toUtf8(), "myRoutingKey");
                qDebug() << "Published message:" << payload;
            });


            // 打开队列
            queue->open();
        });


        // 打开交换器
        exchange->open();
    });


    // 当客户端连接断开时，触发 disconnected 信号
    QObject::connect(&amqpClient, &QAmqpClient::disconnected, [&]() {
        qDebug() << "Disconnected from AMQP server";
    });


    return a.exec();
}

代码解释

头文件导入：
- QCoreApplication：Qt 核心应用程序类，是 Qt 应用程序的基础。
- QDebug：用于输出调试信息。
- QAmqpClient：AMQP 客户端类，用于连接到 AMQP 服务器。
- QAmqpExchange：表示 AMQP 交换器，用于发送消息。
- QAmqpQueue：表示 AMQP 队列，用于接收消息。
创建 AMQP 客户端对象：
- QAmqpClient amqpClient; 创建一个 AMQP 客户端对象，用于后续的 AMQP 操作。
连接到 AMQP 服务器：
- amqpClient.connectToHost("localhost"); 发起连接到 AMQP 服务器的操作，这里假设服务器地址为 localhost。
连接成功后的操作：
- 使用 QObject::connect 连接 connected 信号，当客户端成功连接到 AMQP 服务器时，会触发该信号。在信号的槽函数中：
  - 打印连接成功的消息。
  - 创建一个交换器 QAmqpExchange *exchange = amqpClient.createExchange("myExchange");。
  - 连接交换器的 opened 信号，当交换器创建成功时，触发该信号。在信号的槽函数中：
    - 打印交换器打开的消息。
    - 创建一个队列 QAmqpQueue *queue = amqpClient.createQueue("myQueue");。
    - 连接队列的 opened 信号，当队列创建成功时，触发该信号。在信号的槽函数中：
      - 打印队列打开的消息。
      - 绑定队列到交换器 queue->bind(exchange, "myRoutingKey");。
      - 连接队列的 messageReceived 信号，当队列收到消息时，触发该信号。在信号的槽函数中：
        打印收到的消息并确认消息 queue->ack(message);。
        开始消费队列中的消息 queue->consume(QAmqpQueue::coNoAck);。
      - 发布消息 exchange->publish(payload.toUtf8(), "myRoutingKey");。
连接断开后的操作：
- 使用 QObject::connect 连接 disconnected 信号，当客户端断开连接时，会触发该信号。在信号的槽函数中，打印断开连接的消息。