RabbitMq整合Springboot超全实战案例+图文演示+源码自取_rabbitmq springboot 实战

RabbitMQ 是一个开源的消息代理和队列服务器，用来通过插件机制来支持多种消息协议。RabbitMQ 可以用于跨多个系统分发消息，并支持跨网络和跨操作系统的部署。

Spring AMQP 是一个提供消息传递的抽象和高级消息队列协议支持的Spring 框架。Spring AMQP 是Spring 的一个子项目，它集合了 AMQP （高级消息队列协议）和消息传递模式的实现。

在Spring Boot中，我们可以使用Spring AMQP和RabbitMQ来实现消息队列的功能。

以下是一些常见的使用场景：

1. 异步处理：用户注册后，发送注册邮件和注册短信，传统的方式是串行方式，比较耗时。使用RabbitMQ，可以把两个操作放在异步队列中，提高系统的响应速度。
2. 应用解耦：用户下单后，订单系统需要通知库存系统。传统的方式是库存系统提供接口，订单系统调用接口。使用RabbitMQ，订单系统只需要将消息发送到MQ中，库存系统订阅此消息，就可以在订单系统完全不关心库存系统的情况下完成操作。
3. 流量控制：在高并发的情况下，用户的请求量可能会超过系统能处理的最大限度。使用RabbitMQ可以控制请求入库的速度，保证系统不会被压垮。

以下是一个简单的Spring Boot整合RabbitMQ的例子：

1. 引入依赖

<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>

2. 配置RabbitMQ

spring:
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest

3. 创建一个配置类，配置队列、交换器、路由等信息

@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.#");
    }
}

4. 发送消息

@RestController
public class SendMessageController {
 
    @Autowired
    private RabbitTemplate rabbitTemplate;
 
    @GetMapping("/sendMessage")
    public void sendMessage() {
        rabbitTemplate.convertAndSend("test_exchange", "test.hello", "Hello, RabbitMQ!");
    }
}

5. 接收消息

@Component
public class ReceiveMessageListener {
 
    @RabbitListener(queues = "test_queue")
    public void handleMessage(String message) {
        System.out.println("Received Message: " + message);
    }
}

在这个例子中，我们创建了一个名为test_queue的队列，一个名为test_exchange的交换器，并将队列与交换器通过路由键test.#绑定。然后，我们创建了一个接收消息的