Kafka - 消息队列的两种模式

news/2024/7/3 0:08:06

文章目录

  • 消息队列的两种模式
    • 点对点模式(Point-to-Point,P2P)
    • 发布/订阅模式(Publish/Subscribe,Pub/Sub)
  • 小结

在这里插入图片描述


消息队列的两种模式

消息队列确实可以根据消息传递的模式分为

  • 点对点模式
  • 发布/订阅模式

在这里插入图片描述

这两种模式有不同的特点和应用场景:

点对点模式(Point-to-Point,P2P)

  1. 点对点模式(Point-to-Point,P2P):

    • 在点对点模式中,有一个生产者(Producer)将消息发送到一个特定的队列(Queue)。
    • 只有一个消费者(Consumer)可以接收和处理队列中的消息。
    • 消息在队列中存储,一旦被消费者接收,就会从队列中删除。

这种模式适用于一对一的通信,其中生产者和消费者之间有直接的关联,通常用于任务分发和处理。


发布/订阅模式(Publish/Subscribe,Pub/Sub)

  1. 发布/订阅模式(Publish/Subscribe,Pub/Sub):
    • 在发布/订阅模式中,生产者将消息发布到一个主题(Topic)而不是队列。
    • 多个消费者可以订阅一个或多个主题,以接收相关的消息。
    • 消息广播给所有订阅了相应主题的消费者,每个消费者都会收到一份消息的拷贝。

这种模式适用于一对多的通信,其中消息的发送者不需要关心谁会接收消息,通常用于事件处理、日志记录和实时通知等场景。


小结

消息队列主要分为两种模式:点对点模式(一个生产者对口一个消费者)和发布/订阅模式(一对多)。

这两种模式有各自的优势和适用性,选择哪种模式取决于应用程序的需求。

  • 点对点模式适用于有明确定位的消息接收者的情况
  • 发布/订阅模式适用于需要将消息广播给多个订阅者的情况。

在实际的消息队列系统中,可以根据需求选择合适的模式来实现不同类型的消息传递。

在这里插入图片描述


http://lihuaxi.xjx100.cn/news/1717114.html

相关文章

离谱!面试为啥都问Kafka?赶紧补一下

目录 一、理解Kafka集成模式1.1 什么是Kafka?1.2 以下是Kafka的关键概念: 二、为什么需要批处理和流处理?三、Kafka主题分区策略3.1 默认分区策略3.2 自定义分区策略3.3 最佳实践:如何选择分区策略 四、批处理与流处理简介4.1 批处…

【UE】UMG通信的三种方法

目录 前言 方法一:通过“获取类的所有控件”节点通信 方法二:当创建控件蓝图时传入其它控件蓝图的对象引用 *方法三:使用HUD类来管理UMG通信 前言 首先我们创建了三个控件蓝图,那么其中的一个控件蓝图如何与剩下的控件蓝图通…

BadNets:基于数据投毒的模型后门攻击代码(Pytorch)以MNIST为例

加载数据集 # 载入MNIST训练集和测试集 transform transforms.Compose([transforms.ToTensor(),]) train_loader datasets.MNIST(rootdata,transformtransform,trainTrue,downloadTrue) test_loader datasets.MNIST(rootdata,transformtransform,trainFalse) # 可视化样本 …

Elasticsearch:使用 Open AI 和 Langchain 的 RAG - Retrieval Augmented Generation (三)

这是继之前文章: Elasticsearch:使用 Open AI 和 Langchain 的 RAG - Retrieval Augmented Generation (一) Elasticsearch:使用 Open AI 和 Langchain 的 RAG - Retrieval Augmented Generation (二&…

Docker 启动远程服务访问不了

今天一下午在弄这个 1、防火墙是否关了 firewall-cmd --state2、ip转发开没开 sysctl net.ipv4.ip_forward3、service iptables是不是打开并拦截了 4、检查docker启动的端口号是否一致,或者启动时对不对 5、检查docker的服务是否起来了,比如你的端口号…

【Java】泛型擦除机制

擦除机制:将一个List集合 泛型 赋值给一个没有使用到泛型List集合,直接去除泛型 示例代码 package com.collection.Demo06;import java.util.ArrayList; import java.util.List;/*** 泛型擦除机制*/ public class Test06 {public static void main(Stri…

怎么禁止U盘拷贝电脑资料

怎么禁止U盘拷贝电脑资料 现如今U盘已经成为了人们日常传输文件的主要方式之一,U盘在给我们提供便利的同时,也带来了一些安全隐患,比如U盘可以轻松地复制电脑文件,这可能会导致机密信息泄露。因此,本文将介绍一些方法…

Sharding-JDBC-5.0.0 实现按月分表、自动建表、自动刷新节点

1、引入Maven 依赖 <dependency><groupId>org.apache.shardingsphere</groupId><artifactId>shardingsphere-jdbc-core-spring-boot-starter</artifactId><version>5.0.0</version></dependency><dependency><groupI…