RocketMQ

发布时间 2023-05-20 22:07:13作者: LCX测试小姐姐

RocketMQ背景是阿里巴巴,经历双11考验,Java语言编写,非常好完整体系

1、支持事务消息(实现解决分页式事务的问题)

2、支持高并发顺序消息处理(采用内存队列+多线程处理)

3、消费者支持tag过滤,减少我们带宽传输

RocketMQ关键核心名称:

NameServer: 存放生产者、消费者、topic信息。去中心化,不需要选举。

Broker负责存储和转发我们的消息

Producer生产者

Consumer消费者

Producer 统计消息给Broker,Broker转发给Consumer进行消费;Producer 需要拿到Broker的地址,(若Broker宕机,在Producer 需要重新连接其它Broker。)所以有了注册中心NameServer。如下图:

 

Broker里多主多备,备同步主节点的数据,当主宕机后,可以从备变为主从而保证高可用。