【RabbitMQ】| Lion带你 (超详细) 从0到1使用SpringBoot操作RabbitMQ

一. 🦁 前言

Spring Boot操作RabbitMQ是一种非常有用的技术，它可以提高应用程序的性能、可靠性和可伸缩性，为开发人员提供更好的开发和维护体验。下面是它的一些优点：

提高应用程序的可靠性和稳定性。RabbitMQ作为一种基于消息传递的中间件，可以将消息传递给应用程序，从而避免了高流量压力下的系统崩溃。
提高应用程序的并发性能。RabbitMQ可以作为一种异步消息传递机制，与Spring Boot配合使用可以提高应用程序的并发性能，实现高性能分布式系统。
实现应用程序的解耦。应用程序与RabbitMQ之间的通信是通过消息队列进行的，从而实现了应用程序的解耦，使得应用程序的开发和维护变得更加容易。
为应用程序提供大规模数据的处理和传输能力。RabbitMQ可以处理大规模数据的传输和处理，使得应用程序可以更加高效地处理大量数据。
提高应用程序的可伸缩性。RabbitMQ可以实现应用程序的水平扩展，从而让应用程序可以扩展到更多的服务器和节点上，以处理更大的数据量。

二. 🦁 SpringBoot操作RabbitMQ

Spring Boot操作RabbitMQ是一种非常有用的技术，它可以提高应用程序的性能、可靠性和可伸缩性，为开发人员提供更好的开发和维护体验。以下是一些优点：

提高应用程序的可靠性和稳定性。RabbitMQ作为一种基于消息传递的中间件，可以将消息传递给应用程序，从而避免了高流量压力下的系统崩溃。
提高应用程序的并发性能。RabbitMQ可以作为一种异步消息传递机制，与Spring Boot配合使用可以提高应用程序的并发性能，实现高性能分布式系统。
实现应用程序的解耦。应用程序与RabbitMQ之间的通信是通过消息队列进行的，从而实现了应用程序的解耦，使得应用程序的开发和维护变得更加容易。
为应用程序提供大规模数据的处理和传输能力。RabbitMQ可以处理大规模数据的传输和处理，使得应用程序可以更加高效地处理大量数据。
提高应用程序的可伸缩性。RabbitMQ可以实现应用程序的水平扩展，从而让应用程序可以扩展到更多的服务器和节点上，以处理更大的数据量。

Ⅰ. 前期准备工作

1. 创建项目（不细说）

2. 添加依赖

<!-- RabbitMQ起步依赖 -->
<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

3. 编写配置文件

spring:
  rabbitmq:
    host: 120.79.50.65
    port: 5672
    username: lion
    password: lion
    virtual-host: /

Ⅱ. 创建队列和交换机

SpringBoot整合RabbitMQ时，需要在配置类创建队列和交换机并且交换机绑定队列，（以创建topic模式为例）写法如下：

import org.springframework.amqp.core.*;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitConfig {
//    交换机名
    private final String EXCHANGE_NAME = "boot_topic_exchange";
//    队列名
    private final String QUEUE_NAME = "boot_queue";


    // 创建交换机
    @Bean("bootExchange")
    public Exchange getExchange() {
        return ExchangeBuilder
                .topicExchange(EXCHANGE_NAME) // 交换机类型
                .durable(true) // 是否持久化
                .build();
    }


    // 创建队列
    @Bean("bootQueue")
    public Queue getMessageQueue() {
        return new Queue(QUEUE_NAME); // 队列名
    }


    // 交换机绑定队列
    @Bean
    public Binding bindMessageQueue(@Qualifier("bootExchange") Exchange exchange, @Qualifier("bootQueue") Queue queue) {
        return BindingBuilder
                .bind(queue)
                .to(exchange)
                .with("#.message.#")
                .noargs();
    }
}

Ⅲ. 创建生产者

@SpringBootTest
class Rabbitmq3ApplicationTests {

   @Autowired
   private RabbitTemplate rabbitTemplate;

   @Test
   void contextLoads() {
      /**
       * 发送消息
       * 参数1：交换机
       * 参数2：路由key
       * 参数3：要发送的消息
       */
      rabbitTemplate.convertAndSend("boot_topic_exchange","message","双十一开始了");
   }

}

Ⅳ. 创建消费者

一般来说，消费者和生产者不会在同一个项目中，所以这里创建另外一个项目来创建消费者，也不需要创建队列和交换机，直接监听队列就行。

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
public class Consumer {
//    监听队列
    @RabbitListener(queues = "boot_queue")
    public void listenMessage(String message){
        System.out.println("接收消息："+message);
    }
}