RabbitMQ 是一个开源的消息代理和队列服务器，用来通过封装复杂的分布式技术提供简单的消息队列功能。在 Spring Boot 应用中整合 RabbitMQ，可以使用 Spring AMQP 和 Spring Boot 的自动配置。
以下是一个简单的 Spring Boot 应用整合 RabbitMQ 的示例：
- 添加依赖到
pom.xml：
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
</dependencies>
- 配置
application.properties：
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
- 创建配置类
RabbitMQConfig.java：
@Configuration
public class RabbitMQConfig {
@Bean
Queue queue() {
return new Queue("testQueue", true);
}
@Bean
DirectExchange exchange() {
return new DirectExchange("testExchange");
}
@Bean
Binding binding(Queue queue, DirectExchange exchange) {
return BindingBuilder.bind(queue).to(exchange).with("testRoutingKey");
}
}
- 发送消息的服务
RabbitMQSender.java：
@Service
public class RabbitMQSender {
@Autowired
private RabbitTemplate rabbitTemplate;
public void send(String message) {
rabbitTemplate.convertAndSend("testExchange", "testRoutingKey", message);
}
}
- 接收消息的服务
RabbitMQReceiver.java：
@Component
@RabbitListener(queues = "testQueue")
public class RabbitMQReceiver {
@RabbitHandler
public void receive(String message) {
System.out.println("Received <" + message + ">");
}
}
- 启动类
Application.java：
@SpringBootApplication
public class Application {
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
}
- 使用发送服务发送消息：
@Autowired
private RabbitMQSender sender;
public void sendMessage() {
sender.send("Hello, RabbitMQ!");
}
当你运行这个应用并调用 sendMessage() 方法时，它会通过 RabbitMQ 发送消息到名为 "testQueue" 的队列，并且 RabbitMQReceiver 会接收到消息并打印出来。
以上是一个简单的 RabbitMQ 与 Spring Boot 整合的示例，实际应用中可能需要更复杂的配置和逻辑，但基本概念是一致的。