通信服务 · 统一消息模块（msg-Modules）

服务分类：通信服务 —— 对应统一消息管理域（NATS JetStream）

模块定位

统一消息服务：全平台消息总线 —— 先落 SQLite（审计 + 降级队列） 再投递 NATS JetStream；NATS 不可用时消息进入 pending 队列，由 Worker 恢复后重投。

功能

• 发布：publish(topic, payload, priority)，幂等（同 msg_id 仅一次）；
• 主题规范：字母数字 ._-*；业务主题如 order.created、audit.vpn.*、 telemetry.agent.*、life.*；
• 降级重投：NATS 离线自动写库 pending，redeliver_pending() 周期重投；
• 审计查询：按状态过滤的消息列表（统一消息管理面）；
• 消费端：告警推送、工单事件、生活服务请求等均经总线解耦。

接口要点

GET  /messages?limit=&status=     消息列表（admin/service）
POST /messages/publish            发布 {topic, payload, priority?, msg_id?}

数据表：messages（msg_id/topic/payload/priority/status/created_at）。

状态与关联

• 已实现（nfarmsd v2.3.0 统一消息管理）；
• 关联：nf-agent（遥测主题）、nflive（life.* 生活服务）、商城订单事件、VPN 审计事件；
• 关联前端：hub/（通知）、online/（官方发布）。