消息队列(MQ)

时间:2023-05-26 09:30:50

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