02、交换机

news2024/12/24 2:24:18

目录

1.、Exchange(交换机)的作用

 2、Exchange(交换机)的类型

2.1.直连交换机：Direct Exchange

2.2.主题交换机：Topic Exchange

2.3.扇形交换机：Fanout Exchange

2.4.首部交换机：Headers exchange

2.5.默认交换机

2.6.Dead Letter Exchange（死信交换机）

3、交换机的属性

4、综合案例：交换机的使用

给子模块添加依赖

4.1.直连交换机(Direct Exchange)

4.2.主题交换机(Topic Exchange)

4.3.扇形交换机(Fanout Exchange)

以上就是今天的分享了

1.、Exchange(交换机)的作用

在RabbitMQ中，生产者发送消息不会直接将消息投递到队列中，而是先将消息投递到交换机中，在由交换机转发到具体的队列，队列再将消息以推送或者拉取方式给消费者进行消费

                        创建消息                               路由键                                         pull/push

生产者------------------------------->交换机--------------------------------->队列--------------------------->消费者

 2、Exchange(交换机)的类型

2.1.直连交换机：Direct Exchange

直连交换机是一种带路由功能的交换机，一个队列会和一个交换机绑定，除此之外再绑定一个routing_key，当消息被发送的时候，需要指定一个binding_key，这个消息被送达交换机的时候，就会被这个交换机送到指定的队列里面去。同样的一个binding_key也是支持应用到多个队列中的。这样当一个交换机绑定多个队列，就会被送到对应的队列去处理。

注1：什么是路由键 
          每个消息都有一个称为路由键(routing key)的属性，它其实就是一个简单的字符串

注2：直连交换机适用场景
          有优先级的任务，根据任务的优先级把消息发送到对应的队列，这样可以指派更多的资源去处理高优先级的队列。

2.2.主题交换机：Topic Exchange

直连交换机的缺点！
     直连交换机的routing_key方案非常简单，如果我们希望一条消息发送给多个队列，那么这个交换机需要绑定上非常多的routing_key，
     假设每个交换机上都绑定一堆的routing_key连接到各个队列上。那么消息的管理就会异常地困难。所以RabbitMQ提供了一种主题交换机，发送到主题交换机上的消息需要携带指定规则的routing_key，
     主题交换机会根据这个规则将数据发送到对应的(多个)队列上。

     主题交换机的routing_key需要有一定的规则，交换机和队列的binding_key需要采用*.#.*.....的格式，每个部分用.分开，其中
     *表示一个单词 
     #表示任意数量（零个或多个）单词。

示例：
     队列Q1绑定键为 *.TT.*
     队列Q2绑定键为TT.#

     如果一条消息携带的路由键为 A.TT.B，那么队列Q1将会收到 
     如果一条消息携带的路由键为TT.AA.BB，那么队列Q2将会收到

2.3.扇形交换机：Fanout Exchange

扇形交换机是最基本的交换机类型，它所能做的事情非常简单———广播消息。
扇形交换机会把能接收到的消息全部发送给绑定在自己身上的队列。因为广播不需要“思考”，所以扇形交换机处理消息的速度也是所有的交换机类型里面最快的。 

这个交换机没有路由键概念，就算你绑了路由键也是无视的。 

2.4.首部交换机：Headers exchange

2.5.默认交换机

   实际上是一个由RabbitMQ预先声明好的名字为空字符串的直连交换机（direct exchange）。它有一个特殊的属性使得它对于简单应用特别有用处：那就是每个新建队列（queue）都会自动绑定到默认交换机上，绑定的路由键（routing key）名称与队列名称相同。

     如：当你声明了一个名为”hello”的队列，RabbitMQ会自动将其绑定到默认交换机上，绑定（binding）的路由键名称也是为”hello”。
     因此，当携带着名为”hello”的路由键的消息被发送到默认交换机的时候，此消息会被默认交换机路由至名为”hello”的队列中

类似amq.*的名称的交换机：
     这些是RabbitMQ默认创建的交换机。这些队列名称被预留做RabbitMQ内部使用，不能被应用使用，否则抛出403 (ACCESS_REFUSED)错误 

2.6.Dead Letter Exchange（死信交换机）

