RabbitMQ的Fanout交换机

Fanout交换机

Fanout,英文翻译是扇出,我觉得在MQ中叫广播更合适。
在广播模式下,消息发送流程是这样的:
image.png

  • 1) 可以有多个队列
  • 2) 每个队列都要绑定到Exchange(交换机)
  • 3) 生产者发送的消息,只能发送到交换机
  • 4) 交换机把消息发送给绑定过的所有队列
  • 5) 订阅队列的消费者都能拿到消息

我们的计划是这样的:
image.png

  • 创建一个名为 hmall.fanout的交换机,类型是Fanout
  • 创建两个队列fanout.queue1fanout.queue2,绑定到交换机hmall.fanout

3.5.1.声明队列和交换机(案例练习)

利用SpringAMQP演示FanoutExchange的使用

在这里插入图片描述

在控制台创建队列fanout.queue1:
image.png
在创建一个队列fanout.queue2
image.png
然后再创建一个交换机:
image.png
然后绑定两个队列到交换机:
image.png
image.png

3.5.2.消息发送

在publisher服务的SpringAmqpTest类中添加测试方法:

    /*** 向新声明的交换机发送消息(hmall.fanout)*/@Testpublic void testFanoutExchange() {// 交换机名称String exchangeName = "hmall.fanout";// 消息String message = "hello, everyone!";rabbitTemplate.convertAndSend(exchangeName, null, message);}

3.5.3.消息接收

在consumer服务的SpringRabbitListener中添加两个方法,作为消费者:

    /*** 接受hmall.fanout的消息* @param msg*/@RabbitListener(queues = "fanout.queue1")public void listenFanoutQueue1(String msg) {System.out.println("消费者1所在的fanout.queue1接收到Fanout消息:【" + msg + "】");}/*** 接受hmall.fanout的消息* @param msg*/@RabbitListener(queues = "fanout.queue2")public void listenFanoutQueue2(String msg) {System.out.println("消费者2所在的fanout.queue2接收到Fanout消息:【" + msg + "】");}

3.5.4.总结

交换机的作用是什么?

  • 接收publisher发送的消息
  • 将消息按照规则路由到与之绑定的队列
  • 不能缓存消息,路由失败,消息丢失
  • FanoutExchange的会将消息路由到每个绑定的队列

在这里插入图片描述

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/861585.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

嵌入技术Embedding

嵌入(Embedding)是一种将高维数据映射到低维空间的技术,广泛应用于自然语言处理(NLP)、计算机视觉和推荐系统等领域。嵌入技术的核心思想是将复杂的数据表示为低维向量,使其在这个低维空间中保留尽可能多的…

Java异常处理机制包括哪些?

Java的异常处理机制是一个复杂且多层次的系统,旨在确保程序在遇到错误或意外情况时能够优雅地进行处理。以下是Java异常处理机制的主要组成部分: Java中的异常分为两大类:检查型异常(checked exceptions)和非检查型异…

嵌入式学习——硬件(ARM内核汇编指令)——day52

ARM汇编指令 学习arm汇编的主要目的是为了编写arm启动代码,启动代码启动以后,引导程序到c语言环境下运行。换句话说启动代码的目的是为了在处理器复位以后搭建c语言最基本的需求。因此启动代码的主要任务有: 初始化异常向量表;初…

GD32 GPIO引脚初始化失败问题

问题描述 使用GD32的GPIO引脚来控制 74HC595 ,发现引脚一直无法控制,始终输出3.3v,初始化环节应该是出了问题。用通俗的话来说,就是点灯点不亮 排查了MCU、光耦隔离芯片、被强行上拉等问题,最后发现是GD的GPIO时钟使…

linux进程是什么?

进程概念 进程Process是指计算机中已运行的程序,是系统进行资源分配和调度的基本单位,是操作系统结构的基础。 在早期面向进程设计的计算机结构中,进程是程序的基本执行实体。在当代面向线程设计的计算机结构中,进程是线程的容器…

使用Spring Boot和Spring Data JPA进行数据库操作

使用Spring Boot和Spring Data JPA进行数据库操作 大家好,我是免费搭建查券返利机器人省钱赚佣金就用微赚淘客系统3.0的小编,也是冬天不穿秋裤,天冷也要风度的程序猿!在现代的Web应用开发中,数据库操作是不可或缺的一…

Spring Cloud Netflix:构建强大微服务生态系统的利器

Spring Cloud Netflix是一组集成框架,它将Netflix的多个开源组件整合到Spring Boot应用程序中,使得构建云原生应用程序变得更加简单。这些组件包括用于服务发现和注册的Eureka,断路器模式的实现Hystrix,用于API网关的Zuul&#xf…

零点到两点,我部署了一个es

一开始的准备 实在是水平有限,Clash虚拟机网出不去,研究了LAN方案,还在咸鱼买了一单,搞不定,没辙,那我老老实实下载tar包得了,就不docker了 下载安装 直接官网给它安个es https://www.elasti…

vue自定义事件传递数据

页面应用一个组件,采用自定义事件来传递参数 $emit是Vue实例的一个方法,它用于触发自定义事件。这些事件可以被父组件监听到,从而实现子组件向父组件的通信。 这种方法的好处在于,它可以让数据的流动保持单向,有助于…

web基础学习

1、安装 React 从一开始就被设计为可以被渐进地采用,你可以根据需要或多或少地试用 React。无论你只是想体验一下 React,并为 HTML 页面添加一些交互性,还是创建一个复杂的 React In this chapter 如何将 React 添加到 HTML 页面中 如何新建…

【Android面试八股文】Framework面试:ThreadLocal的原理,以及在Looper是如何应用的?

文章目录 ThreadLocal的原理,以及在Looper是如何应用的?ThreadLocal 是什么ThreadLocalMap是什么?ThreadLocal在Looper中的应用**总结**扩展阅读ThreadLocal的原理,以及在Looper是如何应用的? ThreadLocal 可以把一个对象保存在指定的线程中,对象保存后,只能在指定线程…

C# 初始化的代码是放在Form的构造函数还是放在Form_Load

构造函数Form_Load事件以下是一个简单的例子来说明两者的使用总的来说 在 C#中使用 Windows Forms应用程序开发时,初始化代码通常可以放在两个地方: Form的构造函数或 Form的 Load事件。 构造函数 当你创建一个Form对象时,构造函数会被…

喻颖正:人生算法

1,这是一本什么样的书? 看似在讲算法,实则在讲思维! “算法”:就是解决某个问题的计算方法和可重复的实施步骤。 “人生算法”:教你用科学的思维和方法,应对人生旅途中的不确定性。 2&#…

Git简介与详细教程

一、简介 什么是Git? Git是一款分布式版本控制系统,由Linux之父Linus Torvalds于2005年开发。它旨在快速、高效地处理从小型到大型项目的所有内容。Git与传统的版本控制系统相比,具备显著的优势,主要体现在其分布式架构、强大的…

游戏AI的创造思路-技术基础-深度学习(6)

让人工智障具备信念吧,依莫拉萨~~~串频道暴露年龄。。。不过深度信念和信念真的没啥关系,不知道为啥这样起名 目录 3.6. 深度信念网络(DBN) 3.6.1. 定义 3.6.2. 发展历史 3.6.3. 算法公式 3.6.4. 运行原理 3.6.4.1. 基本原理 3.6.4.2. Python实现…

无线透传技术特点及发展趋势

无线透传技术与其他数据传输技术(如有线连接)相比,具有以下优势和劣势: 1. 优势: 简单易用:无线透传模块由于直接进行数据透传,省去了许多数据处理和协议转换的步骤,使得数据传输更为快速和高效。   传输…

【Week-G1】调用官方GAN实现MNIST数字识别,Pytorch框架

文章目录 1. 准备数据1.1 配置超参数1.2 下载数据1.3 配置数据 2. 创建模型2.1 定义鉴别器2.2 定义生成器 3. 训练模型3.1 创建实例3.2 开始训练3.3 保存模型 4. 什么是GAN(对抗生成网络)? 🍨 本文为🔗365天深度学习训练营 中的学…

【BES2500x系列 -- RTX5操作系统】深入探索CMSIS-RTOS RTX -- 同步与通信篇 -- 信号量和互斥锁 --(三)

💌 所属专栏:【BES2500x系列】 😀 作  者:我是夜阑的狗🐶 🚀 个人简介:一个正在努力学技术的CV工程师,专注基础和实战分享 ,欢迎咨询! &#x1f49…

帕金森患者吞咽困难?如何让饮食更顺畅!

在帕金森病患者的日常生活中,吞咽困难是一个常见而又棘手的问题。它不仅影响了患者的饮食质量,还可能导致营养不良、吸入性肺炎等严重并发症。那么,面对帕金森综合症导致的吞咽困难,我们该如何应对呢? 一、了解帕金森综…

一个去掉PDF背景水印的思路

起因 昨天测试 使用“https://github.com/VikParuchuri/marker” 将 pdf 转 Markdown的过程中,发现转换后的文件中会保护一些背景图片,是转换过程中,程序把背景图识别为了内容。于是想着怎么把背景图片去掉。 背景水印图片的特征 我这里拿…