JoeAllen/mqttx
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
62 Commits 2 Branches 1 Tag
2089bb72598fda3a7f478a9c6e3dcf2d39b96d84
Commit Graph
8 Commits
Author SHA1 Message Date
JoeAllen 7de886410d feat: 连接配置支持「启动时自动连接」 
- ConnectionConfig 新增 auto_connect 字段（serde default，旧数据兼容）
- 连接表单「认证与心跳」区新增开关，随保存持久化
- 应用启动时对勾选的连接逐个拉起（遗嘱模板注入后 connect）
 2026-09-29 17:02:25 +08:00
JoeAllen 85a3bfcb1b perf: 消息内存按字节预算，杜绝大报文流撑爆内存 
- 新增 MessageRing：条数上限 + 每连接 32MB 字节预算双重驱逐
  （从最旧丢弃，均摊 O(1)）；预分配容量按设置钳制在 512
- 单条 payload 保留上限 256KB → 128KB；MqttRecord::retained_bytes
  计入文本与原始字节，供预算驱逐与资源监控展示
- 清空消息统一走 clear_messages；设置页标注字节预算兜底说明
- 新增单元测试：条数驱逐、字节预算、超预算单条保留、驱逐顺序
 2026-09-29 17:00:34 +08:00
JoeAllen ab13f485e0 fix: MQTT 连接生命周期竞态与事件处理 
连接句柄（mqtt.rs）：
- ConnHandle 增加代数 generation，事件循环退出只在仍是自己这一代时
  才移除句柄——旧循环无条件按 id 删除会把重连后的新句柄删掉，
  导致连接显示在线却无法从 UI 断开、发布/订阅报连接不存在
- connect() 同步插入占位句柄（client=None），建连期间也可被取消；
  建连完成后仅当句柄仍是本代才升级为可用客户端
- 重连 2 秒退避改为可取消的 select：原先 close() 的取消信号在退避
  期间不可见，会对用户已关闭的连接继续真实重连
- 重连成功后清零计数（max_reconnect_times 限流的是连续失败次数）；
  v4 CONNACK 拒绝上报真实返回码；test_handshake 断开后再 poll 冲出
  DISCONNECT 报文；建连的证书文件读取移入 spawn_blocking

消息记录与事件（model.rs / app.rs / connection_view.rs）：
- 非文本负载保留原始字节（MqttRecord.raw_bytes，仅非法 UTF-8 时
  占用，纯文本零开销），详情 Hex/Base64 不再展示 lossy 失真字节
- EngineEvent::Published 补齐 response_topic/correlation_data/
  message_expiry；correlation_data 两侧统一「优先文本、回退 hex」
- 事件入口加连接存在性守卫：删除连接后排队的引擎事件不再复活
  状态/消息（内存泄漏）或为已删连接写孤儿订阅
- SUBACK 失败时移除乐观插入的订阅行；成功事件只刷新已有订阅，
  不再用默认字段复活 SUBACK 前被删除的订阅
- Connecting 期间侧栏电源按钮防抖；分组名恰为 all/ungrouped 时
  chip 元素 id 改前缀避免共享交互状态
- 「清空」按钮按消息总数而非过滤命中数判断禁用；搜索匹配的
  大小写快速路径限定 ASCII（U+1E9B 等小写映射非自身的字符）
- 应用发布预设后同步模板变量面板，残留行不再写回全局变量
- 日志文件套 BufWriter，高频消息流不再逐条落盘 syscall
 2026-09-29 10:33:59 +08:00
JoeAllen 96865c0588 perf: 深度优化消息内存占用 
- 消息缓冲 Vec → VecDeque：原来溢出时 drain(0..n) 每条消息 O(n)
  搬移，高频消息下产生大量拷贝；环形缓冲均摊 O(1)，并按配置上限
  预分配避免反复扩容
- connection_id/topic/payload 改 Arc<str>：引擎侧主题驻留
  （10k 上限，超出整体重建），同主题数千条记录只存一份；
  消息列表每帧克隆最多 300 条用于渲染，payload 共享后零拷贝
- 单条 payload 历史保留上限 256KB（retained_payload，UTF-8
  边界安全截断），超大报文不再长期占据环形缓冲；消息行显示
  「已截断」徽章；发布记录改用实际发送字节（修 Base64/Hex
  历史内容与真实报文不一致的隐患）
- live 测试适配 Arc<str>；补截断边界单元测试（22 个 lib 测试 +
  2 个 live 测试通过）
 2026-09-29 01:07:32 +08:00
JoeAllen 085d7c5589 feat: 补齐预设与变量注入（遗嘱模板注入、v5 文本属性注入、删除预设二次确认） 2026-09-28 19:04:41 +08:00
JoeAllen f8ce93f0dd fix: 修复 UI 审查问题（图标资产全量化、主区布局贴顶、订阅数据保护与 28 项交互缺陷） 2026-09-28 18:40:58 +08:00
JoeAllen c1c4fc011e feat: GPUI 版补齐 MQTTX 基础功能对标（分组/SSL证书/订阅增强/消息流控制/设置与日志） 2026-09-28 14:41:15 +08:00
JoeAllen bf6937b776 feat: 重写为 GPUI 原生桌面应用并接入 Gitea 软件包发布 
- gpui-kit 0.6 原生 UI：连接管理、消息流/日志、发布预设、全局变量、
  设置、阿里云连接预设、原生 Logo
- MQTT 5.0/3.1.1 引擎（rumqttc，TCP/TLS/WS/WSS），独立 tokio runtime
  + 事件泵，真实 broker 端到端测试
- 连接表单：保存前可一键测试连接（宽松校验，自动生成临时 Client ID），
  高级属性（认证/MQTT 5 属性/遗嘱）按需折叠显示，WS 路径仅 WS/WSS 显示
- bug 修复：Hex 奇数长度显式报错、测试连接唯一 Client ID、Base64/Hex
  发布发送真实字节、v5 发布记录携带 Content-Type/用户属性、预设应用
  清除旧 Content-Type、模板时间基准统一；补 8 个单元测试
- Gitea 发布：Generic Package 上传脚本（bash/PowerShell）+ Actions
  release 工作流（tag 触发，双平台构建），README 使用说明
 2026-09-28 11:39:47 +08:00