spring boot中使用RabbitMQ routing路由详解

时间:2021-05-02

在上一个教程中我们创建了一个扇形(fanout)交换器。我们能把消息已广播的形式传递给多个消费者。

要做什么?routing 路由

在这个教程中,添加一个新的特性,我们可以只订阅消息的一部分。例如,将只连接我们感兴趣的颜色("orange", "black", "green"),并且把消息全部打印在控制台上。

绑定

交换器和队列是一种绑定关系。简单的理解为:队列对来自这个交换器中的信息感兴趣。

绑定可以加上一个额外的参数routingkey。spring-amqp使用通俗易懂的api(建造者模式)使它们之间的关系非常清晰。把交换器和队列放入bindingbuilder中并可以很容易的把队列用路由键(routingkey)绑定到交换器上。

? 1 2 3 4 @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

    ? 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 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

    ? 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 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

    ? 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 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

    ? 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 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

    声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。

    相关文章