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

rabbitmq Direct交换机简介

在实际开发中,需求可能变得复杂,如消息的收发和处理。以支付系统为例,成功支付后需要改变订单状态并通知用户,而失败则不需要。为处理这种情况,提出了使用Direct交换机,它可以根据规则将消息路由到指定队列。绑定队列时,需要约定一个暗号,以确定消息的处理对象。如果同一个队列绑定到相同的键,那么所有消息都将发送给该队列,实现了定向广播的效果。这种交换机模式更加灵活,可以根据配置实现不同的定向效果。
在这里插入图片描述
在这里插入图片描述

在这里插入图片描述
创建一个direct类型的交换机
在这里插入图片描述
创建两个队列,再绑定上Routing Key

在这里插入图片描述
单元测试,根据交换机和Routing Key的关键字,创建消息到消息到交换机中
在这里插入图片描述
交换机发现两个队列都绑定了red这个key,然后发现两个消费者都对该消息进行了消费

在这里插入图片描述
上图可以看到,当发送的消息key指定为blue时,只有队列1收到了消息,且只有消费者1进行处理消息

相关文章:

  • React Hooks 与异步数据管理
  • Python-matplotlib中的Pyplot API和面向对象 API
  • SolidWorks建模(U盘)- 多实体建模拆图案例
  • STM32:CAN总线精髓:特性、电路、帧格式与波形分析详解
  • CppCon 2014 学习:Decomposing a Problem for Parallel Execution
  • Docker 安装 Redis 容器
  • 如何使用flask做任务调度
  • 机器学习算法:逻辑回归
  • 分布式锁优化:使用Lua脚本保证释放锁的原子性问题
  • 单元测试-断言常见注解
  • MCP还是A2A?AI未来技术选型深度对比分析报告
  • 解决:install via Git URL失败的问题
  • 电路图识图基础知识-高、低压供配电系统电气系统的继电自动装置(十三)
  • 【华为云Astro Zero】组装设备管理页面开发(图形拖拽 + 脚本绑定)
  • 使用 MCP 将代理连接到 Elasticsearch 并对索引进行查询
  • Kotlin 扩展函数详解
  • 【iOS(swift)笔记-14】App版本不升级时本地数据库sqlite更新逻辑二
  • 【数据分析】第四章 pandas简介(1)
  • 基于STM32的循迹避障小车的Proteus仿真设计
  • 《棒球万事通》棒球特长生升学方向·棒球1号位
  • seo分析seo诊断/哈尔滨关键词优化方式
  • 企业网站开发论文/优化品牌seo关键词
  • 晚上必看的正能量网站app/seo优化网络公司排名
  • 做那种网站/软文网官网
  • 怎么做网站 白/连云港seo优化
  • 网站做301对优化有影响/考证培训机构报名网站