消息队列(MQ)

Posted 2021-10-30 ruhuanxingyun

1. 分类：

　　获取消息方式：A. push(推)方式：优点——可以尽可能快地将消息发送给消费者，缺点——如果消费者处理能力跟不上，消费者的缓冲区可能会溢出；

　　　　　　　　    B. pull(拉)方式：优点——消费端可以按处理能力进行拉去，缺点——会增加消息延迟；

　　能否重复消费：A. 点对点(Queue)：不可重复消费；

　　　　　　　　　B. 发布/订阅(Topic)：可重复消费。

2. 特点：

　　A. 先进先出(FIFO)；

　　B. 发布订阅；

       C. 持久化；

       D. 分布式。

 

3. 技术组件

　　A. RabbitMQ：是使用Erlang语言开发的开源消息队列系统，基于AMQP协议来实现，推拉模式和事务，适合对数据一致性、稳定性和可靠性要求很高的场景，对性能和吞吐量的要求还在其次的场景；

　　B. RocketMQ：是阿里开源的消息中间件，它是纯Java开发，支持推拉模式，保证消息顺序，具有高吞吐量、高可用性、适合大规模分布式系统应用的特点；

　　C. Kafka：是LinkedIn开源的分布式发布-订阅消息系统，主要特点是基于拉模式来处理消息消费，高吞吐量，适合产生大量数据的互联网服务的数据收集业务；

　　D. ActiveMQ：纯Java实现，兼容JMS，可以内嵌于Java应用中；

　　E. Redis队列：采用list数据类型实现拉模式，采用lpush/rpush和rpop/lpop实现，阻塞等待采用brpop/blpop命令。

 

可参考：https://github.com/xingshaocheng/architect-awesome/blob/master/README.md#%E4%B8%AD%E9%97%B4%E4%BB%B6