mq点对点和订阅发布的区别

问题描述

精选答案

1.点对点

消息生产者消息发送到queue中，然后消费者从queue中取。 注意：消息被消费以后，队列中不再有存储， 所以消费者不能 消费已经被消费的消息了 。 也就是不能重复消费。

2.发布/订阅

生产者将消息发送到topic中，同事多个消费者消费这个消息。 和点对点不同，发布到topic的消息会被所有订阅在消费。

2.二者分析与区别

2.1 点对点模式

生产者发送一条消息到 queue，只有一个消费者能收到。

2.2 发布订阅模式

发布者发送到 topic 的消息，只有订阅了 topic 的订阅者才会收到消息。

小结

queue 实现了负载均衡，一个消息只能被一个消费者接受，当没有消费者可用时，这个消息会被保存直到有 一个可用的消费者，一个 queue 可以有很多消费者，他们之间实现了负载均衡，

所以 Queue 实现了一个可靠的负载均衡。

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

只有在消息代理收到消息时有一个有效订阅时的订阅者才能得到这个消息的拷贝。

疑问

发布订阅模式下，能否实现订阅者负载均衡消费呢？当发布者消息量很大时，显然单个订阅者的处理能力是不足的。实际上现实场景中是多个订阅者节点组成一个订阅组负载均衡消费 topic 消息即分组订阅，

这样订阅者很容易实现消费能力线性扩展。

3 流行消息队列模型比较

传统企业型消息队列 ActiveMQ 遵循了 JMS 规范，实现了点对点和发布订阅模型，但其他流行的消息队列 RabbitMQ、Kafka 并没有遵循老态龙钟的 JMS 规范，是通过什么方式实现消费负载均衡、多订阅呢？

3.1 RabbitMQ

RabbitMQ 实现了 AQMP 协议，AQMP 协议定义了消息路由规则和方式。生产端通过路由规则发送消息到不同 queue，消费端根据 queue 名称消费消息。此外 RabbitMQ 是向消费端推送消息，订阅关系和消费状态保存在服务端。

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

当 RabbitMQ 需要支持多订阅时，发布者发送的消息通过路由同时写到多个 Queue，不同订阅组消费此消息。

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

3.2 Kafka

Kafka 只支持消息持久化，消费端为拉模型，消费状态和订阅关系由客户端端负责维护，消息消费完后不会立即删除，会保留历史消息。因此支持多订阅时，消息只会存储一份就可以了。