RabbitMq-队列交换机绑定关系优化为枚举注册

📚目录

  • 📚简介:
  • 🚀比较
    • 💨通常注册
    • 🌈优化后注册
  • ✍️代码
    • 💫自动注册的关键代码

📚简介:

       该项目介绍，rabbitMq消息中间件，对队列的注册，交换机的注册，队列与交换机的绑定关系进行注册，这三个步骤进行简化，通过枚举的配置完成这些操作。可以参考之前写的文章>SpringBoot整合Rabbitmq

🚀比较

💨通常注册

通常我们创建一个队列至少三个步骤

  1. 声明队列
  2. 声明交换机
  3. 队列绑定到交换机上，并且且设置路由关键字

在这里插入图片描述

🌈优化后注册

      我们只需要关注我们的队列枚举，里面已经定义好了通用配置，只有队列名称，交换机，交换机类型的指定我们需要自己定义外，之后的注册不需要你们关注即可完成。

在这里插入图片描述

✍️代码

💫自动注册的关键代码

RabbitMqConfig

代码的运行逻辑

  1. 应用启动：当 Spring Boot 应用启动时，RabbitAdmin Bean 会被初始化并启动。
  2. 队列和交换机的创建：在 createQueue 方法中，代码会遍历所有的队列枚举，将每个队列的相关配置（如交换机类型、持久性等）传递给相应的方法，创建所需的队列和交换机。
  3. 完成配置：一旦所有的交换机和队列创建完成，它们之间的绑定关系也会被设置好，从而确保消息可以在它们之间正确地流动。
