实时任务一旦断线,进度和输出不能跟着消失;但为了让消息可恢复,就维护一套 Kafka 之类的专用集群,对小团队又太重。PicoMQ 给出一个轻量思路:用常见的 HTTP 收发消息,把历史数据放进 S3 兼容对象存储。这样,浏览器、手机和服务程序都能用熟悉的方式接入,断线后还能从旧位置继续读取。
它也没有要求把同类记录全塞进一个大“主题”,而是建议按具体用途创建独立消息流。每条流都有自己的地址,可从空闲状态扩展到高吞吐。换句话说,任务进度、事件通知或 Agent 输出可以各走各的通道。
据 PicoMQ GitHub 仓库介绍,底层 s3stream 引擎负责 WAL——先写日志以便故障恢复——以及对象布局、缓存和压缩整理;上层再提供元数据、服务器、HTTP 接口、客户端和命令行工具。项目采用 Apache-2.0 许可证,也支持 SQLite 加本地文件的单节点配置。不过现有材料没有披露性能、成本或可靠性测试,能否真正替代传统消息集群,仍要结合实际负载验证。