Linux云计算运维架构师（连载）-消息队列-RabbitMQ-02

5.1.3 消息中间件的两种模式

消息中间件包含两种模式，点对点(P2P，Point-to-Point）模式和发布/订阅(Pub/Sub，Publish/Subscribe）模式，下面将分别介绍这两种模式。

1、P2P模式

P2P模式包含三个角色：消息队列（Queue）、发送者（Sender）、接收者（Receiver）。该模式使用消息队列作为通信载体，队列的存在使得消息的异步传输成为可能。在该模式中，发送者将消息发送至一个特定的队列，接收者从队列中获取消息。当消息被接收之后，消息队列将不再存储该消息。若消息未及时被接收，消息队列将会一直保留着消息，直到它们被消费或超时。

这里需要注意的是，消息队列支持存在多个消费者，但是一个消息仅有一个消费者可以消费。P2P模式的特点如下所示。

l 每个消息只有一个消费者，某消息一旦被消费，该消息就不再保存于消息队列中。

l 发送者和接收者之间在时间上没有依赖性。当发送者发送消息之后，不管接收者是否正在运行，并不会影响到消息被发送到队列。

l 接收者成功接收消息之后，需向队列应答成功。

l P2P模式可以使每个消息都会被成功处理。

2、Pub/Sub模式

Pub/Sub模式包含三个角色：主题（Topic）、发布者（Publisher）、订阅者（Subscriber）。Pub/Sub模式定义了如何向一个内容节点发布和订阅消息，这个内容节点称为主题(Topic)，主题可以认为是消息传递的中介，消息发布者将消息发布到某个主题，而消息订阅者则从主题中订阅消息。主题使得消息的订阅者与消息的发布者互相保持独立，不需要进行接触即可保证消息的传递，发布/订阅模式在消息的一对多广播时采用，其特点如下所示。

l 每个消息可以有多个消费者。

l 发布者和订阅者之间有时间上的依赖性。针对某个主题（Topic）的订阅者，必须在发布者发布消息之后，其才能消费发布者的消息。

l 为了消费消息，订阅者必须保持运行的状态。

l 如果希望发送的消息可以不被做任何处理、或者只被一个消息者处理、或者可以被多个消费者处理的话，可以采用Pub/Sub模型。

5.1.4 常用消息中间件的介绍与对比

常用的消息中间件有Kafka、RabbitMQ、RocketMQ等，接下来将分别介绍这些消息中间件。

l Kafka

Kafka是LinkedIn开源的分布式发布-订阅消息系统，目前归属于Apache顶级项目，其logo如图5.1所示。

Kafka基于Pull的模式处理消息消费，追求高吞吐量，用于日志收集和传输。它从0.8版本开始支持复制，不支持事务，对消息的重复、丢失、错误没有严格要求，适合产生大量数据的互联网服务的数据收集业务。一般应用在大数据日志处理或对实时性（少量延迟），可靠性（少量丢数据）要求稍低的场景使用，比如ELK日志收集。

l RabbitMQ

RabbitMQ是使用Erlang语言开发的开源消息队列系统，基于AMQP协议来实现，其logo如图5.2所示。

AMQP的主要特征是面向消息、队列、路由（包括点对点和发布/订阅）、可靠性、安全。AMQP协议更多用在企业系统内对数据一致性、稳定性和可靠性要求很高的场景，对性能和吞吐量的要求还在其次。综合来看，RabbitMQ比Kafka可靠。

l RocketMQ

RocketMQ是阿里开源的消息中间件，它是纯Java开发，具有高吞吐量、高可用性、适合大规模分布式系统应用的特点。RocketMQ思路起源于Kafka，但并不是Kafka的一个Copy，它对消息的可靠传输及事务性做了优化，目前在阿里集团被广泛应用于交易、充值、流计算、消息推送、日志流式处理、binglog分发等场景。