XEngine_MQService
GitHub
基于 XEngine V9+ 驱动 · MIT 开源协议

开箱即用的高性能 C/C++
消息队列与分发中间件

XEngine_MQService 提供统一的标准 API 接口，无需繁琐二次开发即可直接投产。原生支持 TCP、WebSocket、MQTT 与 HTTP 协议，兼顾主动拉取与被动订阅推送模式。

获取源码 (GitHub) 观看架构视频教程
TCP / 私有高速协议
WebSocket 实时长连接
MQTT 物联网协议
HTTP 管理与验证接口

全场景消息队列特性

从物联网终端通信到企业级后端异步解耦，提供灵活、可靠的消息生命周期管理。

双模式分发 & 点对点通信

同时支持消费者**主动投递获取模式（Pull）**与**被动订阅通知模式（Push）**，支持广播订阅及精准点对点（P2P）消息投递。

消息序列与历史回溯

内置严格的主题分区与消息序列号管理，支持自定义获取顺序与起始序列号设置，轻松实现历史消息回溯与重放。

定时、永久与超时控制

支持定时任务消息发布、永久持久化消息、消息过期超时自动清理，以及限制消息最大被消费次数等精细化策略。

无限制负载与二进制支持

不限制消息体负载格式，原生支持 JSON、文本、自定义二进制流（Binary）消息及扩展消息属性标记，结合高速缓存加速读写。

权限验证与加密通信

支持全链路加密通信、HTTP 身份验证以及细粒度权限控制开关（管理员级关键接口保护），保障企业核心数据安全。

多渠道联动通知

除实时套接字推送外，还支持电子邮件（Email）离线通知提醒，并持续演进负载均衡与短信通知扩展能力。

多协议接入与在线测试环境

单一服务端进程即可同时监听并处理多种主流通信协议，内置公开测试节点（app.xyry.org）供快速联调。

Port: 5200

TCP / MQTT 高速通道

面向后端微服务、C/C++ 原生客户端与 IoT 物联网设备的超低延迟长连接通道。

Host: app.xyry.org:5200
Port: 5201

WebSocket 实时推送

面向网页前端、H5 小程序及跨平台桌面应用的双向实时消息订阅与通知服务。

ws://app.xyry.org:5201
Port: 5202

HTTP 管理与控制接口

提供统一 RESTful 风格的队列管理、用户鉴权、状态监控与轻量级消息投递接口。

http://app.xyry.org:5202

快速编译与部署指南

支持 Windows (VS)、Linux (Ubuntu 24.04 / RockyLinux 9) 及 macOS 13+ 跨平台编译运行。

bash — Linux / macOS 部署流程

# 1. 安装 XEngine V9+ 基础环境

git clone https://github.com/libxengine/libxengine.git

cd libxengine && sudo ./XEngine_LINEnv.sh -i 3

# 2. 克隆消息队列仓库并拉取依赖子模块

git clone https://github.com/libxengine/XEngine_MQService.git

cd XEngine_MQService

git submodule init && git submodule update

# 3. 导入 MySQL 数据库表结构 (位于 XEngine_SQLFile 目录)

mysql -u root -p < XEngine_SQLFile/CreateDatabase.sql

mysql -u root -p < XEngine_SQLFile/XEngine_MQData.sql

mysql -u root -p < XEngine_SQLFile/XEngine_MQUser.sql

# 4. 编译并启动服务

cd XEngine_Source && make && make FLAGS=InstallAll

cd ../XEngine_Release && ./XEngine_MQServiceApp