SpringBoot 整合 RabbitMQ

当我们在构建分布式系统时，消息队列成为了一个不可或缺的组件，用于解耦系统中的不同部分，提高系统的可靠性和可扩展性。Spring Boot 提供了良好的支持，使得与消息队列的集成变得相对简单。在本篇博客中，我们将讨论如何使用 Spring Boot 整合 RabbitMQ，一个功能强大的开源消息代理。

步骤一：准备工作

首先，确保你已经有一个运行 RabbitMQ 的实例。你可以在官方网站 RabbitMQ Download 下载并安装 RabbitMQ。

步骤二：创建 Spring Boot 项目

使用 Spring Initializer 创建一个新的 Spring Boot 项目。选择 Maven 或 Gradle 作为构建工具，添加 “Spring Web” 和 “RabbitMQ” 依赖。

步骤三：配置 RabbitMQ 连接信息

在 application.properties 或 application.yml 文件中，添加 RabbitMQ 的连接信息。

spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

步骤四：创建消息生产者

创建一个简单的消息生产者类，用于发送消息到 RabbitMQ。

importorg.springframework.amqp.core.AmqpTemplate;importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.stereotype.Component;@ComponentpublicclassRabbitMQProducer{@AutowiredprivateAmqpTemplate amqpTemplate;publicvoidsend(String message){
        amqpTemplate.convertAndSend("exchange","routingKey", message);System.out.println("Message sent: "+ message);}}

步骤五：创建消息消费者

创建一个消息消费者类，用于从 RabbitMQ 接收消息。

importorg.springframework.amqp.rabbit.annotation.RabbitListener;importorg.springframework.stereotype.Component;@ComponentpublicclassRabbitMQConsumer{@RabbitListener(queues ="queue")publicvoidreceiveMessage(String message){System.out.println("Message received: "+ message);}}

步骤六：测试消息发送与接收

在你的应用程序中，通过调用消息生产者的 send 方法发送消息，然后消息消费者将监听并处理收到的消息。

@RestControllerpublicclassMyController{@AutowiredprivateRabbitMQProducer rabbitMQProducer;@GetMapping("/send")publicStringsendMessage(){
        rabbitMQProducer.send("Hello, RabbitMQ!");return"Message sent successfully";}}

步骤七：运行项目

运行你的 Spring Boot 项目，并访问 /send 接口，你应该能在控制台看到消息的发送和接收日志。
至此，你已经成功地将 Spring Boot 与 RabbitMQ 集成。这只是一个简单的例子，你可以根据自己的需求扩展和定制。希望这篇博客对你了解 Spring Boot 和 RabbitMQ 的整合有所帮助。