“深入理解RabbitMQ交换机的原理与应用“

在这里插入图片描述

深入理解RabbitMQ交换机的原理与应用

  • 引言
  • 1. RabbitMQ交换机简介介绍
    • 1.1 什么是RabbitMQ?
      • 1.1.1 消息中间件的作用
      • 1.1.2 RabbitMQ的特点和优势
    • 1.2 RabbitMQ的基本概念
      • 1.2.1 队列
      • 1.2.2 交换机
      • 1.2.3 路由键
    • 1.3 交换机的作用和分类
      • 1.3.1 直连交换机(direct exchange)
      • 1.3.2 扇出交换机(fanout exchange)
      • 1.3.3 主题交换机(topic exchange)
      • 1.3.4 头交换机(headers exchange)
      • 1.3.5 死信交换机
  • 2. RabbitMQ交换机应用
    • 2.1直连交换机实践
    • 2.2 主题交换机实践
    • 2.3 扇形交换机实践
  • 总结

引言

在当今的分布式系统和微服务架构中,消息中间件扮演着至关重要的角色。RabbitMQ作为一个功能强大的消息中间件,其交换机是其中核心的组件之一。本文将深入探讨RabbitMQ交换机的原理和应用,帮助读者更好地理解和应用消息队列技术。

1. RabbitMQ交换机简介介绍

1.1 什么是RabbitMQ?

RabbitMQ是一个开源的消息代理软件,它遵循AMQP(高级消息队列协议)标准,用于在分布式系统中存储和转发消息。作为消息中间件,RabbitMQ扮演着消息传递和消息队列的角色,允许应用程序之间进行异步通信。

1.1.1 消息中间件的作用

消息中间件的作用在于解耦消息的发送者和接收者,实现异步通信,提高系统的可伸缩性和弹性。它可以协调不同服务之间的通信,确保消息的可靠传递,并提供消息的持久化、路由和传输等功能。

1.1.2 RabbitMQ的特点和优势

RabbitMQ具有高可靠性、灵活的路由、消息持久化、集群和分布式部署支持等特点。它的优势在于支持多种消息传递模式,如点对点、发布/订阅和路由等,同时提供了丰富的插件和管理工具。

1.2 RabbitMQ的基本概念

1.2.1 队列

队列是消息的容器,用于存储消息直到消费者准备接收它们。消息可以被一个或多个消费者订阅。

1.2.2 交换机

交换机是消息的分发中心,它接收来自生产者的消息,并将它们路由到一个或多个队列。

1.2.3 路由键

路由键是生产者在将消息发送到交换机时附加的关键字,交换机根据路由键将消息路由到一个或多个队列。

1.3 交换机的作用和分类

在这里插入图片描述

交换机负责接收来自生产者的消息,并将它们路由到一个或多个队列。RabbitMQ提供了不同类型的交换机,包括直连交换机、扇出交换机、主题交换机和头交换机。

1.3.1 直连交换机(direct exchange)

在这里插入图片描述

直连交换机根据消息的路由键将消息路由到特定的队列。它是最简单的交换机类型,路由键与队列绑定的路由键完全匹配时,消息才会被路由到相应的队列。

1.3.2 扇出交换机(fanout exchange)

扇出交换机会将消息路由到与之绑定的所有队列,忽略消息的路由键。这种模式适合广播消息给多个消费者的场景。

1.3.3 主题交换机(topic exchange)

主题交换机根据消息的路由键和通配符将消息路由到一个或多个队列。它提供了更灵活的路由规则,可以根据路由键的模式进行匹配。
在这里插入图片描述

1.3.4 头交换机(headers exchange)

头交换机使用消息的属性(headers)来进行匹配,而不是路由键。这种交换机类型提供了更复杂的匹配规则,可以根据消息的属性进行匹配和路由。

1.3.5 死信交换机

在这里插入图片描述
在这里插入图片描述

2. RabbitMQ交换机应用

2.1直连交换机实践

创建好队列与交换机,并且绑定

 @Beanpublic Queue queue1(){return new Queue("queue1");}@Beanpublic Queue queue2(){return new Queue("queue2");}@Beanpublic DirectExchange drectexchange(){return new DirectExchange("drectexchange");}@Beanpublic Binding bingding1(){return BindingBuilder.bind(queue1()).to(drectexchange()).with("a");}@Beanpublic Binding bingding2(){return BindingBuilder.bind(queue2()).to(drectexchange()).with("b");}

