消息队列的两种实现模式

消息队列的两种实现模式

Java消息服务（Java Message Service，JMS）应用程序接口是一个Java平台中关于面向消息中间件（MOM）的API，用于在两个应用程序之间，或分布式系统中发送消息，进行异步通信。它提供了一种面向消息队列的一种规范。

消息队列的实现模式有两种，均由JSM定义，一种是点对对模式，另一种是发布订阅模式，两种模式的主要区别或解决的问题就是发送到对立的消息能否被重复消费（订阅）。

消息模型定义

JMS规范目前支持两种消息模型：点对点(point to point, queue)和发布订阅模式(publish/suscribe, topic)。

点对点：Queue，不可重复消费

这种模式非常直观，消息生产者生产消息发送到queue中，然后消息消费者从queue中取出并且消费消息。

消息被消费之后，queue中也就不再有存储，所以消息消费者不可能消费到已经被消费的东西。Queue能够支持存在多个消费者，但是对一个消息而言，只有一个消费者可以消费。

发布/订阅：Topic，可以重复消费

消息生成者（发布）将消息发送到topic中，同时有多个消息消费者（订阅）消费该消息。Topic和点对点的Queue不同，发布到topic的消息会被所有订阅者消费。

支持订阅组的发布订阅模式

发布订阅模式下，当发布者消息量很大时，显然单个订阅者的处理能力是不足的。实际上现实场景中是很多个订阅者结点组成的一个负载均衡的订阅组，消费topic中的消息使用分组订阅的方式，这样订阅者可以线性扩展。这种模式可以看成是一个topic下有多个Queue，每个Queue是点对点的方式，Queue与Queue之间是发布订阅模式。

区别 点对点模式

生产者发送一条消息到queue，一个queue可以有很多消费者，但是一个消息只能被一个消费者接受，当没有消费者可用时，这个消息会被保存直到有一个可用的消费者，所以Queue实现了一个基本的可靠的负载均衡。

发布订阅模式

发布者发送到topic的消息，只有订阅了topic的订阅者才会收到消息。topic实现了发布和订阅，当你发布一个消息，所有订阅这个topic的服务都能得到这个消息，所以从1到N个订阅者都能得到这个消息的拷贝。

常见模型比较

传统企业型消息队列ActiveMQ遵循了JMS规范，实现了点对点和发布订阅模型，但其他流行的消息队列RabbitMQ、Kafka并没有遵循JMS规范。

Rabbit MQ

RabibtMQ实现了AMQP(Advanced Message Queue Protocol)协议，AMQP协议定义了消息路由规则和方式。生产端通过路由规则发送消息到不同queue，消费端根据queue名称消费消息。

RabbitMQ既支持内存队列，也支持持久化队列，消费端为推模型，消费状态和订阅关系由服务端维护，消息消费完后立即删除，不保留历史信息。

点对点

生产端发送一条消息通过路由投递到Queue，只有一个消费者能消费到。

多订阅

当Rabbit MQ需要支持多订阅时，发布者发送的消息通过路由同时写到多个Queue，不同订阅组消费不同Queue中的消息。所以支持多订阅时，消息会有多个拷贝。

Kafka

Kafka只支持消息持久化，消费端为拉模型，消费状态和订阅关系由客户端负责维护，消息消费完后不会立即删除，会保留历史消息，因此支持多订阅时，消息只会存储一份，但是也可能产生重复消费的情况。

点对点&多订阅

发布者生产一条消息到topic中，不同订阅组消费此消息。