SpringBoot实现RabbitMQ的定向交换机(SpringAMQP 实现Direct定向交换机)

本文主要是介绍SpringBoot实现RabbitMQ的定向交换机(SpringAMQP 实现Direct定向交换机),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!


文章目录

  • Direct 交换机特点
  • 实战
    • 声明交换及其队列(以注解方式)
    • 发消息
  • 应用


在这里插入图片描述

上一篇文章中的 Fanout 模式,一条消息,会被所有订阅其交换机的队列都消费。

但是,在某些场景下,我们希望不同的消息被不同的队列消费。这时就要用到 Direct类型的交换机。

Direct 交换机特点

在Direct模型下:

  • 队列与交换机的绑定,不能是任意绑定了,而是要指定一个RoutingKey(路由key)
  • 消息的发送方在 向 Exchange发送消息时,也必须指定消息的 RoutingKey
  • Exchange不再把消息交给每一个绑定的队列,而是根据消息的Routing Key进行判断,只有队列的Routingkey与消息的 Routing key完全一致,才会接收到消息

实战

我们定义一个定向交换机( Direct Exchange )
再定义两个队列,让这两个队列绑定到该交换机上,并且按照如下图 key 的规则绑定.

在这里插入图片描述

声明交换及其队列(以注解方式)

上篇文章是按照基于@Bean的方式声明队列和交换机比较麻烦,Spring还提供了基于注解方式来声明。

consumerSpringRabbitListener 中添加两个消费者,同时基于注解来声明队列和交换机:

 /** 基于注解的来声明交换机和队列及其绑定关系 */
@RabbitListener( bindings = @QueueBinding(exchange = @Exchange(name = "test2024.direct", type = ExchangeTypes.DIRECT),value = @Queue(name = "test2024.direct.redOrBlueOrYellow"),key = {"red", "yellow", "blue"}
))
public void rabbitListener5(String message) {System.out.println("红黄蓝: " + message);
}@RabbitListener( bindings = @QueueBinding(exchange = @Exchange(name = "test2024.direct", type = ExchangeTypes.DIRECT),value = @Queue(name = "test2024.direct.WhiteOrBlack"),key = {"white", "black"}
))
public void rabbitListener6(String message) {System.out.println("黑白: " + message);
}
/** 基于注解的来声明交换机和队列及其绑定关系 */

启动上面的服务后 我们发现指定的交换机和队列都创建好了

在这里插入图片描述


发消息

//  测试定向交换机
@Test
public void test03() throws InterruptedException {String exchangeName = "test2024.direct";String[] keyArray = {"red", "yellow", "blue", "black", "white"};String message = "this is a message from direct! key: ";for (int i = 0; i < 50; i++) {int index = new Random().nextInt(keyArray.length);rabbitTemplate.convertAndSend(exchangeName, keyArray[index], message + keyArray[index]);}Thread.sleep(500);
}

在这里插入图片描述


看到数据都规规整整的进入指定的key对应的队列,并被消费.


应用

Direct 交换机适用于一对一的消息传递模式,它通过消息的路由键(Routing Key)将消息发送到与之完全匹配的队列中。因此,Direct交换机常用于以下情况:

  • 点对点通信:当系统中存在一对一的通信需求时,可以使用Direct交换机来确保消息被准确地路由到目标队列。例如,订单系统中将订单消息发送到指定的订单处理队列。

  • 任务分发:在分布式系统中,可以使用Direct交换机来将任务分发到不同的工作节点。每个工作节点都可以绑定一个特定的队列,根据任务的类型或者其他属性,将任务发送到相应的队列中。

  • 系统内部通知:当系统需要向特定的用户或者部门发送通知消息时,可以使用Direct交换机来确保消息仅发送给目标接收者,而不会广播给所有用户。

  • 错误处理:在系统中可能会发生错误,需要将错误消息发送到指定的队列中进行处理。Direct交换机可以将错误消息准确地路由到错误处理队列,方便进行后续的排查和处理。

