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）。
点对点
- 消息生产者生产消息发送到queue中，然后消息消费者从queue中取出并且消费消息。这里要注意：
- 消息被消费以后，queue中不再有存储，所以消息消费者不可能消费到已经被消费的消息。
- Queue支持存在多个消费者，但是对一个消息而言，只会有一个消费者可以消费。
发布/订阅
- 消息生产者（发布）将消息发布到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既支持内存队列也支持持久化队列，消费端为推（push）模型，消费状态和订阅关系由服务端负责维护，消息消费完后立即删除，不保留历史消息。所以支持多订阅时，消息会多个拷贝。
3.2 Kafka
Kafka只支持消息持久化，消费端为拉（pull）模型，消费状态和订阅关系由客户端端负责维护，消息消费完后不会立即删除，会保留历史消息。因此支持多订阅时，消息只会存储一份就可以了。
以上为个人经验，希望能给大家一个参考，也希望大家多多支持猪先飞。
原文出处：https://blog.csdn.net/lizhitao/article/details/47723105
相关文章
- 这篇文章主要介绍了.NET Core下使用Kafka的方法步骤，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧...2021-09-22
- 这篇文章主要介绍了SpringBoot集成Redis实现消息队列的方法，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧...2021-02-10
asp.net通过消息队列处理高并发请求(以抢小米手机为例)
这篇文章主要介绍了asp.net通过消息队列处理高并发请求(以抢小米手机为例)，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧...2021-09-22- 本篇文章小编为大家介绍，基于条件变量的消息队列 说明介绍。需要的朋友参考一下...2020-04-25
- 这篇文章主要介绍了深入了解如何基于Python读写Kafka,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下...2020-05-06
- 本篇文章是对消息队列的应用进行了详细的分析介绍，需要的朋友参考下...2020-04-25
- 这篇文章主要为大家详细介绍了RabbitMQ .NET消息队列使用方法,具有一定的参考价值，感兴趣的小伙伴们可以参考一下...2021-09-22
- 这篇文章主要介绍了C++ 中消息队列函数实例详解的相关资料,需要的朋友可以参考下...2020-04-25
- 这篇文章主要介绍了实现posix消息队列示例，学习记录锁，线程互斥量，线程条件变量，内存映射，信号，线程的综合应用,需要的朋友可以参考下...2020-04-25
- 这篇文章主要介绍了PHP+MySQL消息队列深入理解，有感兴趣的同学可以研究下...2021-02-27
- 这篇文章主要介绍了Golang中优秀的消息队列NSQ基础安装及使用详解，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧...2020-12-18
- 这篇文章主要介绍了C#调用RabbitMQ实现消息队列的示例代码，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧...2020-06-25
- 这篇文章主要介绍了解决kafka消息堆积及分区不均匀的问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教...2021-09-12
- 这篇文章主要为大家详细介绍了.net msmq消息队列的实例，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下...2021-09-22
SpringBoot+Nacos+Kafka微服务流编排的简单实现
本文主要介绍了SpringBoot+Nacos+Kafka微服务流编排的简单实现，文中通过示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下...2021-08-20- class Memcache_Queue { private $memcache; private $name; private $prefix; function __construct($maxSize, $name, $memcache, $prefix = "__memcach...2016-11-25
- 这篇文章主要介绍了.Net Core 集成 Kafka的实现步骤，帮助大家更好的理解和学习使用.net技术，感兴趣的朋友可以了解下...2021-09-22
- 这篇文章主要介绍了PHP基于Redis消息队列实现发布微博的方法,结合实例形式分析了php+redis数据库的安装、连接、读取、插入等相关操作技巧,需要的朋友可以参考下...2017-05-08
- 这篇文章主要介绍了java自己手动控制kafka的offset操作，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧...2021-02-20
- 今天我们说说消息队列的问题，来带大家探一探消息队列的水有多深，希望看完本文大家在引入消息队列的时候先想一想，是不是一定要引入？引入消息队列后产生的问题能不能解决...2021-10-28