文章目录
- Exchanges
- Exchanges的类型
- Fanout
- Direct
- Topic
Exchanges
(交换机)RabbitMQ 消息传递模型的核心思想是: 生产者生产的消息从不会直接发送到队列。
Exchanges的类型
直接(direct),主题(topic),标题(headers),扇出(fanout),无名(exchange)
通过指定交换机的相同的routingkey,同时将信息发送到两个消费者
Fanout
扇出交换机
优点: 只要是Routingkey相同,可以将一条消息发送给多个队列,然后再由队列发送给指定的消费者(类似于一对多的概念)
通过下面的逻辑图可以清晰的看出,生产者先将消息发送给交换机,由交换机通过指定的Routingkey将消息发送给指定的队列。
Direct
直接交换机
与扇出交换机交换机的区别是,直接交换机每个Routingkey是不一样的,一个Routingkey对应一个队列(类似于一对一的概念)
通过下面的逻辑图可以清晰的看出,生产者先将消息发送给交换机,交换机通过指定的Routingkey将消息发送给指定的队列。
在绑定队列时,指定不同的Routingkey(info和warning)交换机在发送消息时,会匹配到对应的Routingkey将消息发送到MQ队列
//绑定队列
channel.queueBind("console",EXCHANGE_NAME,"info");
channel.queueBind("console",EXCHANGE_NAME,"warning");
Topic
主题交换机
Routingkey必须是一个单词列表,以点号分隔开,比如:aaaa.cdk
:可以代替一个单词(.aaaa.*)
#:可以代表零个或多个单词
在声明队列时去指定Routingkey格式(.orange.,两边必须是两个单词,用.隔开,中间必须是orange,才能满足将数据发送Q1队列中的条件)
//声明队列
String queueName = "Q1";
channel.queueDeclare(queueName,false,false,false,null);
channel.queueBind(queueName,EXCHANGE_NAME,"*.orange.*");
通过上面这个定义Routingkey公式,去定义Routingkey,当Routingkey匹配时,可以实现一个消息发送到多个队列中,也可以实现一个消息发送到一个队列中,也可以实现当前Routingkey没有匹配到任何一个队列,相比扇出交换机和直接交换机扩展性更强,应用比较广泛。