RocketMQ是什么?
RocketMQ 是一个分布式消息中间件和流计算平台,由阿里巴巴团队开源并贡献给 Apache 软件基金会,现为 Apache 顶级项目。它主要用于处理大规模数据的传输问题,支持高吞吐量、高可用性和可扩展性的消息发布和订阅服务。RocketMQ 能够确保消息的可靠传输,支持严格的消息顺序,并提供事务性消息处理。
基本概念
生产者(Producer):生产并发送消息的一方
消费者(Consumer):接收使用消息的一方
代理服务器(Broker):临时保存生产者发送消息的服务器,内含多个不同的Topic
命名服务器(NameServer):统筹管理前前三个角色,
-
broker将自己注册进NameServer
-
producer、consumer通过其获取broker信息然后发送、接收消息
-
NameServer通过心跳检测确认producer、consumer、broker上下线
消息(Message):由消息体(body)、主题(Topic)、标签&#x