生产者方法

 @RequestMapping("/send3")public String send3(){//向消息队列发送消息amqpTemplate.convertAndSend("drectexchange","a","hello");return "哈哈;";}

消费者监听

package com.example.consumer;import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;@Component
@SuppressWarnings("all")
@Slf4j
@RabbitListener(queues = "queue1")
public class ReceiverQ1 {
@RabbitHandler
public void process(String msg) {
log.warn("Q1接收到:" + msg);
}
}
package com.example.consumer;import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;@Component
@SuppressWarnings("all")
@Slf4j
@RabbitListener(queues = "queue2")
public class ReceiverQ2 {
@RabbitHandler
public void process(String msg) {
log.warn("Q2接收到:" + msg);
}
}

运行一遍send3方法
在这里插入图片描述

2.2 主题交换机实践

前提准备,打开RabbitMQ服务,参考 构建高可用消息队列系统 01

进入实战

创建好队列与交换机,并且绑定

  @Beanpublic TopicExchange topicExchange(){return new TopicExchange("topicExchange");}@Beanpublic Binding bingding3(){return BindingBuilder.bind(queue1()).to(topicExchange()).with("*.*.a");}@Beanpublic Binding bingding4(){return BindingBuilder.bind(queue2()).to(topicExchange()).with("*.*.b");}@Beanpublic Binding bingding5(){return BindingBuilder.bind(queue1()).to(topicExchange()).with("mq.#");}@Beanpublic Binding bingding6(){return BindingBuilder.bind(queue2()).to(topicExchange()).with("mq.#");}

生产者方法

@RequestMapping("/send4")public String send4(String rex){//向消息队列发送消息amqpTemplate.convertAndSend("topicExchange",rex,"hello");return "哈哈;";}

消费者监听在直连交换机上有
测试1
在这里插入图片描述
在这里插入图片描述
测试2
在这里插入图片描述
在这里插入图片描述
测试3
mq打头
在这里插入图片描述
在这里插入图片描述

2.3 扇形交换机实践

创建好队列与交换机,并且绑定

  @Beanpublic FanoutExchange fanoutExchange(){return new FanoutExchange("fanoutExchange");}@Beanpublic Binding bingding7(){return BindingBuilder.bind(queue1()).to(fanoutExchange());}@Beanpublic Binding bingding8(){return BindingBuilder.bind(queue2()).to(fanoutExchange());}

生产者方法
生产者调用convertAndSend时第二个参数必须要有,可以给null值,否则报错

 @RequestMapping("/send5")public String send5(){//向消息队列发送消息amqpTemplate.convertAndSend("fanoutExchange","","hello");return "哈哈;";}

消费者监听在直连交换机上有
测试
在这里插入图片描述

在这里插入图片描述

总结

RabbitMQ交换机作为消息中间件的核心组件,其灵活的路由规则和丰富的特性为分布式系统和微服务架构提供了强大的消息通信支持。通过深理解RabbitMQ交换机的原理和应用,可以更好地设计和构建可靠的消息传递系统,为复杂的应用场景提供稳定高效的消息通信机制。

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

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

相关文章

leetcode 热题100-学习计划

一、题目链接 1. 两数之和 - 力扣(LeetCode) 解题思路 暴力破解——解题代码 class Solution:def twoSum(self, nums: List[int], target: int) -> List[int]:n len(nums)result []for i in range(0,n):for j in range(i 1,n):#print(i,j)sum …

VS Code Json格式化插件-JSON formatter

🦪整个文件格式化 按快捷键Shift Alt F 🥪仅格式化选择内容 需要选择完整的json段落即:{} 或 [] 括起来的部分,再按快捷键Ctrl K F

社区公益培训系统功能说明

社区公益培训系统功能说明 本系统将用于社区面向居民开展的公益培训课程展示,在线报名,并按班级排课上课,上课时学员要扫码签到,经常旷课的学员将禁止再报名其他课程。 1. 用户注册与登录 - 提供用户注册和登录功能,…

鸿蒙不再兼容安卓,鸿蒙开发薪资高达4w+,程序员是否需转行鸿蒙?

鸿蒙系统的崛起 鸿蒙系统的推出经历了长时间的研发和完善,它是一款自主研发的操作系统,集成了最新的技术和创新理念。该系统具备卓越的安全性、兼容性和扩展性,因此备受关注。最初,鸿蒙系统主要应用于华为手机产品,但…

惬意上手Python —— 装饰器和内置函数

1. Python装饰器 Python中的装饰器是一种特殊类型的函数,它允许用户在不修改原函数代码的情况下,增加或修改函数的行为。 具体来说,装饰器的工作原理基于Python的函数也是对象这一事实,可以被赋值给变量、作为参数传递给其他函数或者作为其他…

比较有创意的网站

有创意的网站通常展示了独特的设计、交互或内容。以下是一些备受赞誉的有创意的网站,你可以参考: Awwwards: Awwwards 是一个评选并展示全球最优秀网站的平台。你可以在这里找到很多有创意的网站设计。 Awwwards CSS Design Awards: 类似于Awwwards&…

3d gaussian splatting笔记(paper部分翻译)

本文为3DGS paper的部分翻译。 基于点的𝛼混合和 NeRF 风格的体积渲染本质上共享相同的图像形成模型。 具体来说,颜色 𝐶 由沿射线的体积渲染给出: 其中密度 𝜎、透射率 𝑇 和颜色 c 的样本是沿着射线以…

VSCode插件 —— Cody AI (免费AI助手!)

之前介绍过一款 阿里云免费的AI开发工具——通义灵码 TONGYI Lingma 本文再推荐一个可以极大提高开发前端开发效率的工具 —— Cody AI (Sourcegraph),同样是免费的! 不过,使用Cody AI需要有github 或 Google 、 git…

vue3相比vue2的效率提升

1、静态提升 2、预字符串化 3、缓存事件处理函数 4、Block Tree 5、PatchFlag 一、静态提升 在vue3中的app.vue文件如下: 在服务器中,template中的内容会变异成render渲染函数。 最终编译后的文件: 1.静态节点优化 那么这里为什么是两部分…

内网安全管理系统(保密管理系统)

在当今信息化的时代,企业的内网已经成为其核心资产的重要组成部分。 随着企业的快速发展和信息化程度的提升,内网安全问题日益凸显,如何保障内网的安全和机密信息的保密性,已经成为企业亟待解决的问题。 内网安全管理系统(保密管…

springboot(ssm计算机学习系统 在线课程学习管理系统Java系统

springboot(ssm计算机学习系统 在线课程学习管理系统Java系统 开发语言:Java 框架:springboot(可改ssm) vue JDK版本:JDK1.8(或11) 服务器:tomcat 数据库:mysql 5.7…

C# 实现 摩尔斯电码

摩尔斯电码(Morse code)是一种用于传输信息的编码系统。它由美国发明家塞缪尔摩尔斯(Samuel Morse)于1830年代发明并推广。摩尔斯电码是一种通过发送和接收短暂的电信号或光信号来表达字母、数字和标点符号的国际通信方式。 摩尔斯…

现在的小年轻真的卷得过分了,真是完全不把自己当人啊

现在的小年轻真的卷得过分了,真是完全不把自己当人啊 都说00后躺平了,但是有一说一,该卷的还是卷。这不,前段时间我们公司来了个00后,工作都没两年,跳槽到我们公司起薪18K,都快接近我了。后来才…

常用电子器件学习——MOS管

MOS管介绍 MOS,是MOSFET的缩写。MOSFET 金属-氧化物半导体场效应晶体管,简称金氧半场效晶体管(Metal-Oxide-Semiconductor Field-Effect Transistor, MOSFET)。 一般是金属(metal)—氧化物(oxide)—半导体(semiconductor)场效应晶…

力扣670-最大交换

最大交换 题目链接 class Solution { public:int maximumSwap(int num) {string sto_string(num);//转成字符串for(int i0;i<s.size();i)//选择排序模板{int posi;for(int js.size()-1;j>i;--j)//内层循环从后往前if(s[pos]<s[j])posj;if(pos!i)//如果最大的不是i&a…

unity 相机截图

/// <summary> /// 针对相机的截图 /// </summary> public void CameraScreenShot(){ Rect rect new Rect(0,0,Screen.width,Screen.height); RenderTexture renderTexture RenderTexture.GetTemporary((int)rect.width,(int)rect.height,0, RenderTextureFormat…

RabbitMQ消息应答与发布

消息应答 RabbitMQ一旦向消费者发送了一个消息,便立即将该消息,标记为删除. 消费者完成一个任务可能需要一段时间,如果其中一个消费者处理一个很长的任务并仅仅执行了一半就突然挂掉了,在这种情况下,我们将丢失正在处理的消息,后续给消费者发送的消息也就无法接收到了. 为了…

蓝桥杯官网填空题(骰子迷题)

题目描述 本题为填空题&#xff0c;只需要算出结果后&#xff0c;在代码中使用输出语句将所填结果输出即可。 小明参加了少年宫的一项趣味活动&#xff1a;每个小朋友发给一个空白的骰子&#xff08;它的 6 个面是空白的&#xff0c;没有数字&#xff09;&#xff0c;要小朋…

OpenHarmony驱动消息机制管理

驱动消息机制管理 当用户态应用和内核态驱动需要交互时&#xff0c;可以使用HDF框架的消息机制来实现。 消息机制的功能主要有以下两种&#xff1a; 用户态应用发送消息到驱动。 用户态应用接收驱动主动上报事件。 配置管理 HCS&#xff08;HDF Configuration Source&…

JVM—垃圾回收

什么是垃圾 一个没有被任何引用的对象就是一个垃圾对象, 垃圾对象需要被清理回收,否则一直占用内存空间, 其他新对象无法使用垃圾对象空间, 严重的话会造成内存溢出 早期的垃圾回收&#xff1a; 早期例如c/c是需要程序员手动在程序对不再使用的对象进行删除释放. 给程序…