/*** @author itmei*/
@Configuration
public class RabbitMqConfig {///**// * 声明队列// * @return// *///@Bean//public Queue directQueue(){//    //持久 - 如果我们声明一个持久队列，则为真（该队列将在服务器重启后继续存在）//    return new Queue(RabbitMqQueueEnum.DEFAULT_DIRECT.getQueueName(),false);//}/////**// * 声明交换机// * @return// *///@Bean//public DirectExchange directExchange(){//    //交换器名称、是否持久化、是否自动删除//    return new DirectExchange(RabbitMqQueueEnum.DEFAULT_DIRECT.getExchangeName(),true,false);//}/////***// * 队列绑定到交换机上// * 并且设置路由关键字// *///@Bean//public Binding binding(Queue queue,DirectExchange exchange){//    return BindingBuilder.bind(queue).to(exchange).with(RabbitMqQueueEnum.DEFAULT_DIRECT.getRoutingKey());//}/*** 用于动态创建队列和交换机* @param rabbitTemplate rabbitMq的模板对象* @return*/@Beanpublic RabbitAdmin rabbitAdmin(RabbitTemplate rabbitTemplate){RabbitAdmin rabbitAdmin = new RabbitAdmin(rabbitTemplate);//默认就是truerabbitAdmin.setAutoStartup(true);return rabbitAdmin;}/*** 绑定* @param rabbitAdmin RabbitAdmin 实例，用于管理队列和交换机的声明* @return*/@Bean("createQueue")public Object createQueue(RabbitAdmin rabbitAdmin) {// 遍历队列枚举RabbitMqQueueEnum.toList().forEach(rabbitMqQueueEnum -> {//创建交换机createExchangeHandle(rabbitAdmin,rabbitMqQueueEnum);// 创建对列createQueueHandle(rabbitAdmin,rabbitMqQueueEnum);// 绑定交换机和对列createBindingHandle(rabbitAdmin,rabbitMqQueueEnum);});return null;}/*** 注册交换机的方法，根据传入的队列枚举配置创建相应类型的交换机。* @param rabbitAdmin RabbitAdmin 实例，用于管理队列和交换机的声明* @param rabbitMqQueueEnum 自定义队列枚举，包含交换机的配置信息，包含交换机的配置信息*/private void createExchangeHandle(RabbitAdmin rabbitAdmin, RabbitMqQueueEnum rabbitMqQueueEnum) {// 获取当前队列的交换机配置ExchangeConfigEnum exchangeConfigEnum = rabbitMqQueueEnum.getExchangeConfigEnum();String exchangeName = rabbitMqQueueEnum.getExchangeName();// 检查是否为延迟交换机if (rabbitMqQueueEnum.isDelayedExchange()) {// 创建并声明延迟交换机rabbitAdmin.declareExchange(new CustomDelayedExchange(// 交换机名称exchangeName,// 交换机是否持久化exchangeConfigEnum.isDurable(),// 交换机是否自动删除exchangeConfigEnum.isAutoDelete(),// 交换机类型exchangeConfigEnum.getType().name().toLowerCase()));} else {// 创建并声明普通交换机createStandardExchange(rabbitAdmin, exchangeName, exchangeConfigEnum);}}/*** 创建并声明标准交换机的方法。* @param rabbitAdmin RabbitAdmin 实例，用于声明交换机* @param exchangeName 交换机的名称* @param exchangeConfigEnum 交换机的配置枚举，包含持久化和自动删除等信息*/private void createStandardExchange(RabbitAdmin rabbitAdmin, String exchangeName, ExchangeConfigEnum exchangeConfigEnum) {AbstractExchange exchange;// 根据交换机类型创建对应的交换机实例switch (exchangeConfigEnum.getType()) {case FANOUT:// 创建 Fanout 交换机exchange = new FanoutExchange(exchangeName, exchangeConfigEnum.isDurable(), exchangeConfigEnum.isAutoDelete());break;case TOPIC:// 创建 Topic 交换机exchange = new TopicExchange(exchangeName, exchangeConfigEnum.isDurable(), exchangeConfigEnum.isAutoDelete());break;case DIRECT:// 创建 Direct 交换机exchange = new DirectExchange(exchangeName, exchangeConfigEnum.isDurable(), exchangeConfigEnum.isAutoDelete());break;default:// 不支持的交换机类型，直接返回return;}// 声明创建的交换机rabbitAdmin.declareExchange(exchange);}/*** 注册队列* @param rabbitAdmin RabbitAdmin 实例，用于管理队列和交换机的声明* @param rabbitMqQueueEnum 自定义队列枚举，包含交换机的配置信息*/public void createQueueHandle(RabbitAdmin rabbitAdmin, RabbitMqQueueEnum rabbitMqQueueEnum) {QueueConfigEnum queueEnum = rabbitMqQueueEnum.getQueueConfigEnum();rabbitAdmin.declareQueue(new Queue(rabbitMqQueueEnum.getQueueName(),queueEnum.isDurable(), queueEnum.isExclusive(), queueEnum.isAutoDelete(), queueEnum.getArguments()));}/*** 注册绑定关系* @param rabbitAdmin RabbitAdmin 实例，用于管理队列和交换机的声明* @param rabbitMqQueueEnum 自定义队列枚举，包含交换机的配置信息*/public void createBindingHandle(RabbitAdmin rabbitAdmin, RabbitMqQueueEnum rabbitMqQueueEnum) {// 绑定rabbitAdmin.declareBinding(new Binding(// queue名称rabbitMqQueueEnum.getQueueName(),Binding.DestinationType.QUEUE,// exchange名称rabbitMqQueueEnum.getExchangeName(),// queue的routingKeyrabbitMqQueueEnum.getRoutingKey(),null));}/*** 用于创建延迟队列的交换机*/public static class CustomDelayedExchange extends CustomExchange {public CustomDelayedExchange(String name, boolean durable, boolean autoDelete, String delayedType) {super(name, "x-delayed-message", durable, autoDelete, Collections.singletonMap("x-delayed-type", delayedType));}}
}

交换机枚举配置

/*** @Author itmei*/
@Getter
@AllArgsConstructor
public enum ExchangeConfigEnum {/*** 直接模式*/DIRECT_EXCHANGE(ExchangeModelEnum.DIRECT, true, false),/*** 匹配模式*/TOPIC_EXCHANGE(ExchangeModelEnum.TOPIC, true, false),;/*** 模式*/private final ExchangeModelEnum type;/*** 是否持久化*/private final boolean durable;/*** 是否自动删除*/private final boolean autoDelete;}

交换机枚举类型

/*** @Author itmei*/
@Getter
@AllArgsConstructor
public enum ExchangeModelEnum {/*** 广播*/FANOUT,/*** 匹配*/TOPIC,/*** 直接模式*/DIRECT
}

