RabbitMq交换机类型介绍

这篇具有很好参考价值的文章主要介绍了RabbitMq交换机类型介绍。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

RabbitMq交换机类型介绍

在RabbitMq中,生产者的消息都是通过交换器来接收,然后再从交换器分发到不同的队列,再由消费者从队列获取消息。这种模式也被成为“发布/订阅”。

分发的过程中交换器类型会影响分发的逻辑。

  • 直连交换机:Direct exchange
  • 扇形交换机:Fanout exchange
  • 主题交换机:Topic exchange
  • 首部交换机:Headers exchange

1 DirectExchange(直连交换机)

​ 直连交换机是一种带路由功能的交换机,交换机会通过路由(Routing_key)和指定队列进行绑定。在创建的时候会创建一个路由,和一个绑定关系,路由和绑定关系相互对应。

​ 发送消息时会指定exchange和routing_key,所有通过该routing_key和exchange绑定的队列都会收到同样的消息。

RabbitMq交换机类型介绍,RabbitMq,java-rabbitmq,rabbitmq,java,中间件

测试实例在https://blog.csdn.net/qq_43331014/article/details/132255631文章中作为例子详细讲解过了。

2 Topic exchange(主题交换机)

​ 在RabbitMq中,生产者的消息都是通过交换机来接收,然后再从交换机分发到不同的队列中去,在分发的过程中交换机类型会影响分发的逻辑,下面主要讲解一下主题交换机。

​ 主题交换机核心是可以以范围的行为向队列发送消息,它和直连交换机区别在于,直连交换机一个队列通过一个binding_key和交换机的进行绑定,只能接受一中消息;主题交换机可以按照一定的匹配规则去匹配多个routing_key

那匹配规则是什么?

交换机和队列的binding_key需要采用*.#.*.....的格式,每个单词用.作为分隔符,其中:

  • *表示一个单词(必须出现的)
  • ##(井号)用来表示任意数量单词(零个或多个)

例如:假设有一条消息的routing_keytopic.china.shanghai,另一条为topic.china,那么binding_keytopic.#的队列这两条消息都会收到

通配符 功能 示例
\* 匹配一个单词 topic.* 可以匹配到 topic.china 或者 topic.shanghai
# 匹配零个或多个单词 topic.# 可以匹配到 topic.china或者 topic.china.beijing

通俗理解:

​ 主题交换机的流程,相当于报纸订阅。有一个总报社(相当于生产者)发出各种类型的报纸到各个分报社,分报社相当于不同的交换机,每种类型报纸相当于不同的routing_key,再往下有卖报点去分报社去报纸,但每个卖报点根据消费者的需求所需要的类型不一样。比如一个分报社手里有两种类型的报纸:新闻.经济新闻.体育。这时三个卖报点来取报纸,卖家A只需要新闻经济类,那他跟交换机的binding_key就是新闻.经济;卖家B只需要新闻体育类,那他的binding_key就是新闻.体育;而卖家C这很多消费者都在他这买报纸,他既需要新闻经济类又需要新闻体育类,他的binding_key相当于是新闻.#,新闻下面的都收。

​ 而直连交换机是什么,相当于更小的分销商,针对更精确的人群。他不能像上面那种情况把新闻下所有类都收了,只能一对一的关系,有人需要新闻.经济就绑定上,只去收新闻.经济报,不能多拿,再有人需要新闻.体育才能再收体育报。

