MQTTX — 基于 GPUI 的跨平台 MQTT 桌面客户端

使用 Rust + gpui-kit（基于 GPUI）重写的 MQTT 调试客户端，对标官方 MQTTX。 纯 Rust 实现：MQTT 引擎、数据持久化与原生 UI 同属一个轻量二进制，无 Electron/WebView 运行时。

早期 Tauri + Vue 实现已归档到 tauri-legacy 分支，本项目仅维护 gpui-app/ 原生实现。

功能特性

• 双协议支持 — MQTT 5.0 与 MQTT 3.1.1（rumqttc-next）
• 多传输方式 — 明文 TCP、TLS、WebSocket(ws)、WebSocket over TLS(wss)，默认 rustls（aws-lc）
• 多连接管理 — 同时管理多个连接，侧边栏实时显示连接状态（未连接/连接中/已连接/错误），多标签页切换；连接分组（分组 chips 过滤 + 表单分组归属）
• 完整 MQTT 5 属性 — 用户属性（可视化键值对编辑器）、Content-Type、消息过期间隔、Response Topic、Correlation Data（连接/遗嘱/发布三处均支持）
• 发布 / 订阅 — QoS 0/1/2、Retain、遗嘱消息（Last Will）、订阅自动恢复（auto resubscribe）、断线自动重连（可配置最大重连次数与连接超时）
• 订阅增强 — 逗号/换行多主题批量订阅、订阅别名、颜色标签（消息按订阅着色）、启用/禁用、点击订阅过滤消息流、MQTT 5 订阅选项（订阅标识符 / No Local / Retain As Published / Retain Handling）
• 消息流 — 收发方向区分、时间戳、QoS/Retain 标记、点击展开查看格式化 JSON 与 v5 属性、全部/接收/发布过滤、主题/内容搜索、逐条 payload 格式切换（自动/文本/Hex/Base64）、复制主题/负载/详情、暂停滚动（高频消息流下锁定画面阅读，消息仍后台接收）、清空历史
• JSON 预览 — 折叠态对 JSON 负载按原始数据美化展示（多行缩进，常规负载完整显示，超大负载兜底截断）
• 连接导入 / 导出 — 原生文件对话框（rfd）导出/导入连接 JSON，按 id 去重
• SSL/TLS 证书 — 自定义 CA、客户端证书/私钥（双向认证）、忽略 CA 校验
• 全局变量 — 发布主题与负载中使用 {{变量名}}，内置 {{$ts}}、{{$ts_ms}}、{{$uuid}}，用户属性同样参与渲染
• 负载格式 — Plaintext / JSON（发送前校验）/ Base64 / Hex
• 阿里云 IoT — Token（GroupId@@@DeviceId + HMAC-SHA1 签名）与一机一密两种鉴权方式一键生成连接
• 连接测试 — 表单内握手测试（超时可配置），保存前验证连通性
• 日志面板 — 连接级事件日志（CONNACK/SUBACK/PUBACK/错误/重连等），按日落盘 mqttx-YYYY-MM-DD.log，设置内一键打开日志目录
• 快捷键 — Ctrl+N 新建连接、Ctrl+, 设置、Ctrl+Shift+E 导出、Ctrl+Shift+I 导入、Ctrl+Shift+R 资源监控、Ctrl+Enter 发送消息（全局生效）、Ctrl+B 收起/展开连接侧栏、Ctrl+W 关闭标签页、Ctrl+Tab / Ctrl+Shift+Tab 切换标签、Ctrl+F 聚焦消息过滤、Enter 提交订阅、Esc 退出编辑/清空输入
• 抽屉式布局 — 连接侧栏（持久化，Ctrl+B）、订阅面板、底部发布面板均可一键收起为窄条抽屉，最大化消息流空间
• 国际化 — 中文 / English 双语界面，默认跟随系统语言，设置内可切换即时生效
• 无障碍 — 全部图标按钮带可访问名称（屏幕阅读器 / UIA 可识别），完整键盘操作路径
• 性能 — 消息预览（JSON 美化/截断）入缓冲时计算一次并随记录缓存，渲染热路径零重复解析
• 主题 — Linear 风格配色（近黑/纯白扁平底 + 靛蓝 #5e6ad2 主色，14px 紧凑排版、6px 圆角），浅色 / 深色 / 跟随系统
• 设置 — 自动检查更新开关、消息缓存条数、时间戳毫秒、数据目录展示与打开、关于页（版本 / 许可）
• 本地持久化 — 连接、订阅、预设、变量、设置以 JSON 存于系统数据目录

技术栈

层	技术
UI	GPUI 0.3 + gpui-kit（gpui-component）0.6
MQTT	rumqttc-v5-next 0.34 / rumqttc-v4-next 0.34（TCP/TLS/WS）
异步	引擎跑在独立 tokio runtime，事件经 smol channel 泵回 UI 线程
持久化	serde + serde_json，原子写（临时文件 + rename）
其他	chrono、dirs、uuid、hmac/sha1/base64（阿里云签名）

目录结构

每个文件与目录单一职责；模块门面（mod.rs）只做聚合导出与再分派。

