常用的消息中间件（ActiveMQ、RabbitMQ、RocketMQ、Kafka）面试精华
目录
主要作用：
四种消息中间件：
主要作用：
-
解耦
-
多个系统调用主系统可选择是否订阅
-
异步
-
主系统可提高响应时间
-
削峰
-
通过消息队列减轻消息访问对服务器的压力
四种消息中间件：
ActiveMQ
-
万级吞吐量
RabbitMQ(中小型公司)
-
万级吞吐量
RocketMQ(中大型公司)(非分布式)
-
十万级
-
Topic主题分类更加细致 有Tag分级
-
高可用：镜像集群模式
-
怎么做：开启镜像集群策略，可指定同步数据节点数量是所有还是个别几个
Kafka(纯分布式的mq)
-
十万级
-
高可用：假设一个topic有三个partition，在topic中写三条消息，每条消息存在不同的partition中，每个partition有自己的副本，选出leader和follower，leader宕机后，在follower中选出leader
-
只能leader读写，保证一致性，减轻复杂度
-
leader读取数据后，follower从leader拉取数据，响应ack告诉leader
-
生产者给kafka发送消息都有一个offset 在kafka中是有序的，消费者也是按照顺序消费的，消费者按顺序消费到哪个offset，zookeeper有记录，kafka可以从zookeeper中读取消费到那个位置了
-
由于消费者重启，kafka无法感知消费者消标记的offset，kafka会重复发已经发过的消息，导致消费者会重复消费 需要要保证幂等性
解决办法：
每条消息设置id存入Redis
数据库主键唯一性