默认队列配置

/*** @author itmei*/
@Getter
@AllArgsConstructor
public enum QueueConfigEnum {/*** 自定义的队列配置*/DEFAULT_QUEUE_CONFIG(true, false, false, null),;/*** 是否为持久队列(该队列将在服务器重启后保留下来)*/private final boolean durable;/*** 是否为排他队列(该队列仅由声明者的队列使用连接)*/private final boolean exclusive;/*** 如果队列为空是否删除(如果服务器在不再使用队列时是否删除队列)*/private final boolean autoDelete;/*** queue的参数*/private final Map<String, Object> arguments;}

自定义队列配置（以后只需要把队列增加到这里即可）


/*** @author itmei*/
@Getter
@AllArgsConstructor
public enum RabbitMqQueueEnum {/*** 自定义的队列与交换机的关系*/DEFAULT_DIRECT("direct_itmei_exchange","direct.itmei.exchange.default.queue","direct.itmei.exchange.default.queue",ExchangeConfigEnum.DIRECT_EXCHANGE,QueueConfigEnum.DEFAULT_QUEUE_CONFIG,true,"默认队列"),DEFAULT_TEST_DIRECT("direct_itmei_exchange","direct.itmei.exchange.test.queue","direct.itmei.exchange.test.queue",ExchangeConfigEnum.DIRECT_EXCHANGE,QueueConfigEnum.DEFAULT_QUEUE_CONFIG,true,"测试对列"),;/*** 交换机名称*/private final String exchangeName;/*** 队列名称(每个队列的名称应是唯一的)*/private final String queueName ;/*** 默认保持和对列名称一样，模式为 topic时需要注意匹配符设置* 队列路由键(*  注意匹配，#匹配一个或者多个,*匹配一个*      如： abc.new.n , abc.new.n.m*      abc.new.# 匹配{abc.new.n,abc.new.n.m}*      abc.new.* 匹配{abc.new.n}* )*/private final String routingKey;/*** 交换机的配置*/private final ExchangeConfigEnum exchangeConfigEnum;/*** 对列的配置*/private final QueueConfigEnum queueConfigEnum;/*** 是否是延迟交换机 如果已经存在不是延迟交换机则需要删除再标记* treu:延迟交换机 false:普通交换机*/private final boolean delayedExchange;/*** 描述*/private final String desc;public static List<RabbitMqQueueEnum> toList() {return Arrays.asList(RabbitMqQueueEnum.values());}}

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

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

相关文章

面试简要介绍hashMap

面试简要介绍hashMap

jdk8之前&#xff0c;hashmap采用的数据结构是数组链表&#xff0c;jdk8之后采用的数据结构是数组链表/红黑树。hashmap的数据以键值对的形式存在&#xff0c;如果两个元素的hash值相同&#xff0c;就会发生hash冲突&#xff0c;被放到同一个链表上--->如何解决hash冲突---&…
阅读更多...
D50【python 接口自动化学习】- python基础之类

D50【python 接口自动化学习】- python基础之类

day50 init方法 学习日期&#xff1a;20241027 学习目标&#xff1a;类 -- 64 init方法&#xff1a;如何为对象传递参数&#xff1f; 学习笔记&#xff1a; 魔术方法 init方法 class Klass(object):# 定义初始化方法&#xff0c;类实例化时自动进行初始化def __init__(self…
阅读更多...
检索引擎Elasticsearch

检索引擎Elasticsearch

一.为什么要用Elasticsearch 由于我们在运行我们的项目的时候通常都是将数据存到mysql或者sql serve等数据库中&#xff0c;在进行数据搜索时使用sql 语句 like进行模糊匹配查询&#xff0c;其一&#xff1a;虽然可以查到数据&#xff0c;但是它模糊匹配查询速度较慢&#xff0…
阅读更多...
grep,wc和管道符，echo,tail和重定向符，vi编辑器

grep,wc和管道符，echo,tail和重定向符，vi编辑器

