当前位置：首页 > news >正文

麒麟V10 SP1 + Qt + Qpid Proton 连接 Apache Artemis 实战指南

news 2026/6/15 6:38:50

麒麟V10 SP1 + Qt + Qpid Proton 连接 Apache Artemis 实战指南

一、背景

在企业级消息中间件场景中，Apache Artemis 作为高性能、多协议的 ActiveMQ 替代品，广泛用于生产环境。然而，在国产操作系统麒麟 V10 SP1 上，使用 Qt 框架通过 AMQP 1.0 协议连接 Artemis 却有不少坑。本文记录了从零开始搭建 Qt 项目、集成 Qpid Proton 库、解决各种编译和运行时错误的完整过程。

二、环境概览

操作系统：麒麟 V10 SP1（基于 Debian/Ubuntu）
Qt 版本：5.12 / 5.15（通过 apt 安装）
编译器：GCC（系统自带）
目标 Broker：Apache Artemis 2.53.0（AMQP 1.0 端口 5672）
客户端库：Qpid Proton 0.22.0（C++ 绑定）

三、安装 Qpid Proton 库

麒麟 V10 的 apt 源中包含libqpid-proton-cpp12-dev和libqpid-proton11-dev，直接安装即可：

sudoaptupdatesudoaptinstall-ylibqpid-proton-cpp12-dev libqpid-proton11-dev

验证安装：

# 头文件应在 /usr/include/proton/ls/usr/include/proton/messaging_handler.hpp# 库文件应在 /usr/lib/x86_64-linux-gnu/ls/usr/lib/x86_64-linux-gnu/libqpid-proton-cpp.so

注意：某些情况下.so符号链接可能缺失，需要手动创建：

sudoln-sf/usr/lib/x86_64-linux-gnu/libqpid-proton-cpp.so.12\/usr/local/lib/libqpid-proton-cpp.sosudoln-sf/usr/lib/x86_64-linux-gnu/libqpid-proton.so.11\/usr/local/lib/libqpid-proton.sosudoldconfig

四、Qt 项目配置

4.1 创建项目

在 Qt Creator 中选择“Qt Widgets Application”，取消勾选“Create form”（不使用 .ui 文件）。项目名称为ArtemisClient。

4.2`.pro`文件

QT += core gui network greaterThan(QT_MAJOR_VERSION, 4): QT += widgets TARGET = ArtemisClient CONFIG += c++11 # Proton 库路径 INCLUDEPATH += /usr/include LIBS += -L/usr/lib/x86_64-linux-gnu LIBS += -lqpid-proton-cpp -lqpid-proton -lssl -lcrypto -lpthread # 运行时 RPATH（防止加载不到 .so） QMAKE_RPATHLINKDIR *= /usr/lib/x86_64-linux-gnu SOURCES += \ amqpworker.cpp \ main.cpp \ mainwindow.cpp HEADERS += \ amqpworker.h \ mainwindow.h

五、核心代码实现

5.1 AMQP Worker 类 (`amqpworker.h`/`amqpworker.cpp`)

由于 Qpid Proton 0.22 的 API 与高版本有所不同，需特别注意以下几点：

使用proton::container::connect()建立连接，再通过connection.open_sender()/open_receiver()创建链路。
连接选项通过proton::connection_options设置，并通过connect()传入。
消息体解码时，判断v.type() == proton::STRING或proton::BINARY。

amqpworker.h（仅声明，不包含 Proton 头文件）：

#ifndefAMQPWORKER_H#defineAMQPWORKER_H#include<QObject>#include<QString>classAmqpWorker:publicQObject{Q_OBJECTpublic:explicitAmqpWorker(constQString&connUrl,constQString&address,constQString&user,constQString&pass,QObject*parent=nullptr);~AmqpWorker();publicslots:voidstartContainer();voidrequestStop();voidsendMessage(constQString&body);signals:voidconnected();voiddisconnected();voidmessageReceived(constQString&from,constQString&body);voiderrorOccurred(constQString&err);voidlog(constQString&txt);private:classImpl;Impl*d;};#endif// AMQPWORKER_H

amqpworker.cpp（包含 Proton 头文件）：

#include"amqpworker.h"#include<proton/messaging_handler.hpp>#include<proton/container.hpp>#include<proton/connection.hpp>#include<proton/connection_options.hpp>#include<proton/sender.hpp>#include<proton/receiver.hpp>#include<proton/message.hpp>#include<proton/delivery.hpp>#include<proton/url.hpp>#include<thread>#include<atomic>classAmqpWorker::Impl:publicQObject,publicproton::messaging_handler{Q_OBJECTpublic:Impl(conststd::string&url,conststd::string&addr,conststd::string&user,conststd::string&pass):m_url(url),m_addr(addr),m_user(user),m_pass(pass){}voidon_container_start(proton::container&c)override{emitlog("🚀 Container starting...");proton::connection_options opts;if(!m_user.empty()){opts.user(m_user);opts.password(m_pass)