spring boot 中使用 RabbitMQ 教程四 routing 路由
2018-03-09 16:31
549 查看
https://www.jianshu.com/p/20d9009d2db8
在上一个教程中我们创建了一个扇形(
要做什么?Routing 路由在这个教程中,添加一个新的特性,我们可以只订阅消息的一部分。例如,将只连接我们感兴趣的颜色(
绑定交换器和队列是一种绑定关系。简单的理解为:队列对来自这个交换器中的信息感兴趣。
绑定可以加上一个额外的参数
直连交换器前一个教程中我们的消息系统是以广播的形式传递给所有的消费者。我们想要扩展一下功能,加入基于颜色类型的过滤器。例如,我们想要程序一个接收详细的错误消息并写入硬盘作为日志,不接收Info或者警告日志。
我们使用直连
橙色、黑色、绿色三种路由键
如上图,直连交换器
在这个设定中,把一个使用路由键为
并联绑定
并联绑定这个可以实现类似
作者:阿波罗程序猿
链接:https://www.jianshu.com/p/20d9009d2db8
來源:简书
著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。
在上一个教程中我们创建了一个扇形(
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或者警告日志。
fanout交换器不能实现这个操作,因为它只能笨笨的广播。
我们使用直连
direct交换器替代。直连交换器背后的路由算法很简单,绑定的键要精确匹配消息的路由键后,这个消息才能进入队列中。
橙色、黑色、绿色三种路由键
如上图,直连交换器
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", "black", "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
当keys[0]时 send++++++++++:哈哈哈 send++++++++++:哈哈哈 send++++++++++:哈哈哈 send++++++++++:哈哈哈 send++++++++++:哈哈哈 receiver0++++++++++:哈哈哈 receiver0++++++++++:哈哈哈 receiver0++++++++++:哈哈哈 receiver0++++++++++:哈哈哈 receiver0++++++++++:哈哈哈 当keys[1]时 send++++++++++:哈哈哈 send++++++++++:哈哈哈 send++++++++++:哈哈哈 send++++++++++:哈哈哈 send++++++++++:哈哈哈 receiver1++++++++++:哈哈哈 receiver1++++++++++:哈哈哈 receiver0++++++++++:哈哈哈 receiver0++++++++++:哈哈哈 receiver0++++++++++:哈哈哈 receiver1++++++++++:哈哈哈 receiver1++++++++++:哈哈哈 receiver0++++++++++:哈哈哈 receiver1++++++++++:哈哈哈 receiver0++++++++++:哈哈哈 当keys[2]时 send++++++++++:哈哈哈 send++++++++++:哈哈哈 send++++++++++:哈哈哈 send++++++++++:哈哈哈 send++++++++++:哈哈哈 receiver1++++++++++:哈哈哈 receiver1++++++++++:哈哈哈 receiver1++++++++++:哈哈哈 receiver1++++++++++:哈哈哈 receiver1++++++++++:哈哈哈
作者:阿波罗程序猿
链接:https://www.jianshu.com/p/20d9009d2db8
來源:简书
著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。
相关文章推荐
- Spring Boot教程(十)Spring Boot中使用RabbitMQ
- springboot使用RabbitMQ教程
- RabbitMQ官方中文入门教程(PHP版) 第四部分:路由(Routing)
- Spring Boot中使用RabbitMQ
- RabbitMQ入门教程——路由(Routing)
- springboot 使用教程
- spring cloud教程之使用spring boot创建一个应用
- Spring Boot入门级使用教程
- SpringBoot非官方教程 | 第十五篇:Springboot整合RabbitMQ
- spring boot / cloud (九) 使用rabbitmq消息中间件
- Spring Boot系列教程三:使用devtools实现热部署
- Spring boot下使用RabbitMQ实例
- 【Spring Boot教程】推荐使用Spring Tool Suite(STS)开发
- Spring Boot中使用RabbitMQ
- Maven快速使用教程(二) spring boot 项目构建
- Spring Boot教程(六) -- 使用 Spring Boot CLI
- spring cloud教程之使用spring boot创建一个应用
- Spring Boot中使用RabbitMQ
- RabbitMQ-三、Java使用--3、路由选择 (Routing)
- spring cloud教程之使用spring boot创建一个应用