gpui-app/
├── Cargo.toml
├── src/
│   ├── main.rs              # 入口：Sentry 初始化、创建窗口、挂载 gpui-kit Root
│   ├── lib.rs               # 库导出（模型/引擎/UI 可被集成测试复用）
│   ├── model/               # 数据模型（纯数据层，不依赖 GPUI）
│   │   ├── mod.rs           #   门面：聚合导出 + 模型测试
│   │   ├── connection.rs    #   连接配置：协议/传输/遗嘱/TLS/会话参数
│   │   ├── subscription.rs  #   订阅条目与订阅选项
│   │   ├── message.rs       #   消息记录 + 条数/字节双预算环形缓冲
│   │   ├── publish.rs       #   发布参数与发布预设
│   │   ├── variable.rs      #   全局变量与 {{占位符}} 模板渲染
│   │   ├── log.rs           #   运行日志级别与条目
│   │   └── settings.rs      #   应用设置与主题偏好
│   ├── mqtt/                # MQTT 引擎（独立 tokio runtime）
│   │   ├── mod.rs           #   门面：EngineEvent / MqttEngine 连接生命周期
│   │   ├── tls.rs           #   rustls 配置与跳过校验
│   │   ├── v5.rs            #   MQTT 5.0 客户端构建与事件循环
│   │   └── v4.rs            #   MQTT 3.1.1 客户端构建与事件循环
│   ├── update/              # OTA 自更新（GitHub Releases 源）
│   │   ├── mod.rs           #   门面：版本比较、资产命名约定
│   │   ├── check.rs         #   检查最新版本与资产挑选
│   │   └── install.rs       #   7z 下载暂存、sha256 校验、自替换安装
│   ├── store.rs             # JSON 持久化（损坏备份与 fsync）
│   ├── sysmon.rs            # 自身进程资源采样（CPU/内存/线程/句柄）
│   ├── platform.rs          # 平台窗口操作（Windows 置顶）
│   ├── aliyun.rs            # 阿里云 IoT 签名与连接生成
│   └── ui/
│       ├── mod.rs           # 界面层导出
│       ├── app/             # 应用外壳
│       │   ├── mod.rs       #   MqttXApp 状态、初始化与渲染分派
│       │   ├── events.rs    #   引擎事件 → 应用状态（消息/日志缓冲）
│       │   ├── actions.rs   #   连接/订阅/预设/设置等用户动作
│       │   ├── io.rs        #   连接配置导入导出
│       │   ├── theme.rs     #   Linear 风格主题应用
│       │   ├── titlebar.rs  #   标题栏（置顶钉子/主题切换/动作菜单）
│       │   ├── sidebar.rs   #   侧边栏（搜索/分组/连接列表）
│       │   └── main_area.rs #   标签页栏与内容装配
│       ├── connection_view/ # 连接工作区
│       │   ├── mod.rs       #   ConnectionView 状态与渲染分派
│       │   ├── subscribe.rs #   订阅表单/列表
│       │   ├── messages.rs  #   消息流、单条消息行与日志
│       │   ├── publish.rs   #   发布表单与发布预设
│       │   ├── vars.rs      #   模板变量面板
│       │   └── util.rs      #   topic 匹配/格式化纯函数
│       ├── connection_form.rs  # 新建/编辑连接表单
│       ├── dialogs/         # 模态对话框集合（设置/资源监控/发布预设/阿里云/变量）
│       ├── widgets/         # 复用小组件（枚举下拉/键值对编辑器/字段行/状态指示）
│       └── logo.rs          # 品牌图标绘制
└── tests/
    └── engine_live.rs       # 真实 broker 端到端测试（默认 ignored）

构建与运行

前置：Rust nightly（GPUI 0.3 依赖，使用 rustup default nightly）。

# 开发运行
cargo run -p mqttx-desktop

# 优化构建
cargo build --release -p mqttx-desktop
# 产物：target/release/mqttx(.exe)

中国大陆网络下若 index.crates.io 不可达，仓库已提供仅作用于本工程的 .cargo/config.toml（rsproxy 镜像）。

端到端连通性测试

测试默认 #[ignore]，需要外网：

MQTTX_LIVE=1 cargo test -p mqttx-desktop --test engine_live -- --ignored

会连接公共服务器 broker.emqx.io:1883，验证：

• MQTT 5.0 连接 → 订阅 → 发布 → 回环接收
• MQTT 3.1.1 连接握手

发布到 GitHub Releases

推送 v* tag 即触发 .github/workflows/release.yml：

1. 版本一致性校验：tag 必须等于 v + gpui-app/Cargo.toml 的版本，否则整条流水线失败
2. 单元测试（--lib --tests，集成测试只编译不执行）
3. Linux + Windows + macOS 三平台 release 构建（产物重命名为 mqttx-v<ver>-<target>-mqttx[.exe] 并生成 .sha256 侧车；macOS 仅 Apple Silicon）
4. 打包 7z（单条目，内部文件名 = 裸二进制名）并创建 GitHub Release，上传 7z / 裸二进制 / .sha256 附件

应用内 OTA 只认 Release 附件，附件名必须匹配 mqttx-v<ver>-<triple>-mqttx[.exe]。 7z 是 OTA 主通道；裸二进制供不识别 7z 的旧客户端（≤v1.0.3）升级。

macOS 产物未做签名/公证：浏览器下载后首次打开会被 Gatekeeper 拦截，需 xattr -d com.apple.quarantine <binary>；应用内 OTA 自更新不走浏览器，无此问题。

GitHub 侧发布历史自 v1.0.0 起独立开始，不向其他渠道镜像。

数据目录

平台	路径
Windows	%APPDATA%\MQTTX-GPUI
macOS	~/Library/Application Support/MQTTX-GPUI
Linux	~/.local/share/MQTTX-GPUI

刻意与官方 Electron MQTTX 的 MQTTX/ 目录区分，互不影响。读取时容忍 UTF-8 BOM。

与 Tauri 版本的差异

• 单一 Rust 二进制（release ~17MB），无需打包 Node/WebView 资源
• MQTT 引擎从 Tauri 命令模型改为独立 tokio runtime + 事件通道，UI 直接订阅
• 数据存储从浏览器 localStorage 迁移到系统数据目录下的 JSON 文件
• 新增 TLS/WSS 传输、负载格式（Base64/Hex）、遗嘱消息、连接测试等能力