在默认情况，如果消息在投递到交换机时，交换机发现此消息没有匹配的队列，则这个消息将被悄悄丢弃。
为了解决这个问题，RabbitMQ中有一种交换机叫死信交换机。当消费者不能处理接收到的消息时，将这个消息重新发布到另外一个队列中，等待重试或者人工干预。这个过程中的exchange和queue就是所谓的”Dead Letter Exchange 和 Queue

3、交换机的属性

 除交换机类型外，在声明交换机时还可以附带许多其他的属性，其中最重要的几个分别是：
   Name：交换机名称
   Durability：是否持久化。如果持久性，则RabbitMQ重启后，交换机还存在
   Auto-delete：当所有与之绑定的消息队列都完成了对此交换机的使用后，删掉它
   Arguments：扩展参数

4、综合案例：交换机的使用

     rabbitmq02                     #主模块    maven
     rabbitmq-provider            #生产者   springboot
     rabbitmq-consumer            #消费者   springboot

 

 

给子模块添加依赖

<dependency>
       <groupId>org.springframework.boot</groupId>
       <artifactId>spring-boot-starter-amqp</artifactId>
     </dependency>
     <dependency>
       <groupId>org.springframework.boot</groupId>
       <artifactId>spring-boot-starter-web</artifactId>
     </dependency>
     <dependency>
       <groupId>org.projectlombok</groupId>
       <artifactId>lombok</artifactId>
       <optional>true</optional>
     </dependency>

4.1.直连交换机(Direct Exchange)

1.RabbitmqDirectConfig
2.SendMessageController
         关键代码：rabbitTemplate.convertAndSend("testDirectExchange", "testDirectRouting", map);
                   sendDirectMessage：进行消息推送（也可以改为定时任务，具体看需求）
         
3.查看rabbitmq管理界面
       我们目前还创建消费者rabbitmq-consumer，消息没有被消费的，我们去rabbitMq管理页面看看，是否推送成功 
       Overview选项卡，可以查看到刚刚创建的消息
4.创建消息接收监听类DirectReceiver

注1：新版jdk日期及格式化
          LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));

注2：rabbitTemplate和amqpTemplate有什么关系
          查看源码中会发现rabbitTemplate实现自amqpTemplate接口，两者使用起来并无区别，功能一致

注3：不要@Configuration写成了@Configurable，这两个长得很像
          @Configuration该注解是可以用来替代XML文件。
          手动new出来的对象，正常情况下，Spring是无法依赖注入的，这个时候可以使用        

          @Configurable注解

  

 生产者

package com.zking.rabbitmqproduct.config;

import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.DirectExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * 直连交换机
 */
@Configuration
public class RabbitmqDirectConfig {
    /**
     * 定义队列
     * @return
     */
    @Bean
    public Queue directQueue(){
        return new Queue("direct-queue");
    }

    /**
     * 自定义直连交换机
     * @return
     */
    @Bean
    public DirectExchange directExchange(){
        return new DirectExchange("direct-exchange",true,false);
    }

    /**
     * 将队列与交换机进行绑定，并设置路由键
     * @return
     */
    @Bean
    public Binding binding(){
        return BindingBuilder.bind(directQueue())
                .to(directExchange())
                .with("direct_routing_key");
    }

}

消费者

package com.zking.rabbitmqconsumer.receiver;

import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

import java.util.Map;

@Component
@RabbitListener(queues = {"direct-queue"})
public class DirectReceiver {

    @RabbitHandler
    public void handler(Map<String,Object> json){
        System.out.println(json);
    }
}

4.2.主题交换机(Topic Exchange)

RabbitTopicConfig

生产者

package com.zking.rabbitmqproduct.config;

import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.core.TopicExchange;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitmqTopicConfig {

    @Bean
    public Queue queueA(){
        return new Queue("queue-a");
    }

    @Bean
    public Queue queueB(){
        return new Queue("queue-b");
    }

    @Bean
    public Queue queueC(){
        return new Queue("queue-c");
    }

    /**
     * 定义主题交换机
     * @return
     */
    @Bean
    public TopicExchange topicExchange(){
        return new TopicExchange("topic-exchange",true,false);
    }

    @Bean
    public Binding bindingA(){
        return BindingBuilder.bind(queueA())
                .to(topicExchange())
                .with("topic.person.aa");
    }

    @Bean
    public Binding bindingB(){
        return BindingBuilder.bind(queueB())
                .to(topicExchange())
                .with("topic.person.bb");
    }

    @Bean
    public Binding bindingC(){
        return BindingBuilder.bind(queueC())
                .to(topicExchange())
                .with("topic.person.*");
    }
}

