一. 前言
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;
@Configurationpublic 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(); }}
复制代码
Ⅲ. 创建生产者
@SpringBootTestclass 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;
@Componentpublic class Consumer {// 监听队列 @RabbitListener(queues = "boot_queue") public void listenMessage(String message){ System.out.println("接收消息："+message); }}
复制代码
三. 总结
本文章总结了 SpringBoot 操作 RabbitMQ 的各种过程，希望对您有帮助哦！！！咱们下期见！
评论