rocketmq

Apache RocketMQ 是一个为高吞吐量、低延迟和可靠数据交换而构建的分布式消息与流处理平台。其设计旨在处理万亿级消息容量并具备灵活的扩展能力，适用于复杂的事件驱动企业应用。主要特性包括对发布/订阅和请求/回复模式的支持、金融级事务消息以及严格的 FIFO 顺序保证。该平台通过 DLedger 提供强大的容错能力，支持消息追踪，并能与大数据生态系统灵活集成。RocketMQ 支持 gRPC、MQTT 和 JMS 等多种协议，并提供高效的拉取/推送消费模型。它具有高度的可部署性，可在本地机器、Docker 容器以及通过 RocketMQ Operator 在 Kubernetes 集群中运行。其生态系统包含丰富的工具，如管理控制台、Prometheus 导出器以及各种语言客户端（Java、Go、Python、C++、Node.js），还有用于无缝集成 Flink 和 Spring Boot 等系统的连接器。