消费者 

package com.zking.rabbitmqconsumer.receiver;

import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

import java.util.Map;

@Component
public class TopicReceiver {

    @RabbitListener(queues = {"queue-a"})
    @RabbitHandler
    public void handlerA(Map<String,Object> json){
        System.out.println("已接受到队列queue-a传递过来的消息："+json);
    }

    @RabbitListener(queues = {"queue-b"})
    @RabbitHandler
    public void handlerB(Map<String,Object> json){
        System.out.println("已接受到队列queue-b传递过来的消息："+json);
    }

    @RabbitListener(queues = {"queue-c"})
    @RabbitHandler
    public void handlerC(Map<String,Object> json){
        System.out.println("已接受到队列queue-c传递过来的消息："+json);
    }
}

4.3.扇形交换机(Fanout Exchange)

//因为是扇型交换机, 路由键无需配置,配置也不起作用，两处地方均未配置路由键
     BindingBuilder.bind(queueA()).to(fanoutExchange()); 
     rabbitTemplate.convertAndSend(RabbitFanoutConfig.EXCHANGE_NAME,null, map);

生产者

package com.zking.rabbitmqproduct.config;

import org.springframework.amqp.core.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitmqFanoutConfig {

    @Bean
    public Queue queueX(){
        return new Queue("queue-x");
    }

    @Bean
    public Queue queueY(){
        return new Queue("queue-y");
    }

    @Bean
    public Queue queueZ(){
        return new Queue("queue-z");
    }

    /**
     * 定义扇形交换机，与路由键无关
     * @return
     */
    @Bean
    public FanoutExchange fanoutExchange(){
        return new FanoutExchange("fanout-exchange",true,false);
    }

    @Bean
    public Binding bindingX(){
        return BindingBuilder.bind(queueX())
                .to(fanoutExchange());
    }

    @Bean
    public Binding bindingY(){
        return BindingBuilder.bind(queueY())
                .to(fanoutExchange());
    }

    @Bean
    public Binding bindingZ(){
        return BindingBuilder.bind(queueZ())
                .to(fanoutExchange());
    }
}

消费者

package com.zking.rabbitmqconsumer.receiver;

import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

import java.util.Map;

@Component
public class FanoutReceiver {

    @RabbitListener(queues = {"queue-x"})
    @RabbitHandler
    public void handlerY(Map<String,Object> json){
        System.out.println("已接受到队列queue-x传递过来的消息："+json);
    }

    @RabbitListener(queues = {"queue-y"})
    @RabbitHandler
    public void handlerX(Map<String,Object> json){
        System.out.println("已接受到队列queue-y传递过来的消息："+json);
    }

    @RabbitListener(queues = {"queue-z"})
    @RabbitHandler
    public void handlerZ(Map<String,Object> json){
        System.out.println("已接受到队列queue-z传递过来的消息："+json);
    }
}

以上就是今天的分享了

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

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

相关文章

MySQL基础三问：底层逻辑、正在执行、日志观察

MySQL基础三问：底层逻辑、正在执行、日志观察

背景及目录&#xff1a; 经常面试会遇到且实际工作中也会应用到的三个场景&#xff1a; 一.mysql查询时的底层原理是什么&#xff1f; 二.如何查看正在执行的mysql语句&#xff1f; 三.如何观察mysql运行过程中的日志信息&#xff1f; - - - - - - - - - -分割线- - - - -…
阅读更多...
【html5期末大作业】基于HTML+CSS+JavaScript管理系统页面模板

【html5期末大作业】基于HTML+CSS+JavaScript管理系统页面模板

&#x1f389;精彩专栏推荐 &#x1f4ad;文末获取联系 ✍️ 作者简介: 一个热爱把逻辑思维转变为代码的技术博主 &#x1f482; 作者主页: 【主页——&#x1f680;获取更多优质源码】 &#x1f393; web前端期末大作业&#xff1a; 【&#x1f4da;毕设项目精品实战案例 (10…
阅读更多...
pyinstaller 操作以及常见问题解决

pyinstaller 操作以及常见问题解决

