消息中间件

基础知识

• 消息队列 MQ：
  • 为什么：当数据进行更新时，数据库，索引库，静态页面都需要进行修改，如果直接让服务器端修改这些代码，违背了微服务的独立原则；即使通过接口进行修改也会导致代码的耦合，所以产生了消息队列的机制，如果数据发生修改，服务器端只需要向消息队列发送消息，就可以做其他工作了（异步），而索引库和静态页面的接口时刻监听消息队列，如果监听到服务端的消息便进行数据的更新。
  • 是什么：消息队列是典型的：生产者、消费者模型。生产者不断向消息队列中生产消息，消费者不断的从队列中获取消息。因为消息的生产和消费都是异步的，而且只关心消息的发送和接收，没有业务逻辑的侵入，这样就实现了生产者和消费者的解耦。
  • 怎么实现：AMQP协议、Java提供的JMS接口。
    • JMS是定义了统一的接口，来对消息操作进行统一；AMQP是通过规定协议来统一数据交互的格式
    • JMS限定了必须使用Java语言；AMQP只是协议，不规定实现方式，因此是跨语言的。
    • JMS规定了两种消息模型；而AMQP的消息模型更加丰富

常见MQ产品

• ActiveMQ：基于JMS
• RabbitMQ：基于AMQP协议，erlang语言开发，稳定性好
• RocketMQ：基于JMS，阿里巴巴产品，目前交由Apache基金会
• Kafka：分布式消息系统，高吞吐量

RabbitMQ

RocketMQ

ActiveMQ

Kafka

消息中间件：
1、种类
1、RabbitMQ
2、Kafka
1、核心组件
2、原理
3、常见问题
1、怎么保证数据不丢失
2、确保消息不会被重复消费
3、消息送达确认怎么做
4、保证数据的可靠性
3、RocketMQ
1、核心组件
2、常见问题
1、如何实现消息去重
4、ActiveMQ
2、不同MQ的区别