个人中心
gpt4 book ai didi

Spring Boot整合RabbitMQ开发实战详解

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

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

这篇CFSDN的博客文章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 。

最后此篇关于Spring Boot整合RabbitMQ开发实战详解的文章就讲到这里了,如果你想了解更多关于Spring Boot整合RabbitMQ开发实战详解的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。

28 4 0
文章推荐： Python实现获取域名所用服务器的真实IP
文章推荐： Android 初识 Helloworld 详解
文章推荐： Android 监听apk安装替换卸载广播的实现代码
文章推荐： Python制作爬虫采集小说
qq735679552
个人简介

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

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