消息队列的两种模式

简述

Java 消息服务（Java Message Service,JMS）应用程序接口是一个java平台中关于消息中间件（Mom）的API，用于在两个程序之间，或分布式消息系统中发送消息，进行异步通讯。

点对点 和 发布订阅 最初是JMS定义的。这两种模式主要区别或解决的问题就是发送队列的消息可否重复消息。

1.定义

JMS规范目前支持两种消息模型：点对点 （point to point，queue）和发布/订阅（publish/subscribe,topic）

1.一、点对点：Queue，不可重复消费

消息生产者生产消息发送到queue中，而后消息消费者从queue中取出而且消费消息。消息被消费之后，queue中再也不有存储，因此消息消费者不可能消费到已经被消费的消息。Queue支持存在多个消费者，可是对一个消息而言，只会有一个消费者能够消费。

1.二、发布/订阅：Topic，能够重复消费

消息生产者（发布）将消息发布到topic中，同时有多个消息消费者（订阅）消费该消息。和点对点方式不一样，发布到topic的消息会被全部订阅者消费。

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

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

二、区别

2.一、点对点模式

生产者发送一条消息到queue，一个queue能够有不少消费者，可是一个消息只能被一个消费者接受，当没有消费者可用时，这个消息会被保存直到有 一个可用的消费者，因此Queue实现了一个可靠的负载均衡。

2.二、发布订阅模式

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

三、流行模型比较

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

3.一、RabbitMQ :消费端为推模型

RabbitMQ实现了AQMP协议，AQMP协议定义了消息路由规则和方式。生产端经过路由规则发送消息到不一样queue，消费端根据queue名称消费消息。 RabbitMQ既支持内存队列也支持持久化队列，消费端为推模型，消费状态和订阅关系由服务端负责维护，消息消费完后当即删除，不保留历史消息。

（1）点对点

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

（2）多订阅

当RabbitMQ须要支持多订阅时，发布者发送的消息经过路由同时写到多个Queue，不一样订阅组消费不一样的Queue。因此支持多订阅时，消息会多个拷贝。

3.二、Kafka：消费端为拉模型

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

（1）点对点&多订阅

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