下面通过代码演示下主题交换机

  • 创建交换机、队列、绑定关系

    @Configuration
    public class TopicRabbitConfig {
    
        @Bean
        public Queue firstQueue(){
            return new Queue("topic.shanghai",true,false,false);
        }
    
        @Bean
        public Queue secondQueue(){
            return new Queue("topic.beijing",true,false,false);
        }
    
        @Bean
        public Queue thirdQueue(){
            return new Queue("topic.china.beijing",true,false,false);
        }
    
        @Bean
        public TopicExchange topicExchange(){
            return new TopicExchange("topicExchange",true,false);
        }
    
        /**
         * 交换机和队列绑定,并设置绑定key
         */
        @Bean
        Binding firstBinding(){
            return BindingBuilder.bind(firstQueue()).to(topicExchange()).with("topic.shanghai");
        }
    
        @Bean
        Binding secondBinding(){
            //只要是消息携带的路由键是以topic.开头,后面还更有一个单词的都会分发到该队列
            return BindingBuilder.bind(secondQueue()).to(topicExchange()).with("topic.*");
        }
    
        @Bean
        Binding thirdBinding(){
            //只要是消息携带的路由键是以topic.开头,都会分发到该队列
            return BindingBuilder.bind(thirdQueue()).to(topicExchange()).with("topic.#");
        }
    }
    

    可以看到已经创建成功
    RabbitMq交换机类型介绍,RabbitMq,java-rabbitmq,rabbitmq,java,中间件
    RabbitMq交换机类型介绍,RabbitMq,java-rabbitmq,rabbitmq,java,中间件

  • 分别给交换机按三个不同routing_key发送消息,对应的routing_key分别为:topic.shanghaitopic.haha.hehetopic.test

    @PostMapping("/sendMessageByTopic")
    public AjaxResult sendMessageByTopic(@RequestBody Map params) {
        String id = UUID.randomUUID().toString();
        String createTime = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
        params.put("messageId",id);
        params.put("createTime",createTime);
        /**
         * 发给交换机,通过匹配队列和交换机绑定关系值,判断发送给哪个队列
         */
        rabbitTemplate.convertAndSend("topicExchange","topic.shanghai",params);
        rabbitTemplate.convertAndSend("topicExchange","topic.haha.hehe",params);
        rabbitTemplate.convertAndSend("topicExchange","topic.test",params);
        return AjaxResult.success("成功");
    }
    

    三个队列分别对应的匹配规则及接受到消息的结果如图:
    RabbitMq交换机类型介绍,RabbitMq,java-rabbitmq,rabbitmq,java,中间件

    可以看到topic.shanghai队列只能匹配一条,topic.china.beijing队列因为binding_key是topic.#所以全部匹配,topic.beijing队列因为binding_key是topic.*,所以匹配了topic后面只跟一个单词的。

监听就不细说了,跟交换机类型关系不大,主要根据队列名称去监听,实例可以看https://blog.csdn.net/qq_43331014/article/details/132255631第六节

3 Fanout exchange(扇形交换机)

扇形交换机广播消息,会将接到的消息发送到每一个与其绑定的队列中去。

不需要管绑定的binding_key是什么

RabbitMq交换机类型介绍,RabbitMq,java-rabbitmq,rabbitmq,java,中间件

在编写发送消息代码时,不需要填写routing_key

/**
 *广播交换机
 * @return
 * @throws InterruptedException
 */
@PostMapping("/sendMessageByFanout")
public AjaxResult sendMessageByFanout(@RequestBody Map params) {
    String id = UUID.randomUUID().toString();
    String createTime = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
    params.put("messageId",id);
    params.put("createTime",createTime);
    /**
     * 扇形交换机,不需要指定路由,会广播给每一个绑定的队列
     */
    rabbitTemplate.convertAndSend("fanoutExchange","",params);
    return AjaxResult.success("成功");
}

4 Headers exchange(首部交换机)

​ 与routingKey无关,匹配机制是匹配消息头中的属性信息。在绑定消息队列与交换机之前声明一个map键值对,通过这个map对象实现消息队列和交换机的绑定。当消息发送到RabbitMQ时会取到该消息的headers与Exchange绑定时指定的键值对进行匹配;如果完全匹配则消息会路由到该队列,否则不会路由到该队列。

匹配规则x-match有下列两种类型:

x-match = all :表示所有的键值对都匹配才能接受到消息

x-match = any :表示只要有键值对匹配就能接受到消息

种交换器类型在性能上相对来说较差,在实际工作中很少会用到。
RabbitMq交换机类型介绍,RabbitMq,java-rabbitmq,rabbitmq,java,中间件文章来源地址https://www.toymoban.com/news/detail-658986.html

