个人中心
gpt4 book ai didi

spring boot中使用RabbitMQ routing路由详解

转载 作者：qq735679552 更新时间：2022-09-27 22:32:09 28 4
gpt4 key购买 nike

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章spring boot中使用RabbitMQ routing路由详解由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.

在上一个教程中我们创建了一个扇形（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或者警告日志.

  1. fanout交换器不能实现这个操作，因为它只能笨笨的广播。
  2. 我们使用直连direct交换器替代。直连交换器背后的路由算法很简单，绑定的键要精确匹配消息的路由键后，这个消息才能进入队列中。

spring boot中使用RabbitMQ routing路由详解

橙色、黑色、绿色三种路由键 。

如上图，直连交换器x上绑定了2个队列。第一个队列使用路由键是orange，第二个有2个路由键，black和green.

在这个设定中，把一个使用路由键为orange的消息推送到交换器上时，那么这个消息将会被路由到队列q1上。消息使用的路由键是black或者green时将会被路由到q2。其余没有使用路由键的消息将会被丢弃.

并联绑定 。

spring boot中使用RabbitMQ routing路由详解

并联绑定 。

这个可以实现类似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 。

最后此篇关于spring boot中使用RabbitMQ routing路由详解的文章就讲到这里了,如果你想了解更多关于spring boot中使用RabbitMQ routing路由详解的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。

28 4 0
文章推荐： vbs实现的tasklist效果代码
文章推荐： vbs 自制数字益智游戏实现代码
文章推荐： java获取json中的全部键值对实例
文章推荐： VBS中常见字符串操作函数
qq735679552
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com