Direct交换机适用于需要精确路由消息到指定队列的场景,是一种简单而高效的消息传递方式。



在这里插入图片描述



这篇关于SpringBoot实现RabbitMQ的定向交换机(SpringAMQP 实现Direct定向交换机)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/860866

相关文章

Java的栈与队列实现代码解析

《Java的栈与队列实现代码解析》栈是常见的线性数据结构,栈的特点是以先进后出的形式,后进先出,先进后出,分为栈底和栈顶,栈应用于内存的分配,表达式求值,存储临时的数据和方法的调用等,本文给大家介绍J... 目录栈的概念(Stack)栈的实现代码队列(Queue)模拟实现队列(双链表实现)循环队列(循环数组

C++如何通过Qt反射机制实现数据类序列化

《C++如何通过Qt反射机制实现数据类序列化》在C++工程中经常需要使用数据类,并对数据类进行存储、打印、调试等操作,所以本文就来聊聊C++如何通过Qt反射机制实现数据类序列化吧... 目录设计预期设计思路代码实现使用方法在 C++ 工程中经常需要使用数据类,并对数据类进行存储、打印、调试等操作。由于数据类

Python实现图片分割的多种方法总结

《Python实现图片分割的多种方法总结》图片分割是图像处理中的一个重要任务,它的目标是将图像划分为多个区域或者对象,本文为大家整理了一些常用的分割方法,大家可以根据需求自行选择... 目录1. 基于传统图像处理的分割方法(1) 使用固定阈值分割图片(2) 自适应阈值分割(3) 使用图像边缘检测分割(4)

Android实现在线预览office文档的示例详解

《Android实现在线预览office文档的示例详解》在移动端展示在线Office文档(如Word、Excel、PPT)是一项常见需求,这篇文章为大家重点介绍了两种方案的实现方法,希望对大家有一定的... 目录一、项目概述二、相关技术知识三、实现思路3.1 方案一:WebView + Office Onl

Java中Switch Case多个条件处理方法举例

《Java中SwitchCase多个条件处理方法举例》Java中switch语句用于根据变量值执行不同代码块,适用于多个条件的处理,:本文主要介绍Java中SwitchCase多个条件处理的相... 目录前言基本语法处理多个条件示例1:合并相同代码的多个case示例2:通过字符串合并多个case进阶用法使用

Java中的Lambda表达式及其应用小结

《Java中的Lambda表达式及其应用小结》Java中的Lambda表达式是一项极具创新性的特性,它使得Java代码更加简洁和高效,尤其是在集合操作和并行处理方面,:本文主要介绍Java中的La... 目录前言1. 什么是Lambda表达式?2. Lambda表达式的基本语法例子1:最简单的Lambda表

Java中Scanner的用法示例小结

《Java中Scanner的用法示例小结》有时候我们在编写代码的时候可能会使用输入和输出,那Java也有自己的输入和输出,今天我们来探究一下,对JavaScanner用法相关知识感兴趣的朋友一起看看吧... 目录前言一 输出二 输入Scanner的使用多组输入三 综合练习:猜数字游戏猜数字前言有时候我们在

C# foreach 循环中获取索引的实现方式

《C#foreach循环中获取索引的实现方式》:本文主要介绍C#foreach循环中获取索引的实现方式,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录一、手动维护索引变量二、LINQ Select + 元组解构三、扩展方法封装索引四、使用 for 循环替代

Spring Security+JWT如何实现前后端分离权限控制

《SpringSecurity+JWT如何实现前后端分离权限控制》本篇将手把手教你用SpringSecurity+JWT搭建一套完整的登录认证与权限控制体系,具有很好的参考价值,希望对大家... 目录Spring Security+JWT实现前后端分离权限控制实战一、为什么要用 JWT?二、JWT 基本结构

java解析jwt中的payload的用法

《java解析jwt中的payload的用法》:本文主要介绍java解析jwt中的payload的用法,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录Java解析jwt中的payload1. 使用 jjwt 库步骤 1:添加依赖步骤 2:解析 JWT2. 使用 N