RabbitMQ 是一个开源的消息代理和队列服务器，用来通过插件机制来支持多种消息协议。RabbitMQ 可以用于跨多个系统分发消息，并支持跨网络和跨操作系统的部署。
Spring AMQP 是一个提供消息传递的抽象和高级消息队列协议支持的Spring 框架。Spring AMQP 是Spring 的一个子项目，它集合了 AMQP （高级消息队列协议）和消息传递模式的实现。
在Spring Boot中，我们可以使用Spring AMQP和RabbitMQ来实现消息队列的功能。
以下是一些常见的使用场景：
- 异步处理：用户注册后，发送注册邮件和注册短信，传统的方式是串行方式，比较耗时。使用RabbitMQ，可以把两个操作放在异步队列中，提高系统的响应速度。
- 应用解耦：用户下单后，订单系统需要通知库存系统。传统的方式是库存系统提供接口，订单系统调用接口。使用RabbitMQ，订单系统只需要将消息发送到MQ中，库存系统订阅此消息，就可以在订单系统完全不关心库存系统的情况下完成操作。
- 流量控制：在高并发的情况下，用户的请求量可能会超过系统能处理的最大限度。使用RabbitMQ可以控制请求入库的速度，保证系统不会被压垮。
以下是一个简单的Spring Boot整合RabbitMQ的例子：
- 引入依赖
<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>
- 配置RabbitMQ
spring:
rabbitmq:
host: localhost
port: 5672
username: guest
password: guest
- 创建一个配置类，配置队列、交换器、路由等信息
@Configuration
public class RabbitConfig {
@Bean
Queue queue() {
return new Queue("test_queue", true);
}
@Bean
TopicExchange exchange() {
return new TopicExchange("test_exchange");
}
@Bean
Binding binding(Queue queue, TopicExchange exchange) {
return BindingBuilder.bind(queue).to(exchange).with("test.#");
}
}
- 发送消息
@RestController
public class SendMessageController {
@Autowired
private RabbitTemplate rabbitTemplate;
@GetMapping("/sendMessage")
public void sendMessage() {
rabbitTemplate.convertAndSend("test_exchange", "test.hello", "Hello, RabbitMQ!");
}
}
- 接收消息
@Component
public class ReceiveMessageListener {
@RabbitListener(queues = "test_queue")
public void handleMessage(String message) {
System.out.println("Received Message: " + message);
}
}
在这个例子中，我们创建了一个名为test_queue的队列，一个名为test_exchange的交换器，并将队列与交换器通过路由键test.#绑定。然后，我们创建了一个接收消息的