RocketMQ 概述

Rocket 火箭

MQ的作用:同步转异步(异步解耦)。

难点:如何确保消息一定被消费,而且仅消费一次。

1、消息架构:生产者、服务器、消费者、路由发现。

2、消息顺序:严格按照消息到达服务器的顺序进行消费。

3、消息过滤:

  a、服务端过滤

  b、消费端过滤。

  缺点:无用的消息也传输到消费端。优点:可控性高。服务端过滤与消费端过滤优缺点正好相反。

4、消息存储:通过内存映射机制,保证高性能存储。

5、消息高可用:同步刷盘,异步刷盘。

6、消息回溯:向前或者向后获取消息。

7、定时消息:消息的定时消费。

8、消息重试

架构:

  1、Broker  MQ服务器。

  2、NameServer 注册中心,集群高可用相关。

架构图:

 

原文地址:https://www.cnblogs.com/chen--biao/p/10163834.html