到了这里,关于RabbitMq交换机类型介绍的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • SpringBoot整合RabbitMQ,三种交换机类型示例

    在application.properties或application.yml中配置RabbitMQ服务器的连接参数: 4.1、DirectExchange(直连交换机) 消费者 生产者 测试 一个交换机对多个队列的特点: 一个队列对多个消费者特点: 4.2、FanoutExchange(扇形/广播交换机) 消费者 生产者 4.3、TopicExchange(主题交换机) 消费者 生

    2024年04月12日
    浏览(35)
  • 【图解RabbitMQ-6】说说交换机在RabbitMQ中的四种类型以及使用场景

    🧑‍💻作者名称:DaenCode 🎤作者简介:CSDN实力新星,后端开发两年经验,曾担任甲方技术代表,业余独自创办智源恩创网络科技工作室。会点点Java相关技术栈、帆软报表、低代码平台快速开发。技术尚浅,闭关学习中······ 😎人生感悟:尝尽人生百味,方知世间冷暖。

    2024年02月07日
    浏览(79)
  • rabbitmq基础-java-3、Fanout交换机

    Fanout,英文翻译是扇出。 1)  可以有多个队列 2)  每个队列都要绑定到Exchange(交换机) 3)  生产者发送的消息,只能发送到交换机 4)  交换机把消息发送给绑定过的所有队列 5)  订阅队列的消费者都能拿到消息 交换机的作用是什么? 接收publisher发送的消息 将消息按

    2024年01月25日
    浏览(46)
  • rabbitmq基础-java-5、Topic交换机

    Topic 类型的 Exchange 与 Direct 相比,都是可以根据 RoutingKey 把消息路由到不同的队列。 只不过 Topic 类型 Exchange 可以让队列在绑定 BindingKey 的时候使用通配符! BindingKey 一般都是有一个或多个单词组成,多个单词之间以 . 分割,例如: item.insert 通配符规则: # :匹配一个或多个

    2024年01月25日
    浏览(36)
  • rabbitmq基础-java-4、Direct交换机

            在Fanout模式中,一条消息,会被所有订阅的队列都消费。但是,在某些场景下,我们希望不同的消息被不同的队列消费。这时就要用到Direct类型的Exchange。   在Direct模型下: 队列与交换机的绑定,不能是任意绑定了,而是要指定一个 RoutingKey (路由key) 消息的发

    2024年01月25日
    浏览(44)
  • RabbitMQ 备份交换机和死信交换机

      为处理生产者将消息推送到交换机中,交换机按照消息中的路由键及自身策略无法将消息投递到指定队列中造成消息丢失的问题,可以使用备份交换机。   为处理在消息队列中到达TTL的过期消息,可采用死信交换机进行消息转存。可以通过死信交换机的方式实现延迟队

    2024年02月14日
    浏览(52)
  • RabbitMQ之Exchange(交换机)属性及备用交换机解读

    目录 基本介绍 主要结论 备用交换机  springboot代码实战(备用交换机) 实战架构 工程概述 RabbitConfigDeal 配置类:创建队列及交换机并进行绑定  MessageService业务类:发送消息及接收消息 主启动类RabbitMq01Application:实现ApplicationRunner接口 在 RabbitMQ 中,交换机主要用来将生产

    2024年02月02日
    浏览(51)
  • 【RabbitMQ】RabbitMQ的交换机

    在上文中, 都没有交换机,生产者直接发送消息到队列。 而一旦引入交换机,消息发送的模式会有很大变化:可以看到,在订阅模型中,多了一个exchange角色,而且过程略有变化: Publisher:生产者,不再发送消息到队列中,而是发给交换机 Exchange:交换机,一方面,接收生

    2024年03月12日
    浏览(56)
  • 【RabbitMQ(day3)】扇形交换机和主题交换机的应用

    扇型交换机将消息路由给绑定到它身上的所有队列,而不会理会绑定的路由键。如果 N 个队列绑定到某个扇型交换机上,当有消息发送给此扇型交换机时,交换机会将消息的拷贝分别发送给这所有的 N 个队列。扇型用来交换机处理消息的广播路由。 因为扇型交换机投递信息的

    2024年02月14日
    浏览(49)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包