服务器之家:专注于服务器技术及软件下载分享
分类导航

PHP教程|ASP.NET教程|Java教程|ASP教程|编程技术|正则表达式|C/C++|IOS|C#|Swift|Android|VB|R语言|JavaScript|易语言|vb.net|

服务器之家 - 编程语言 - Java教程 - Spring Boot整合RabbitMQ开发实战详解

Spring Boot整合RabbitMQ开发实战详解

2021-03-31 13:53皂白 Java教程

这篇文章主要介绍了Spring Boot整合RabbitMQ开发实战,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧

这篇文章主要讲基本的整合。先把代码跑起来,再说什么高级特性。

rabbitmq 中的一些术语

如果你打开 rabbitmq web 控制台,你会发现其中有一个 exhanges 不好理解。下面简单说明一下。

Spring Boot整合RabbitMQ开发实战详解

交换器(exchange)

交换器就像路由器,我们先是把消息发到交换器,然后交换器再根据路由键(routingkey)把消息投递到对应的队列。(明白这个概念很重要,后面的代码里面充分体现了这一点)

队列(queue)

队列很好理解,就不用解释了。

绑定(binding)

交换器怎么知道把这条消息投递到哪个队列呢?这就需要用到绑定了。大概就是:使用某个路由键(routingkey)把某个队列(queue)绑定到某个交换器(exchange),这样交换器就知道根据路由键把这条消息投递到哪个队列了。(后面的代码里面充分体现了这一点)

加入 rabbitmq maven 依赖

?
1
2
3
4
<dependency>
 <groupid>org.springframework.boot</groupid>
 <artifactid>spring-boot-starter-amqp</artifactid>
</dependency>

再加入另外一个依赖(这个依赖可省略,主要是用来简化代码)

?
1
2
3
4
5
<dependency>
 <groupid>cn.hutool</groupid>
 <artifactid>hutool-all</artifactid>
 <version>4.0.2</version>
</dependency>

rabbitmqconfig.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
@configuration
public class rabbitmqconfig {
 
 public final static string queue_name = "spring-boot-queue";
 public final static string exchange_name = "spring-boot-exchange";
 public final static string routing_key = "spring-boot-key";
 
 // 创建队列
 @bean
 public queue queue() {
 return new queue(queue_name);
 }
 
 // 创建一个 topic 类型的交换器
 @bean
 public topicexchange exchange() {
 return new topicexchange(exchange_name);
 }
 
 // 使用路由键(routingkey)把队列(queue)绑定到交换器(exchange)
 @bean
 public binding binding(queue queue, topicexchange exchange) {
 return bindingbuilder.bind(queue).to(exchange).with(routing_key);
 }
 
 @bean
 public connectionfactory connectionfactory() {
 cachingconnectionfactory connectionfactory = new cachingconnectionfactory("127.0.0.1", 5672);
 connectionfactory.setusername("guest");
 connectionfactory.setpassword("guest");
 return connectionfactory;
 }
 
 @bean
 public rabbittemplate rabbittemplate(connectionfactory connectionfactory) {
 return new rabbittemplate(connectionfactory);
 }
 
}

生产者

直接调用 rabbittemplate 的 convertandsend 方法就可以了。从下面的代码里也可以看出,我们不是把消息直接发送到队列里面的,而是先发送到了交换器,交换器再根据路由键把我们的消息投递到对应的队列。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
@restcontroller
public class producercontroller {
 
 @autowired
 private rabbittemplate rabbittemplate;
 
 @getmapping("/sendmessage")
 public object sendmessage() {
 new thread(() -> {
  for (int i = 0; i < 100; i++) {
  string value = new datetime().tostring("yyyy-mm-dd hh:mm:ss");
  console.log("send message {}", value);
  rabbittemplate.convertandsend(rabbitmqconfig.exchange_name, rabbitmqconfig.routing_key, value);
  }
 }).start();
 return "ok";
 }
 
}

消费者

消费者也很简单,只需要对应的方法上加入 @rabbitlistener 注解,指定需要监听的队列名称即可。

?
1
2
3
4
5
6
7
8
@component
public class consumer {
 
 @rabbitlistener(queues = rabbitmqconfig.queue_name)
 public void consumemessage(string message) {
 console.log("consume message {}", message);
 }
}

运行项目

运行项目,然后打开浏览器,输入 http://localhost:9999/sendmessage 。在控制台就可以看到生产者在不停的的发送消息,消费者不断的在消费消息。

Spring Boot整合RabbitMQ开发实战详解

打开 rabbitmq web 控制台,也可以看到刚才我们在代码里面配置的交换器和队列,以及绑定信息。

Spring Boot整合RabbitMQ开发实战详解

点击进入交换器的详情

Spring Boot整合RabbitMQ开发实战详解

Spring Boot整合RabbitMQ开发实战详解

结语

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持服务器之家。

原文链接:https://my.oschina.net/u/3523423/blog/1618335

延伸 · 阅读

精彩推荐