学习目标&#xff1a; 1.掌握使用grep命令过滤文件内容 2.掌握使用wc命令统计内容数量 3.掌握|管道符的概念和应用 4.掌握使用echo命令输出内容 5.掌握反引号的使用 6.掌握tail命令跟踪文件更改 7.掌握重定向符号使用 8.掌握使用VI \ VIM编辑器完成文件编辑工作 grep…
阅读更多...
你知道吗？从 .NET9 开始删除内置的 Swagger 支持 （Swashbuckle）！

你知道吗？从 .NET9 开始删除内置的 Swagger 支持 （Swashbuckle）！

.NET 9 中使用 Scalar 替代内置的 Swagger 支持 &#xff08;Swashbuckle&#xff09; 为什么 Swagger &#xff08;Swashbuckle&#xff09; 被删除&#xff1f;Swagger 的替代方案&#xff1a;Scalar&#xff08;Scalar.AspNetCore&#xff09;如何在 Dotnet 9 中使用它?如何…
阅读更多...
Python4

Python4

4. 更多控制流工具 除了刚介绍的 while 语句&#xff0c;Python 还用了一些别的。我们将在本章中遇到它们。 4.1. if 语句 if elif else if x<0: x 0 print(Negative changed to zero) elif x0: print( zero) else: print(More) 4.2. for 语句 Pyth…
阅读更多...
【大模型理论篇】大模型压缩技术之注意力层剪枝以及与MLP层联合剪枝

【大模型理论篇】大模型压缩技术之注意力层剪枝以及与MLP层联合剪枝

1. 背景分析 本来打算写一篇关于大模型蒸馏的文章&#xff0c;但刚好看到近期发表的一篇讨论大模型压缩的文章【1】&#xff0c;是关于注意力机制冗余性的讨论&#xff0c;比较有意思&#xff0c;作者分析得出并不是所有的注意力都是必须的&#xff0c;可以通过对模型去除冗余的…
阅读更多...
引爆品牌曝光：揭秘Facebook品牌知名度广告的成功秘诀

引爆品牌曝光：揭秘Facebook品牌知名度广告的成功秘诀

来源&#xff1a;CREATING SUCCESSFUL FACEBOOK BRAND AWARENESS 本文主要介绍如何创建成功的Facebook品牌知名度广告活动。 创建成功的Facebook品牌知名度广告活动 在当今以Facebook为驱动的社交媒体管理中&#xff0c;品牌需要通过以下共同因素来构建品牌知名度&#xff1a;…
阅读更多...
【音视频 | ADPCM】音频编码ADPCM详细介绍及例子

【音视频 | ADPCM】音频编码ADPCM详细介绍及例子

&#x1f601;博客主页&#x1f601;&#xff1a;&#x1f680;https://blog.csdn.net/wkd_007&#x1f680; &#x1f911;博客内容&#x1f911;&#xff1a;&#x1f36d;嵌入式开发、Linux、C语言、C、数据结构、音视频&#x1f36d; &#x1f923;本文内容&#x1f923;&a…
阅读更多...
《深入浅出HTTPS​​》读书笔记（2）：HTTP

《深入浅出HTTPS​​》读书笔记（2）：HTTP

HTTP目前的版本是HTTP/1.1&#xff0c;定义在RFC 2616规范上。 HTTP的模型很简单&#xff0c;是一个B/S模型&#xff0c;由客户端和服务器组成&#xff0c;交互流程很简单。 ◎一个HTTP客户端发送请求至HTTP服务器&#xff0c;然后等待服务器的响应。 ◎一个HTTP服务器负责监…
阅读更多...
【ArcGIS Pro实操第5期】全局及局部空间插值：GPI、LPI、IDW等

【ArcGIS Pro实操第5期】全局及局部空间插值：GPI、LPI、IDW等

ArcGIS Pro实操第5期&#xff1a;全局及局部空间插值 ArcGIS Pro-用于空间插值的丰富工具箱实操&#xff1a;空间插值方法1&#xff1a;Trend Surface Model for Interpolation-以降水数据为例方法2&#xff1a;Kernel Density Estimation Method-以单位面积鹿的目击数为例方法…
阅读更多...
Lodash.js处理数组、对象、函数等常用方法介绍

Lodash.js处理数组、对象、函数等常用方法介绍

