java

关注公众号 jb51net

关闭
首页 > 软件编程 > java > 消息队列点对点与发布订阅区别

kafka 消息队列中点对点与发布订阅的区别说明

作者:幽灵之使

这篇文章主要介绍了kafka 消息队列中点对点与发布订阅的区别说明,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教

背景知识

JMS一个在 Java标准化组织(JCP)内开发的标准(代号JSR 914)。2001年6月25日,Java消息服务发布JMS 1.0.2b,2002年3月18日Java消息服务发布 1.1.

Java消息服务(Java Message Service,JMS)应用程序接口是一个Java平台中关于面向消息中间件(MOM)的API,用于在两个应用程序之间,或分布式系统中发送消息,进行异步通信。 

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

1.JMS中定义

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

点对点

发布/订阅

2.二者分析与区别

2.1 点对点模式

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

2.2 发布订阅模式

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

小结

疑问

3.流行的消息队列模型比较

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

3.1 RabbitMQ

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

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

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

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

3.2 Kafka

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

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

您可能感兴趣的文章:
阅读全文