spring boot中使用RabbitMQ routing路由详解
|
在上一个教程中我们创建了一个扇形（fanout）交换器。我们能把消息已广播的形式传递给多个消费者。 要做什么？Routing 路由 在这个教程中，添加一个新的特性，我们可以只订阅消息的一部分。例如，将只连接我们感兴趣的颜色（"orange","black","green"），并且把消息全部打印在控制台上。 绑定 交换器和队列是一种绑定关系。简单的理解为：队列对来自这个交换器中的信息感兴趣。 绑定可以加上一个额外的参数routingKey。Spring-amqp使用通俗易懂的API（建造者模式）使它们之间的关系非常清晰。把交换器和队列放入BindingBuilder中并可以很容易的把队列用路由键（routingKey）绑定到交换器上。
@Bean
public Binding binding0a(DirectExchange directExchange,Queue autoDeleteQueue0) {
return BindingBuilder.bind(autoDeleteQueue0).to(directExchange).with("orange");
}
这个意味着，绑定键依赖交换器类型，fanout交换器就不行没有可以绑定的选项。 直连交换器 前一个教程中我们的消息系统是以广播的形式传递给所有的消费者。我们想要扩展一下功能，加入基于颜色类型的过滤器。例如，我们想要程序一个接收详细的错误消息并写入硬盘作为日志，不接收Info或者警告日志。
橙色、黑色、绿色三种路由键 如上图，直连交换器x上绑定了2个队列。第一个队列使用路由键是orange，第二个有2个路由键，black和green。 在这个设定中，把一个使用路由键为orange的消息推送到交换器上时，那么这个消息将会被路由到队列Q1上。消息使用的路由键是black或者green时将会被路由到Q2。其余没有使用路由键的消息将会被丢弃。 并联绑定
并联绑定 这个可以实现类似fanout交换器的功能。 差不多了，看代码 Config.java
package com.zb.rabbitMQtest.t4routing.config;
import org.springframework.amqp.core.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/**
* @author 张博
*/
@Configuration(value = "t4Config")
public class Config {
/**
* 创建人：张博
* 时间：2018/3/5 上午10:45
* @apiNote 定义直连交换器
*/
@Bean
public DirectExchange directExchange() {
return new DirectExchange("direct-exchange");
}
/**
* 创建人：张博
* 时间：2018/3/5 上午10:48
* @apiNote 定义自动删除匿名队列
*/
@Bean
public Queue autoDeleteQueue0() {
return new AnonymousQueue();
}
/**
* 创建人：张博
* 时间：2018/3/5 上午10:48
* @apiNote 定义自动删除匿名队列
*/
@Bean
public Queue autoDeleteQueue1() {
return new AnonymousQueue();
}
/**
* 创建人：张博
* 时间：2018/3/5 上午10:48
* @param directExchange 直连交换器
* @param autoDeleteQueue0 自动删除队列
* @apiNote 绑定使用路由键为 orange 的 autoDeleteQueue0 队列到直连交换器上
* @return Binding
*/
@Bean
public Binding binding0a(DirectExchange directExchange,Queue autoDeleteQueue0) {
return BindingBuilder.bind(autoDeleteQueue0).to(directExchange).with("orange");
}
/**
* 创建人：张博
* 时间：2018/3/5 上午10:48
* @param directExchange 直连交换器
* @param autoDeleteQueue0 自动删除队列
* @apiNote 绑定使用路由键为 black 的 autoDeleteQueue0 队列到直连交换器上
* @return Binding
*/
@Bean
public Binding binding0b(DirectExchange directExchange,Queue autoDeleteQueue0) {
return BindingBuilder.bind(autoDeleteQueue0).to(directExchange).with("black");
}
/**
* 创建人：张博
* 时间：2018/3/5 上午10:48
* @param directExchange 直连交换器
* @param autoDeleteQueue1 自动删除队列
* @apiNote 绑定使用路由键为 black 的 autoDeleteQueue1 队列到直连交换器上
* @return Binding
*/
@Bean
public Binding binding1a(DirectExchange directExchange,Queue autoDeleteQueue1) {
return BindingBuilder.bind(autoDeleteQueue1).to(directExchange).with("black");
}
/**
* 创建人：张博
* 时间：2018/3/5 上午10:48
* @param directExchange 直连交换器
* @param autoDeleteQueue1 自动删除队列
* @apiNote 绑定使用路由键为 green 的 autoDeleteQueue1 队列到直连交换器上
* @return Binding
*/
@Bean
public Binding binding1b(DirectExchange directExchange,Queue autoDeleteQueue1) {
return BindingBuilder.bind(autoDeleteQueue1).to(directExchange).with("green");
}
}
Receiver.java
package com.zb.rabbitMQtest.t4routing.receiver;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;
/**
* @author 张博
*/
@Component(value = "t4Receiver")
public class Receiver {
@RabbitListener(queues = "#{autoDeleteQueue0.name}")
public void receiver0(String str) {
System.out.println("receiver0++++++++++:" + str);
}
@RabbitListener(queues = "#{autoDeleteQueue1.name}")
public void receiver1(String str) {
System.out.println("receiver1++++++++++:" + str);
}
}
Send.java
package com.zb.rabbitMQtest.t4routing.send;
import org.springframework.amqp.core.DirectExchange;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
/**
* @author 张博【zhangb@lianliantech.cn】
*/
@Component(value = "t4Send")
public class Send {
@Autowired
private DirectExchange directExchange;
@Autowired
private RabbitTemplate rabbitTemplate;
private String[] keys = {"orange","green"};
public void send() {
String message = "哈哈哈";
for (int i = 0; i < 5; i++) {
System.out.println("send++++++++++:".concat(message));
rabbitTemplate.convertAndSend(directExchange.getName(),keys[2],message);
}
}
}
SendTest.java
package com.zb.rabbitMQtest.t4routing.send;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;
/**
* @author 张博
*/
@RunWith(SpringRunner.class)
@SpringBootTest
public class SendTest {
@Autowired
private Send send;
@Test
public void send() throws Exception {
send.send();
}
}
测试结果，如果是keys[0]那么只有receiver0，如果是keys[1]那么就是类似广播那样，有receive0和receive1，如果是keys[2]那么只有receive1
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持编程小技巧。 您可能感兴趣的文章:
（编辑：李大同） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |
