RabbitMQ交换机(2)-Direct

1.Direct

直连(路由)交换机,生产者将消息发送到交换机,并指定消息的Routing Key(路由键)。交换机会将Routing Key与队列绑定进行匹配,如果匹配成功,则将该消息路由到对应的队列中。如果没有匹配成功,该消息将被丢弃或返回给生产者。在Direct模式中,每个消息只能被一个消费者接收。
通过使用Exchange和Routing Key来进行消息传输,Direct模式实现了消息的有选择性地路由,提高了消息传输的效率,减少了系统负载.
在这里插入图片描述
在这里插入图片描述
如上图中的routingKey为error绑定队列disk,routingKey为info或warning绑定队列console。

2.生产者

package com.hong.rabbitmq7;import com.hong.utils.RabbitMQUtil;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.Channel;import java.nio.charset.StandardCharsets;
import java.util.HashMap;
import java.util.Map;
import java.util.Scanner;/*** @Description: 直连模式消息发送者* @Author: hong* @Date: 2024-01-15 22:24* @Version: 1.0**/
public class DirectSend {public static final String EXCHANGE_NAME = "direct_logs";public static void main(String[] args) throws Exception {Channel channel = RabbitMQUtil.getChannel();channel.exchangeDeclare(EXCHANGE_NAME, BuiltinExchangeType.DIRECT);Map<String,String> map = new HashMap<>();map.put("info","我是info信息");map.put("debug","我是debug信息");map.put("warning","我是warning信息");map.put("error","我是error信息");for(Map.Entry<String,String> bindingKeys : map.entrySet()){String bindingKey = bindingKeys.getKey();String message = bindingKeys.getValue();channel.basicPublish(EXCHANGE_NAME,bindingKey,null,message.getBytes(StandardCharsets.UTF_8));System.out.println("消息发送完成------" + message);}}
}

在这里插入图片描述

3.消费者1-disk只接受error消息