最近有需要用pyinstaller打包 直接上命令&#xff1a; pyinstaller -F xxx.py -w -i img.ico-F 指定需要打包的主文件&#xff0c;-w是让打包后的exe&#xff0c;运行不再出现cmd框&#xff0c;一般打包都会加上&#xff0c;-i 是指定打包后的图标ico文件 在线生成ico链接&am…
阅读更多...
（14）点云数据处理学习——RGBD 里程计

（14）点云数据处理学习——RGBD 里程计

1、主要参考 &#xff08;1&#xff09;官网 RGBD Odometry — Open3D 0.16.0 documentation 2、原理和实现 2.1 RGBD Odometry主要作用 RGBD里程计在两个连续的RGBD图像对之间查找相机运动。输入是RGBDImage的两个实例。输出是刚体变换形式的运动。Open3D实现了[Steinbruc…
阅读更多...
Transformer——台大李宏毅详讲Transformer

Transformer——台大李宏毅详讲Transformer

文章目录李宏毅老师讲TransformerEncoderDecoderDecoder整体逻辑non-autoregressiveDecoder中的Cross Attention训练Seq2seq的一些Tips老师讲的超级棒&#xff0c;激动哭了&#xff1a; 视频链接&#xff1a;台大李宏毅21年机器学习课程 self-attention和transformer 李宏毅老师…
阅读更多...
Mac版Word设置从第K页开始显示页码

Mac版Word设置从第K页开始显示页码

tags: Word Tips 写在前面 最近有同学问我怎么在word文档中从第四页开始设置页码, 也就是首页以及第二页第三页的说明页都不编页码, 从第四页开始页码为1, 然后往后编号这种. 一开始我以为直接在页码设置处就有这个选项的(毕竟写东西几乎不用word, 也不熟悉), 后来发现还是t…
阅读更多...
从Unity Robotics Hub入门Unity-ROS

从Unity Robotics Hub入门Unity-ROS

0.简介 对于Unity而言&#xff0c;其拥有非常完备的物理特性&#xff0c;这对于机器人仿真是非常有用的&#xff0c;但是实际上Unity和ROS之间的通信一直是摆在两者之间的难题&#xff0c;正好看到宇宙爆肝锦标赛冠军写的这个系列&#xff0c;所以个人想参照为数不多的资料来进…
阅读更多...
2022年创新药行业研究报告

2022年创新药行业研究报告

第一章 行业概况 创新药&#xff0c;也称为原研药&#xff0c;是一个相对于仿制药的概念&#xff0c;指的是从机理开始源头研发&#xff0c;具有自主知识产权&#xff0c;具备完整充分的安全性有效性数据作为上市依据&#xff0c;首次获准上市的药物。新药上市要经历化合物的发…
阅读更多...
学个Antenna：Matlab天线工具箱知多少（二）

学个Antenna：Matlab天线工具箱知多少（二）

学个Antenna是以天线仿真和调试为主&#xff0c;理论原理为辅的干货天线技术专栏&#xff0c;包括天线入门知识以及各类天线的原理简介、仿真软件建模、设计、调试过程及思路。如有想看到的内容或技术问题&#xff0c;可以在文尾写下留言。 ​摘要&#xff1a; 上节推文学个Ant…
阅读更多...
A-Level商务例题解析及练习Sources of finance

A-Level商务例题解析及练习Sources of finance

今日知识点&#xff1a;Sources of finance 例题 Q: Discuss the benefits and drawbacks to a business of using only internal sources of finance to fund expansion. 解析 Answers could include:Outline of types of internal funding sources, such as building up rese…
阅读更多...
我与足球以及世界杯的过往

我与足球以及世界杯的过往

中东土豪卡塔尔斥资2000亿举办的世界杯正在如火如荼的进行中&#xff0c;我也是几乎一场不落的看完了每一场的比赛直播【最近都没怎么更文。。。】&#xff0c;目前小组赛已经结束&#xff0c;我们也见证了很多球星的落寞背影与不甘&#xff0c;也见证了新星的天赋与成长&#…
阅读更多...
E语言基本特征码/时钟反调试/窗体push大法

E语言基本特征码/时钟反调试/窗体push大法

