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

目录

一. 🦁 前言

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

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

二. 🦁 SpringBoot操作RabbitMQ

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

1. 提高应用程序的可靠性和稳定性。RabbitMQ作为一种基于消息传递的中间件，可以将消息传递给应用程序，从而避免了高流量压力下的系统崩溃。
2. 提高应用程序的并发性能。RabbitMQ可以作为一种异步消息传递机制，与Spring Boot配合使用可以提高应用程序的并发性能，实现高性能分布式系统。
3. 实现应用程序的解耦。应用程序与RabbitMQ之间的通信是通过消息队列进行的，从而实现了应用程序的解耦，使得应用程序的开发和维护变得更加容易。
4. 为应用程序提供大规模数据的处理和传输能力。RabbitMQ可以处理大规模数据的传输和处理，使得应用程序可以更加高效地处理大量数据。
5. 提高应用程序的可伸缩性。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:5672username: lion
    password: lion
    virtual-host: /

Ⅱ. 创建队列和交换机

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

importorg.springframework.amqp.core.*;importorg.springframework.beans.factory.annotation.Qualifier;importorg.springframework.context.annotation.Bean;importorg.springframework.context.annotation.Configuration;@ConfigurationpublicclassRabbitConfig{//    交换机名privatefinalString EXCHANGE_NAME ="boot_topic_exchange";//    队列名privatefinalString QUEUE_NAME ="boot_queue";// 创建交换机@Bean("bootExchange")publicExchangegetExchange(){returnExchangeBuilder.topicExchange(EXCHANGE_NAME)// 交换机类型.durable(true)// 是否持久化.build();}// 创建队列@Bean("bootQueue")publicQueuegetMessageQueue(){returnnewQueue(QUEUE_NAME);// 队列名}// 交换机绑定队列@BeanpublicBindingbindMessageQueue(@Qualifier("bootExchange")Exchange exchange,@Qualifier("bootQueue")Queue queue){returnBindingBuilder.bind(queue).to(exchange).with("#.message.#").noargs();}}

Ⅲ. 创建生产者

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

Ⅳ. 创建消费者

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

importorg.springframework.amqp.rabbit.annotation.RabbitListener;importorg.springframework.stereotype.Component;@ComponentpublicclassConsumer{//    监听队列@RabbitListener(queues ="boot_queue")publicvoidlistenMessage(String message){System.out.println("接收消息："+message);}}

三. 🦁 总结

本文章总结了SpringBoot操作RabbitMQ的各种过程，希望对您有帮助哦！！！咱们下期见！😄