package com.hong.rabbitmq7;import com.hong.utils.RabbitMQUtil;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.CancelCallback;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.DeliverCallback;import java.nio.charset.StandardCharsets;/*** @Description: 直连模式消息接收者1-disk接收error消息* @Author: hong* @Date: 2024-01-15 20:22* @Version: 1.0**/
public class Receiver1 {public static final String EXCHANGE_NAME = "direct_logs";public static void main(String[] args) throws Exception {Channel channel = RabbitMQUtil.getChannel();/**声明交换机*第1个参数:交换机名称*第2个参数:交换机类型*/channel.exchangeDeclare(EXCHANGE_NAME, BuiltinExchangeType.DIRECT);//声明队列String queueName = "disk";channel.queueDeclare(queueName,false,false,false,null);/** 绑定队列与交换机* 第1个参数:队列名称* 第2个参数:交换机名称* 第3个参数:routingKey*/channel.queueBind(queueName,EXCHANGE_NAME,"error");DeliverCallback deliverCallback = (comsumerTag, message) -> {System.out.println("disk中的:"+  new String(message.getBody(), StandardCharsets.UTF_8));};CancelCallback cancelCallback = var -> {};channel.basicConsume(queueName,true,deliverCallback,cancelCallback);}
}

在这里插入图片描述

4.消费2-console接收info和warning消息

package com.hong.rabbitmq7;import com.hong.utils.RabbitMQUtil;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.CancelCallback;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.DeliverCallback;import java.nio.charset.StandardCharsets;/*** @Description: 直连模式消息接收者2-console接收info和warning消息* @Author: hong* @Date: 2024-01-15 20:22* @Version: 1.0**/
public class Receiver2 {public static final String EXCHANGE_NAME = "direct_logs";public static void main(String[] args) throws Exception {Channel channel = RabbitMQUtil.getChannel();/**声明交换机*第1个参数:交换机名称*第2个参数:交换机类型*/channel.exchangeDeclare(EXCHANGE_NAME, BuiltinExchangeType.DIRECT);//声明队列String queueName = "console";channel.queueDeclare(queueName,false,false,false,null);/** 绑定队列与交换机* 第1个参数:队列名称* 第2个参数:交换机名称* 第3个参数:routingKey*/channel.queueBind(queueName,EXCHANGE_NAME,"info");channel.queueBind(queueName,EXCHANGE_NAME,"warning");DeliverCallback deliverCallback = (comsumerTag, message) -> {System.out.println("console中的:"+  new String(message.getBody(), StandardCharsets.UTF_8));};CancelCallback cancelCallback = var -> {};channel.basicConsume(queueName,true,deliverCallback,cancelCallback);}
}

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

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

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

相关文章

Python不同数据对象的空值校验

更多Python学习内容&#xff1a;ipengtao.com 空值校验在数据处理和应用程序开发中是一个非常重要的任务。Python提供了多种方式来检查不同数据对象&#xff08;如字符串、列表、字典、集合等&#xff09;是否为空或包含空值。本文将详细介绍Python中对不同数据对象进行空值校验…

患者需要定期复查吗?

发作性睡病是一种慢性睡眠障碍性疾病&#xff0c;需要长期治疗和管理。因此&#xff0c;患者需要定期进行复查&#xff0c;以便医生了解患者的病情变化和治疗效果&#xff0c;及时调整治疗方案。 定期复查可以帮助医生评估患者的睡眠状况、猝倒等症状的改善情况&#xff0c;以…

Android 捕获native异常

11.使用google官方提供的breakpad 地址&#xff1a;Android 捕获native异常 https://github.com/google/breakpad 2.编译breakpad的so文件 2.1设置需要编译的架构 3.编译完&#xff0c;在build\intermediates\cmake\debug\obj目录下获取对应架构的so包 4.编译一个错误的so包…

3.3.3 使用集线器的星形拓扑

3.3.3 使用集线器的星形拓扑 集线器的一些特点 3.3.4 以太网的信道利用率 多个站在以太网上同时工作就可能会发生碰撞当发生碰撞时&#xff0c;信道资源实际上是被浪费了。因此&#xff0c;当扣除碰撞所造成的信道损失后&#xff0c;以太网总的信道利用率并不能达到100% 3.…

企业在数据中台上该怎么选择

随着数字化时代的到来&#xff0c;数据已经成为企业的核心资产之一。而数据中台作为数据管理和利用的核心平台&#xff0c;对于企业的发展起着至关重要的作用。然而&#xff0c;面对市场上琳琅满目的数据中台解决方案&#xff0c;企业应该如何选择合适的方案呢&#xff1f;下面…

创意交融:集成自定义报表和仪表盘设计器,实现图标替换

前言 在现代数据分析领域&#xff0c;随着对报表和数据分析的需求不断增长&#xff0c;市场上涌现了许多嵌入式报表工具。这些工具能够与企业现有的OA、ERP、MES、CRM等应用系统深度集成&#xff0c;实现对业务数据的自助式分析。然而&#xff0c;在实际应用中&#xff0c;不同…

在java中为什么重写equals要重写hashcode

为什么重写equals要重写hashcode 在Java中&#xff0c;当我们重写equals方法时&#xff0c;通常也需要重写hashCode方法。这是因为&#xff1a; 一致性&#xff1a;如果两个对象相等&#xff08;即equals方法返回true&#xff09;&#xff0c;那么它们的哈希码&#xff08;has…

PyQt5 QFileDialog 详解

PyQt5 QFileDialog 详解 QFileDialog 是 PyQt5 中用于显示文件和文件夹选择对话框的类。它提供了一种方便的方式&#xff0c;让用户在应用程序中选择文件、文件夹或多个文件。QFileDialog 类位于 QtWidgets 模块中。 下面是关于 QFileDialog 的一些详解&#xff1a; 创建和显…

发作性睡病是否会遗传给下一代?

发作性睡病是一种慢性睡眠障碍性疾病&#xff0c;具有一定的遗传性&#xff0c;因此有可能会遗传给下一代。 研究表明&#xff0c;发作性睡病与遗传因素密切相关&#xff0c;大约有60%的患者有家族遗传史。也就是说&#xff0c;如果父母双方或一方患有发作性睡病&#xff0c;子…

招生官怒批ChatGPT文书质量“缺少灵魂”

ChatGPT无疑是最近两年留学届的热门话题&#xff0c;也成为了不少留学生再也离不开的万能工具&#xff0c;从总结文献、润色论文、给教授写email似乎无所不能。甚至还有不少同学在考虑直接提交ChatGPT生成的文书。 那么ChatGPT生成的文书质量高吗&#xff1f;各大高校对于学生…

Oracle AWR报告的生成和解读

Oracle AWR报告的生成和解读 一、AWR报告概念及原理 Oracle10g以后&#xff0c;Oracle提供了一个性能检测的工具&#xff1a;AWR&#xff08;Automatic Workload Repository 自动工作负载库&#xff09;这个工具可以自动采集Oracle运行中的负载信息&#xff0c;并生成与性能相…

C# 消息队列、多线程、回滚、并行编程、异步编程、反射

消息队列 消息队列是一种在应用程序之间传递消息的异步通信机制。它可以使应用程序解耦并提高系统的可伸缩性和可靠性。在 C# 中&#xff0c;你可以使用多个消息队列技术&#xff0c;其中一种广泛使用的技术是 RabbitMQ。 RabbitMQ 是一个开源的消息代理&#xff0c;实现了高…

Vue中的全局组件与局部组件

聚沙成塔每天进步一点点 本文内容 ⭐ 专栏简介1. 全局组件的原理2. 局部组件的原理3. 组件注册的影响与考虑因素全局组件的使用场景&#xff1a;局部组件的使用场景&#xff1a; 4. 组合使用全局组件与局部组件 ⭐ 写在最后 ⭐ 专栏简介 Vue学习之旅的奇妙世界 欢迎大家来到 Vu…

个人网站制作 Part 6 添加高级特性(页面动画、服务端集成) | Web开发项目

文章目录 &#x1f469;‍&#x1f4bb; 基础Web开发练手项目系列&#xff1a;个人网站制作&#x1f680; 添加页面动画&#x1f528;使用CSS动画&#x1f527;步骤 1: 添加动画效果 &#x1f528;使用JavaScript实现动画&#x1f527;步骤 2: 使用JavaScript添加动画 &#x1…

笔记本电脑如何连接显示屏?

目录 1.按下快捷键 winP,选择扩展 2.连接显示器&#xff0c;连好接线 3.笔记本驱动有问题&#xff0c;显示错误如下&#xff1a; 4.驱动已经下载完成&#xff0c; 按下快捷键&#xff0c;还是显示第3步中的错误 5.驱动已经下载完成&#xff0c; 按下快捷键&#xff0c;参照…

步进电机基本原理详解

步进电机基本原理 步进电机是一种将电脉冲信号转换成相应角位移或线位移的电动机。 区别于以电压或电流作为控制信号&#xff0c;被控制量是转速的电动机。 每输入一个脉冲信号&#xff0c;转子就转动一个角度或前进一步&#xff0c;其输出的角位移或线位移与输入的脉冲数成正…

C++(9.5)——浅谈new和delete的实现原理

(注:本文是针对上篇文章中C内存管理的两个关键字)两个关键字原理的解析&#xff0c;对于这两个关键字的使用并没有什么影响&#xff0c;如果只想得知两个关键字的使用方法&#xff0c;则可以直接跳过本篇文章&#xff09; 目录 1. 引入&#xff1a; 2.operator new 与 operat…

实战 php 使用 wkhtmltopdf 生成pdf的全过程

公司里边有生成pdf报告的业务需求,之前有过尝试用tcpdf,直接生成的pdf的过程,但是pdf报告的内容数据,根据不同内容的变化,都是各种各样的bug,一直处理修修补补的状态,让后台开发人员很是头疼. 经过思索和甄选,总结出我们的业务中是由于样式不可控导致的,当时从逻辑上就思考到用…

医院如何选择高效的内外网数据交换方案 替代U盘进行跨网传输?

医院信息网络是所有网络中安全性要求较高的网络之一&#xff0c;因此很多医院基于信息安全相关要求&#xff0c;会使用防火墙将网络隔离成内网和外网。内网用于日常医疗信息交换&#xff0c;外网可以及时获取Internet信息资源。但是网络隔离后&#xff0c;医院仍存在将报告资料…

原子类-数组类型原子类

数组类型原子类 AtomicIntegerArray:整型数组原子类 AtomicLongrArray:长整型数组原子类 AtomicReferenceArray:用类型数组原子类 常用API简介 数组类型原子类常用API简介 public final int get(int i) //获取 index=i 位置元素的值 public final int getAndSet(int i, in…