Kafka中消息队列的两种模式讲解
更新时间：2022年05月05日 11:47:38 作者：MnerX
这篇文章主要介绍了Kafka中消息队列的两种模式讲解，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
Kafka消息队列的两种模式
消息队列包括两种模式，点对点模式（point to point， queue）和发布/订阅模式（publish/subscribe，topic）
1、点对点模式
点对点模式下包括三个角色：
- 消息队列
- 发送者 (生产者)
- 接收者（消费者）
消息发送者生产消息发送到queue中，然后消息接收者从queue中取出并且消费消息。消息被消费以后，queue中不再有存储，所以消息接收者不可能消费到已经被消费的消息。
点对点模式特点：
- 每个消息只有一个接收者（Consumer）(即一旦被消费，消息就不再在消息队列中)；
- 发送者和接收者间没有依赖性，发送者发送消息之后，不管有没有接收者在运行，都不会影响到发送者下次发送消息；
- 接收者在成功接收消息之后需向队列应答成功，以便消息队列删除当前接收的消息；
2、发布/订阅模式
发布/订阅模式下包括三个角色：
- 角色主题（Topic）
- 发布者(Publisher)
- 订阅者(Subscriber)
发布者将消息发送到Topic,系统将这些消息传递给多个订阅者。
发布/订阅模式特点：
- 每个消息可以有多个订阅者；
- 发布者和订阅者之间有时间上的依赖性。针对某个主题（Topic）的订阅者，它必须创建一个订阅者之后，才能消费发布者的消息。
- 为了消费消息，订阅者需要提前订阅该角色主题，并保持在线运行；
Kafka消息队列模型图解
Kafka 的消息队列一般分为两种模式：点对点模式和发布订阅模式
Kafka 是支持消费者群组的，也就是说 Kafka 中会有一个或者多个消费者，如果一个生产者生产的消息由一个消费者进行消费的话，那么这种模式就是点对点模式
如果一个生产者或者多个生产者产生的消息能够被多个消费者同时消费的情况，这样的消息队列成为发布订阅模式的消息队列
队列模型非常简单 topic主题：
队列 就是消息的分类。
以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。
相关文章
这篇文章主要介绍了Java排序算法中的选择排序算法实现,选择排序算法的实现思路类似插入排序,分已排序区间和未排序区间,选择排序每次会从未排序区间中找到最小(大)的元素,将其放到已排序区间的末尾,需要的朋友可以参考下2023-12-12
这篇文章主要介绍了RabbitMQ Stream插件使用案例代码,2.4版为RabbitMQ流插件引入了对RabbitMQStream插件Java客户端的初始支持,需要的朋友可以参考下2024-04-04
下面小编就为大家分享一篇spring boot 自定义starter的实现教程，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2017-12-12
这篇文章主要介绍了Java的Synchronized锁原理和优化,synchronized的作用是保证在同一时刻， 被修饰的代码块或方法只会有一个线程执行，以达到保证并发安全的效果,需要的朋友可以参考下2023-05-05
java中的new关键字是实例化对象，接下来本文通过一个案例给大家讲解Java中的 new 关键字，感兴趣的朋友可以参考下2016-08-08
这篇文章主要介绍了SpringMVC的概念以及快速入门示例,SpringMVC 已经成为目前最主流的MVC框架之一,它通过一套注解，让一个简单的 Java 类成为处理请求的控制器，而无须实现任何接口,需要的朋友可以参考下2023-05-05
JAVA在1.8版本推出Optional，官方文档将其描述为可能包含或不包含非空值的容器对象，目前Optional用于避免程序出现异常NullPointerException，感兴趣的可以了解一下2022-09-09
这篇文章主要介绍了使用Java servlet实现自动登录退出功能,，本文通过实例代码给大家介绍的非常详细，具有一定的参考借鉴价值，需要的朋友可以参考下2019-11-11
基于Docker的K8s(Kubernetes)集群部署方案
这篇文章主要介绍了基于Docker的K8s(Kubernetes)集群部署方案,文中介绍了安装k8s的可视化界面的相关操作，需要的朋友可以参考下2024-01-01
这篇文章主要介绍了Java基础之文件概述,文中有非常详细的代码示例,对正在学习java基础的小伙伴们有一定的帮助,需要的朋友可以参考下2021-05-05
最新评论