参考网址&#xff1a;Lodash 简介 | Lodash中文文档 | Lodash中文网 安装 npm install lodash 引入 const _ require(lodash) 使用 基础数据 const array1 [{ id: 1, value: A }, { id: 2, value: B }] const array2 [{ id: 2, value: B }, { id: 3, value: C }] 交集…
阅读更多...
spring-第十一章 注解开发

spring-第十一章 注解开发

spring 文章目录 spring前言1.注解回顾1.1原理1.2springIOC注解扫描原理1.2.1解释1.2.2案例 2.声明bean的注解补充&#xff1a;Bean注解&#xff0c;管理三方包对象 3.spring注解的使用3.1加入aop依赖3.2配置文件中添加context命名空间3.3配置文件中指定要扫描的包3.4在Bean上使…
阅读更多...
golang中的goroutine

golang中的goroutine

1.golang中的主线程&#xff1a;&#xff08;可以理解为线程/也可以理解为进程&#xff09;&#xff0c;在一个Golang程序的主线程上可以起多个协程。Golang中多协程可以实现并行或者并发。 1.1 goroutine 协程&#xff1a;可以理解为用户级线程&#xff0c;这是对内核透明的&…
阅读更多...
CSS 入门：美化网页的魔法

CSS 入门：美化网页的魔法

CSS&#xff08;层叠样式表&#xff09;是一种用于描述网页文档样式的标记语言。它可以控制网页的布局、字体、颜色、大小、背景等外观效果。CSS可以与HTML结合使用&#xff0c;通过选择器来选择HTML元素&#xff0c;并为其应用样式。 CSS的基本语法由选择器和声明块组成。选择…
阅读更多...
2024_SHCTF_week2_Crypto

2024_SHCTF_week2_Crypto

pading 题目&#xff1a; from Crypto.Util.number import * import gmpy2 flag bSHCTF{********} assert len(flag) 39 p getPrime(512) q getPrime(512) n p * q e 0x3 pad ba_easy_problem c pow(bytes_to_long(flag pad),e,n) print(fn {n}) print(fc {c})思路…
阅读更多...
C语言数据结构学习：[汇总]

C语言数据结构学习：[汇总]

介绍 这些是我在学习C语言数据结构时练习的一些题目以及个人笔记 大家也可以参考着来学习 正在更新 大家可以在我的gitee仓库 中下载笔记源文件 笔记源文件可以在Notion中导入 内容导航 C语言数据结构学习&#xff1a;单链表-CSDN博客
阅读更多...
Python中的递归函数是如何工作的，它有哪些应用场景？

Python中的递归函数是如何工作的，它有哪些应用场景？

1、Python中的递归函数是如何工作的&#xff0c;它有哪些应用场景&#xff1f; Python中的递归函数是一种特殊类型的函数&#xff0c;它能够调用自己来解决问题。递归函数的应用非常广泛&#xff0c;可以解决很多不同类型的问题&#xff0c;比如计算阶乘、生成斐波那契数列、字…
阅读更多...
webpack5搭建react脚手架详细步骤

webpack5搭建react脚手架详细步骤

1. 初始化项目 首先&#xff0c;创建一个新目录并初始化项目&#xff1a; bash mkdir create-react cd create-react pnpm init --y git init 这里使用pnpm作为包管理工具&#xff0c;因为它在处理依赖和速度上表现更好。 2. 安装React和TypeScript 安装React和React-DOM…
阅读更多...
视频编辑的创意工坊，使用视频剪辑软件将视频随机分割成两段并去声进行MP3音频和M3u8文件的生成，让视频制作更高效

视频编辑的创意工坊，使用视频剪辑软件将视频随机分割成两段并去声进行MP3音频和M3u8文件的生成，让视频制作更高效

面对海量的视频编辑任务&#xff0c;你是否曾感到手足无措&#xff0c;渴望一种既简单又高效的方式来处理它们&#xff1f;别担心&#xff0c;媒体梦工厂软件带着它的魔法棒来啦&#xff01;它就像一位技艺高超的视频巫师&#xff0c;能轻松帮你在线完成视频编辑任务&#xff0…
阅读更多...
最新文章

Copyright @ 2022~2023