Queen MQ

产品概述

Queen MQ 是一款基于 PostgreSQL 构建的开源消息队列系统，它巧妙地将 Postgres 的可靠性转化为高性能消息中间件，同时支持 Kafka 式的流式处理和 RabbitMQ 式的队列特性。只需一个 Docker 容器，即可获得企业级消息队列能力。

核心功能

• 每实体 FIFO 排序：支持任意基数下的每个实体先进先出排序，确保消息处理顺序与业务逻辑一致。
• 事务性入队：消息入队可直接嵌入 PostgreSQL 事务中，保证数据一致性与原子性。
• 时间戳重播：支持从指定时间点重新消费消息，便于故障恢复和数据回溯。
• 死信队列：自动处理消费失败的消息，防止消息无限重试导致阻塞。
• JWT 认证：内置 JSON Web Token 认证机制，保障队列访问安全。
• Vue 3 仪表盘：提供现代化 Web 管理界面，实时监控队列状态与性能。

主要特性

• 轻量部署：仅需一个 Docker 容器，无需额外依赖，秒级启动。
• 多语言 SDK：提供 JavaScript、Python、Go、PHP、C++ 五种官方 SDK，覆盖主流开发语言。
• 开源免费：采用 Apache 2.0 许可证，可自由使用、修改和商用。
• Postgres 原生：充分利用 PostgreSQL 的成熟生态，如复制、备份、监控等。
• 高吞吐低延迟：基于 Postgres 的 WAL 和索引优化，实现接近原生消息队列的性能。

适用场景

• 微服务异步通信：解耦服务间调用，实现可靠异步消息传递。
• 事件驱动架构：作为事件总线，支持领域事件、CQRS 等模式。
• 任务队列：处理后台任务、定时任务、工作流编排。
• 数据管道：连接数据生产者与消费者，实现 ETL 或流式处理。

Queen MQ 为 Postgres 用户提供了无缝的消息队列体验，无需引入额外中间件，即可享受 Kafka 和 RabbitMQ 的核心能力。