当前位置: 首页 > news >正文

Rabbitmq中常见7种模式介绍

  1. p:生成者,生成消息的程序
  2. c:消费者,消费消息的程序
  3. Queue:消息队列,用于缓存消息,生产者向里面投递消息,消费者从里面拿取消息消费
  4. X:交换机,在rabbitMQ中,实际上是把生成者的消息先发送到交换机上面,然后在按照一定的规则路由到一个或者多个队列中,相关概念:[[交换机类型]]

simple(简单模式)

在这里插入图片描述

  1. 一个生产者,一个消费者
  2. 适用场景:消息只能被单个消费者处理

此处省略了exchange交换机,在rabbitmq中是一定有交换机的,其他的可能没有

Work Queue(工作队列)

在这里插入图片描述

  1. 一个生产者,多个消费者
  2. 多消息的情况下,Work Queue 会将消息分派给不同的消费者,每个消费者都会接收到不同的消息
  3. 特点:消息不会重复,分配给不同的消费者
  4. 使用场景:在集群环境中做异步处理

此处省略了exchange交换机,在rabbitmq中是一定有交换机的,其他的可能没有

比如在12306短信通知服务,订票成功后,订单消息会发送到RabbitMQ,短信服务从RabbitMQ中获取订单消息,并且发送消息
在这里插入图片描述

Publish/Subscribe(发布/订阅)

在这里插入图片描述

  1. 一个生产者,多个消费者
  2. X代表交换机消息复制多份,每个消费者接收相同的消息
  3. 生产者发送一条消息,经过交换机转发到不同的队列,多个不同队列就有多个不同的消费者(无条件)
  4. 适合场景:消息需要被多个消费者同时接收的场景,如实时通知或者广播消息

Routing(路由模式)

在这里插入图片描述

  1. 路由模式是发布订阅模式的变种,在其基础上添加了RoutingKey
  2. 相比于前者的无条件分发消息,路由模式根据Exchange的RoutingKey的规则将数据筛选后发送给对应的消费者队列
  3. 使用场景:需要特定规则分发消息的场景

Topic(通配符模式)

在这里插入图片描述

  1. 在routingKey的基础上,增添[[交换机类型#^8c5d09|通配符]]的功能,使得匹配规则更加灵活
  2. 交换机通过RoutingKey将消息转发给RoutingKey匹配的队列
  3. 适用场景:需要灵活匹配和过滤消息的场景

[!QUESTION] Routing和Topic有什么不同?
不同之处:routingKey的匹配方式不同。Routing模式是相等匹配,topics模式是通配符匹配

RPC(Remote Procedure Call)

在这里插入图片描述

  1. 当客户端启动时,它会创建一个独占的回调队列。
  2. 对于 RPC 请求,客户端发送一个包含两个属性的消息: reply_to,该属性设置为回调队列,以及 correlation_id,该属性为每个请求设置一个唯一值。
  3. 请求被发送到一个 rpc_queue 队列。
  4. RPC 工作进程(又名:服务器)正在该队列上等待请求。当请求出现时,它会执行任务,并使用来自 replyTo 字段的队列将结果消息发送回客户端。
  5. 客户端在应答队列上等待数据。当消息出现时,它会检查 correlationId 属性。如果它与请求中的值匹配,则将响应返回给应用程序。

Publisher Confirms(发布确认模式)

Publisher Confirms模式是RabbitMQ提供的一种确保消息可靠发送到RabbitMQ服务器的机制。在这种模式下,生产者可以等待RabbitMQ服务器的确认,以确保消息已经被服务器接收并处理。

  1. 生产者将Channel设置为confirm模式(通过调用channel.confirmSelect()完成)后,发布的每一条消息都会获得一个唯一的ID,生产者可以将这些序列号与消息关联起来,以便跟踪消息的状态。
  2. 当消息被RabbitMQ服务器接收并处理后,服务器会异步地向生产者发送一个确认(ACK)给生产者(包含消息的唯一ID),表明消息已经送达。
  3. 通过Publisher Confirms模式,生产者可以确保消息被RabbitMQ服务器成功接收,从而避免消息丢失的问题。
  4. 适用场景:对数据安全性要求较高的场景。比如金融交易,订单处理。
http://www.lryc.cn/news/604797.html

相关文章:

  • pytorch小记(三十三):PyTorch 使用 TensorBoard 可视化训练过程(含完整示例)
  • 用 Go Typed Client 快速上手 Elasticsearch —— 从建索引到聚合的完整实战
  • 8.Linux : 日志的管理与时钟同步的配置
  • Rabbit MQ的消息模式-Java原生代码
  • YOLO-01目标检测基础
  • 02 基于sklearn的机械学习-特征降维(特征选择、PCA)、KNN算法、模型选择与调优(交叉验证、朴素贝叶斯算法、拉普拉斯平滑)
  • Android调用python库和方法的实现
  • YOLOv5u:无锚点检测的革命性进步
  • android-PMS-创建新用户流程
  • 舆情监测专员需要哪些常用软件工具?
  • 基于 Hadoop 生态圈的数据仓库实践 —— OLAP 与数据可视化(一)
  • 论文Review 3DGSSLAM S3PO-GS | ICCV 2025 港科广出品!| 高效快速的3DGSSLAM!
  • sqli-labs:Less-1关卡详细解析
  • CMS框架漏洞
  • 3D Web轻量化引擎HOOPS Communicator数据处理与流式加载能力概述
  • 【音视频】WebRTC-Web 音视频采集与播放
  • 【预判一手面试问题:排序】
  • 依托客户满意度分析协助企业精准把握市场趋势​(满意度调查)
  • 智能AI医疗物资/耗材管理系统升级改造方案分析
  • InfluxDB 与 Java 框架集成:Spring Boot 实战(二)
  • VSCode插件开发完整教程:从零开始创建文件导出插件
  • Python 程序设计讲义(37):字符串的处理方法——设置字符串居中显示:center() 方法
  • 图像平滑处理
  • 9.项目起步(3)
  • OpenCV学习day1
  • 实习小记(个人中心的编辑模块)
  • 商标注册后可以随意更改字体和颜色吗!
  • 怎么理解锁相环主时钟(PLL)怎么做到对时钟进行倍频?
  • Keil STM32工程各文件作用
  • AI框架工具FastRTC快速上手2——整体框架及Stream类详解