SpringBoot使用Rabbit详解含完整代码

1. 摘要

本文将详细介绍如何在Spring Boot应用程序中集成和使用RabbitMQ消息队列。RabbitMQ是一个开源的消息代理和队列服务器，用于通过轻量级和可靠的消息在应用程序或系统之间进行异步通信。本文将通过步骤说明、代码示例和详细注释，指导读者在Spring Boot项目中配置RabbitMQ，并演示如何发送和接收消息。

RabbitMQ基础知识详解《RabbitMQ详解（值得珍藏）》

2. 使用步骤 2.1 添加依赖

首先，在Spring Boot项目的pom.xml文件中添加RabbitMQ的依赖。

<dependencies> <!-- Spring Boot RabbitMQ Starter --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency> <!-- 其他依赖... --> </dependencies> 2.2 配置RabbitMQ

在application.properties或application.yml文件中配置RabbitMQ的连接信息。

application.properties 示例:

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

或者，如果你使用application.yml，则配置如下：

spring: rabbitmq: host: localhost port: 5672 username: guest password: guest 2.3 创建消息发送者

接下来，我们将创建一个消息发送者，使用RabbitTemplate来发送消息。

import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; @Component public class MessageSender { @Autowired private RabbitTemplate rabbitTemplate; // 发送消息到名为"hello"的队列 public void send(String message) { rabbitTemplate.convertAndSend("hello", message); } } 2.4 创建消息接收者

现在，我们需要创建一个消息接收者，使用@RabbitListener注解来监听队列。

import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.stereotype.Component; @Component public class MessageReceiver { // 监听名为"hello"的队列 @RabbitListener(queues = "hello") public void receive(String message) { System.out.println("Received Message: " + message); } } 2.5 在应用程序中使用发送者和接收者

最后，在你的Spring Boot应用程序中，你可以使用上面创建的MessageSender和MessageReceiver类来发送和接收消息。

import org.springframework.boot.CommandLineRunner; import org.springframework.stereotype.Component; @Component public class MyAppRunner implements CommandLineRunner { private final MessageSender messageSender; public MyAppRunner(MessageSender messageSender) { this.messageSender = messageSender; } @Override public void run(String... args) throws Exception { // 当应用程序启动时，发送一条消息 messageSender.send("Hello, RabbitMQ!"); } } 3. 总结

本文介绍了如何在Spring Boot应用程序中集成RabbitMQ消息队列，并通过简单的示例演示了发送和接收消息的过程。RabbitMQ的集成使得应用程序能够处理异步消息，提高了系统的可伸缩性和可靠性。通过使用Spring Boot提供的RabbitMQ Starter，我们可以快速轻松地配置和使用RabbitMQ，而无需编写大量繁琐的配置代码。在实际生产环境中，你还可以进一步探索RabbitMQ的更多特性，如交换器、路由键、消息确认和持久化等。