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

RabbitMQ 消息队列的工作模式

RabbitMQ 提供了多种工作模式,按照官网的描述,实际上可以分为七种模式

简单模式
  • 作用: 生产者将消息发送到队列,消费者从队列中获取消息。每条消息只能被一个消费者消费。

  • 适用场景: 适用于消息量较小且不需要复杂路由逻辑的场景。

RabbitMQ 提供了多种工作模式,按照官网的描述,实际上可以分为七种模式

工作队列模式
  • 作用: 通过多个消费者分担任务,达到负载均衡的目的。是一种竞争关系的模式,多个消费者之间是竞争关系,即一条消息如果被某个消费者消费了,那么其他的消费者就获取不到了。

  • 适用场景: 适用于需要并行处理大量独立任务的场景,如图像处理、视频转码等

发布/订阅模式
  • 作用: 消息发布到交换机,所有绑定到该交换机的队列都会收到消息。常用的交换机类型是 fanout。

  • 适用场景: 适用于广播消息的场景,如日志处理、事件通知等

路由模式
  • 作用: 消息发布到交换机,并根据路由键将消息发送到相应的队列。以此去匹配交换机和队列的绑定,常用的交换机类型是 direct.

  • 适用场景: 适用于需要对消息进行分类处理的场景,如日志系统中按严重级别分类的日志处理。

主题模式
  • 作用: 消息发布到交换机,并根据路由键模式( 通配符匹配 )将消息发送到相应的队列。常用的交换机类型是topic。

  • 适用场景: 适用于需要根据复杂的路由规则对消息进行分类处理的场景,如日志系统中按模块和严重级别分类的日志处理。

RPC 模式

作用: 实现远程过程调用,客户端发送请求消息到队列,服务器端处理后返回响应消息。 适用场景: 适用于需要实现远程服务调用的场景,如微服务之间的通信。

发布确认模式
  • 作用: 用于确保消息已经成功地发布并被 broker 接收。它提供了一种轻量级的方法来确认消息的持久性和可靠性,适用于需要高可靠性消息传递的场景。

  • 适用场景: 金融交易、订单处理等确保消息被可靠地传递和处理,防止丢失的场景。


http://www.kler.cn/a/557598.html

相关文章:

  • 基于VirtualBox虚拟机部署完全分布式Hadoop环境
  • TextGNN: Improving Text Encoder via Graph Neural Network in Sponsored Search
  • Pytorch框架03-网络的搭建(nn.Module/卷积层/池化层/非线性激活/线性层/CIFAR-10分类模型搭建)
  • 分页功能组件开发
  • 1688代采下单API接口使用指南:实现商品采集与自动化下单
  • 深度学习-5.卷积网络
  • npm、pnpm和yarn有什么区别
  • Matplotlib 高级图表绘制与交互式可视化(ipywidgets)
  • 【Windows系统node_modules删除失败(EPERM)问题解析与应对方案】
  • mysql之规则优化器RBO
  • 关于 Grok-3 大语言模型的研究
  • Web Worker终极优化指南:4秒卡顿→0延迟的实战蜕变
  • 【AcWing】动态规划-线性DP -选数异或
  • MapReduce 读取 Hive ORC ArrayIndexOutOfBoundsException: 1024 异常解决
  • python脚本(一):飞书机器人实现新闻抓取与推送
  • socket()函数的概念和使用案例
  • Android:权限permission申请示例代码
  • C++ 设计模式-模板方法模式
  • 【Python】Python顺序语句经典题合集
  • java开发——为什么要使用动态代理?