Spring Boot 整合 RabbitMQ

野性酷女 2022-11-29 12:28 211阅读 0赞

上一节介绍了 RabbitMQ 的基本概念，这一节介绍 RabbitMQ 的安装使用，以及 SpringBoot 中如何整合使用 RabbitMQ，将介绍 direct/fanout/topic 三种类型的交换器的使用。

--------------------

## RabbitMQ 安装 ##

从官网下载安装包：[https://www.rabbitmq.com/download.html][https_www.rabbitmq.com_download.html]  
  
  
以 windows 为例，直接下载 EXE 文件：  
  
  
  
![format_png][]

运行 EXE 文件，等待安装完成后。可以在 windows 的应用中看到 RabbitMQ Service，启动它。  
  
  
  
![format_png 1][]

开启可视化管理插件，找到 RabbitMQ 的安装目录，切换到 sbin 文件夹下，打开命令行，输入：

rabbitmq-plugins enable rabbitmq_management

![format_png 2][]

打开浏览器，输入：http://127.0.0.1:15672，可以看到管理页面了。在这个页面，我们可以手动操作 RabbitMQ，包括新建 exchange，新建队列，设置队列绑定，查看队列信息等等。  
  
  
注：rabbitmq 默认的账号和密码都是 guest !

![format_png 3][]

下面我们快速的看一下 Spring Boot 中如何整合使用 RabbitMQ

--------------------

## SpringBoot 整合 RabbitMQ ##

上一节提到 RabbitMQ 中的 exchange 有四种类型，其中 headers 类型很少使用，这里分别以 direct/fanout/topic 三种 exchange 类型为例，记录 默认/广播/模式匹配 这三种常见场景中 RabbitMQ 的使用。    
  
  
  
  
Spring Boot 提供了快速接入 RabbitMQ 的依赖，我们只要引入这个依赖并添加很少的一些配置就可以了！

<dependency>
    	<groupId>org.springframework.boot</groupId>
    	<artifactId>spring-boot-starter-amqp</artifactId>
    </dependency>

### direct ###

#### producer ####

在配置文件中添加 RabbitMQ 的配置信息：

server:
      port: 8701
    spring:
      rabbitmq:
        addresses: 127.0.0.1
        username: guest
        password: guest
        port: 5672
        virtual-host: /

发送消息：

@RestController
    @RequestMapping(value = "msg")
    public class HelloAction { 
    
        @Autowired
        private RabbitTemplate rabbitTemplate;
    
        @GetMapping(value = "direct")
        public String sayHello(String msg) { 
            rabbitTemplate.convertAndSend("demo", msg);
            return "消息发送成功";
        }
    }

这时候 demo 队列可能不存在，我们可以手动在 mq 中的创建，也可以通过 @Bean 来 declare：

@Configuration
    public class RabbitConfig { 
        @Bean
        public Queue demo() { 
            return new Queue("demo", true);
        }
    }

测试：  
  
![format_png 4][]

--------------------

#### consumer ####

同样创建一个 spring boot 项目，引入 rabbitmq 依赖，并添加相关配置。  
利用 @RabbitListener 注解接收数据：

@Component
    public class RabbitConsumer { 
    
        @RabbitListener(queues = { "demo"})
        public void consume(Message message, Channel channel) throws IOException { 
            System.out.println("接收到消息：" + message);
            channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
        }
    }

启动项目：

![format_png 5][]

这里用的是 Message 类型，我们可以通过 @Payloa 注解来直接接收 body 数据：

@RabbitListener(queues = { "demo"})
        public void consume(@Payload String body, Channel channel) throws IOException { 
            System.out.println("接收到消息：" + body);
        }

Spring Boot RabbitMQ 中可以使用 @RabbitListener 和 @RabbitHandler 两个注解联合来从同样的接口中接收不同参数类型的数据并处理，比如 String、Object 等。  
不过个人建议发送数据的时候直接用 String，如果是对象，可以用 JSON 工具将对象转换为字符串。接收数据时再用 JSON 工具将字符串还原为对象。

--------------------

注意，在这种情况下，我们使用的默认的 direct exchange，默认的 routing key 就是队列名。  
如果需要自定义 exchange，那么就要指定 binding。比如新建一个 direct 类型的 exchange，名为 demoex，然后添加一个 binding 到 demo，这个 routing key 是完全匹配的：

![format_png 6][]

--------------------

### fanout ###

fanout 类型的 exchange 表示广播。  
我们这里创建三个队列：pub\_demo1, pub\_demo2, pub\_demo3  
然后创建一个 exchange：demoex\_fanout  
将这三个队列绑定到这个exchange上，不需要 routing\_key。这些操作都是通过 management 页面进行的。

![format_png 7][]

发送广播消息：

@GetMapping(value = "broadCast")
        public String broadCast(String msg) { 
            // 广播消息到 demoex_public 这个 exchange 绑定的所有队列
            rabbitTemplate.convertAndSend("demoex_fanout", "", msg);
            return "广播成功";
        }

测试接口，可以看到这三个队列中都有数据了：  
  
![format_png 8][]

--------------------

### topic ###

topic 的模式匹配包括两个通配符：\#和\* *，其中 \# 匹配 0 或多个单词，* \* 匹配一个单词。  
需要注意的是，这里的匹配符是用在 exchange 的 bindling 里的，如下，将 pat\_demo1,2,3 绑定到 demoex\_topic 这个 topic 类型的 exchange 上：  
  
  
  
![format_png 9][]

发送：

@GetMapping(value = "pattern")
        public String pattern(String msg) { 
            rabbitTemplate.convertAndSend("demoex_topic", "demo.a.b.c", msg);
            return "模式传播成功";
        }

查看 mq 中的 pat\_demo1,2,3 队列：

![format_png 10][]

--------------------

好了，到此为止，我们已经介绍了 RabbitMQ 的基础知识、如何安装 RabbitMQ ，以及 SpringBoot 如何快速接入 RabbitMQ 了。  
  
  
希望我的文章对你有所帮助！

[https_www.rabbitmq.com_download.html]: https://www.rabbitmq.com/download.html
[format_png]: /images/20221124/9226730e777840c398375f9d3d9728c4.png
[format_png 1]: /images/20221124/6e71e89f9607457186a76054ce92af36.png
[format_png 2]: /images/20221124/6630aadd4e914bfaae3a78d3dc9e2e92.png
[format_png 3]: /images/20221124/ca4403c564544f31bdcce5353c312033.png
[format_png 4]: /images/20221124/885aba3dfe174632a61ebcc63fb740b4.png
[format_png 5]: /images/20221124/af5976a9be474ab2a12b0be2a5509168.png
[format_png 6]: /images/20221124/2d610a6743aa448fbea4473b74d0177e.png
[format_png 7]: /images/20221124/b0069601e5844bd79161f1434685abaa.png
[format_png 8]: /images/20221124/cd6794645ed84e309e3dcdea3b957896.png
[format_png 9]: /images/20221124/eadeb8bfd53c42718c8cee4918b4b1a7.png
[format_png 10]: /images/20221124/4206f5b2e6ca448d8dc810c52b0beff4.png