交换机主要是接收消息并且转发到绑定的队列，交换机不存储消息，在启用ack模式后，交换机找不到队列会返回错误。交换机有四种类型：Direct, topic, Headers and Fanout。
图片
按规则转发消息(最灵活)，转发消息主要是根据通配符。在这种交换机下，队列和交换机的绑定会定义一种路由模式，那么，通配符就要在这种路由模式和路由键之间匹配后交换机才能转发消息。
1、 路由键(routingKey)：必须是字符，用句号.隔开：例如："order.a"；(一般有发布者定义)；
2、路由模式：必须包含一个 星号（*），主要用于匹配路由键指定位置的一个单词， #就表示相当于一个或者多个单词。(例如:order.*.*.*….)（一般由接收者提供），但是也可通过rabbitmq客户端配置。常用在队列Queues定义中。
direct类型要求routingkey完全相等，但是topic exchange可以有通配符：“*”:表示匹配一个单词， “#”:则表示匹配没有或者多个单词。优势：可实现批量订阅消费。(Routingkey与Queues之间支持模糊匹配)。
图片
案例：
/** * 功能描述:通过消费端注解绑定的方式发送Topic交换机中 * @MethodName: sendTopicMessageByZJ * @MethodParam: [messageData] * @Return: void * @Author: yyalin * @CreateDate: 2022/4/9 18:17 */ public void sendTopicMessageByZJ(String messageData){ CorrelationData correlationData = new CorrelationData("1"); rabbitTemplate.convertAndSend("topicExchange", "china.car",messageData,correlationData); }direct 类型的行为是"先匹配, 再投送". 即:在绑定时设定一个 routingkey, 消息的routingkey 匹配时, 才会被交换器投送到绑定的队列中。是RabbitMQ默认的交换机模式，也是最简单的模式，根据key全文匹配去寻找队列。(按照routingkey分发到指定队列)
所有发送到direct exchange的消息被转发到routingkey中指定到queue。
注意：direct模式可使用rabbitmq自带的exchange:AMQP default，所以不需将exchange进行任何绑定操作(binding)，消息传递时，routingkey必须完全匹配才会被对列接收，否则该消息会被抛弃。(Routingkey与Queues之间必须全文匹配)。
图片
在direct类型的exchange中，只有routingkey完全相同，exchange才会选择对应的binging进行消息路由。
案例：
/** * 功能描述:通过消费端注解绑定的方式发送Direct交换机中 * @MethodName: sendDirectMessageByZJ * @MethodParam: [messageData] * @Return: void * @Author: yyalin * @CreateDate: 2022/4/9 18:17 */ public void sendDirectMessageByZJ(String messageData){ CorrelationData correlationData = new CorrelationData("1"); rabbitTemplate.convertAndSend("directExchange", "blue",messageData,correlationData); }设置header attribute参数类型的交换机，相较于 direct 和 topic 固定地使用 routing_key , headers 则是一个自定义匹配规则的类型. 在队列与交换器绑定时, 会设定一组键值对规则, 消息中也包括一组键值对( headers 属性), 当这些键值对有一对, 或全部匹配时, 消息被投送到对应队列.
转发消息到所有绑定队列，消息广播的模式，不管路由键或者是路由模式，会把消息发给绑定给它的全部队列，如果配置了routing_key会被忽略。(直接将消息路由到所有绑定的队列中，无须对消息的routingkey进行匹配操作)。
图片
案例：
/** * 功能描述:发送FanoutMessage消息 * @MethodName: sendFanoutMessage * @MethodParam: [messageData] * @Return: void * @Author: yyalin * @CreateDate: 2022/4/9 17:46 */ public void sendFanoutMessage(String messageData){ CorrelationData correlationData = new CorrelationData("1"); rabbitTemplate.convertAndSend("fanoutExchange", "",messageData,correlationData); }一般direct和topic用来具体的路由消费，若要用广播的消息一般用fanout的exchange，header类型比较少。
本文链接：http://www.28at.com/showinfo-26-17168-0.htmlRabbitMQ的四种交换机详解
声明：本网页内容旨在传播知识，若有侵权等问题请及时与本网联系，我们将在第一时间删除处理。邮件：2376512515@qq.com
Copyright © 2016-2023 天津谷骐科技有限公司 版权所有 sitemap.xml
违法及侵权请联系：2376512515@qq.com 津ICP备18001702号
津公网安备 12010102000574号