目录
一. 🦁 前言
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);
}
}
三. 🦁 总结
本文章总结了SpringBoot操作RabbitMQ的各种过程，希望对您有帮助哦！！！咱们下期见！😄
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
文章由半码博客整理，本文链接：https://www.bmabk.com/index.php/post/143131.html