E语言基本特征码/时钟反调试/窗体push大法 该篇文章有以下内容&#xff1a; 1. 易语言字符串比较函数 test edx,3 F7C203000000 2. 按钮事件特征码&#xff1a;FF55FC5F5E,可以被修改恒成立 3. 易语言体 FF 25 4. 时钟的反调试 5. Push窗体大法 一、利用 test…
阅读更多...
Qt-FFmpeg开发-音频解码为PCM文件（9）

Qt-FFmpeg开发-音频解码为PCM文件（9）

Qt-FFmpeg开发-使用libavcodec API的音频解码示例&#xff08;MP3转pcm&#xff09; 文章目录Qt-FFmpeg开发-使用libavcodec API的音频解码示例&#xff08;MP3转pcm&#xff09;1、概述2、实现效果3、主要代码4、完整源代码更多精彩内容&#x1f449;个人内容分类汇总 &#x…
阅读更多...
关于 registerForActivityResult()的使用方法，不能说详细，只能说略懂得例子

关于 registerForActivityResult()的使用方法，不能说详细，只能说略懂得例子

目录 1.情况说明 2.registerForActivityResult()的使用方法 1.情况说明 startActivityForResult();函数过时 使用了 registerForActivityResult()进行了代替 2.registerForActivityResult()的使用方法 数据来源 (2条消息) registerForActivityResult()的使用方法例子_发狂…
阅读更多...
西北工业大学算法实验机试复习

西北工业大学算法实验机试复习

&#x1f600;大家好&#xff0c;我是白晨&#xff0c;一个不是很能熬夜&#x1f62b;&#xff0c;但是也想日更的人✈。如果喜欢这篇文章&#xff0c;点个赞&#x1f44d;&#xff0c;关注一下&#x1f440;白晨吧&#xff01;你的支持就是我最大的动力&#xff01;&#x1f4…
阅读更多...
TC申请是否需要银行转账记录？

TC申请是否需要银行转账记录？

【TC申请是否需要银行转账记录&#xff1f;】 答案是毫无疑问的。 根据TE官网公开的文件CCS Certification Procedures V3.0 里面关于TC申请所需的文件指引E2.1.1f&#xff1a;&#xff08;如图&#xff09; 企业在申请与TE相关的认证项目&#xff08;例如GRS/RCS等等&#xf…
阅读更多...
iptables 命令和 iptables.service 服务 有什么关系 ?

iptables 命令和 iptables.service 服务 有什么关系 ?

写在前面 关于iptables 命令 和 iptabls.service 的一些疑惑理解不足小伙伴帮忙指正 傍晚时分&#xff0c;你坐在屋檐下&#xff0c;看着天慢慢地黑下去&#xff0c;心里寂寞而凄凉&#xff0c;感到自己的生命被剥夺了。当时我是个年轻人&#xff0c;但我害怕这样生活下去&…
阅读更多...
企业级大数据平台智能运维好帮手——星环科技多模数据平台监控软件Aquila Insight

企业级大数据平台智能运维好帮手——星环科技多模数据平台监控软件Aquila Insight

Aquila Insight介绍 Aquila Insight是星环科技推出的一款多模数据平台监控软件&#xff0c;为企业运维团队提供了一套统一、完整、便捷的智能化运维解决方案。通过丰富的仪表盘管理、告警与通知管理、实时和历史查询语句运行分析、计算和存储引擎的统一监控、完整的日志收集过滤…
阅读更多...
编程内功心法「底层原理系列」 回归与本质，让本文带你认识什么是计算机软件系统

编程内功心法「底层原理系列」 回归与本质，让本文带你认识什么是计算机软件系统

前提概要 如果希望可以把计算机编程技术提升到另外一个高度&#xff0c;,那么想要搞清楚什么是软件设计&#xff0c;首先就要理解什么是计算机软件&#xff0c;在这之后&#xff0c;再去考虑为什么对软件进行设计&#xff0c;以及在通常情况下应该怎样设计软件。 什么是计算机…
阅读更多...
计算机毕业设计：基于HTML学校后台用户登录界面模板源码

计算机毕业设计：基于HTML学校后台用户登录界面模板源码

&#x1f389;精彩专栏推荐 &#x1f4ad;文末获取联系 ✍️ 作者简介: 一个热爱把逻辑思维转变为代码的技术博主 &#x1f482; 作者主页: 【主页——&#x1f680;获取更多优质源码】 &#x1f393; web前端期末大作业&#xff1a; 【&#x1f4da;毕设项目精品实战案例 (10…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023