Springboot整合RabbitMQ消息中间件的使用
1、RabbitMQ概述
RabbitMQ是shiyongERLANG语言编写的，实现了高级消息队列协议(AMQP)的开源消息代理软件（亦称面向消息的中间件）。
常见的消息中间件：KAFKA、RabbitMQ、ActiveMQ、RocketMQ(可以处理分布式事务)
1.1、什么是RabbitMQ?
【1、通过案例理解RabbitMQ】
你想和远方的好友实现通信，这个时候你给好友写封信，我们将写好的信封装成一个信封，将信放到邮箱中，邮差就会在规定的时间将这封信送到远方好友的手中。
寄件人是A系统，远方好友是B系统，RabbitMQ就是邮箱，邮差就是信道。A系统和B系统可以通过RabbitMQ实现通信。
【2、为什么要使用RabbitMQ? 】
1、RabbitMQ实现了AMQP标准的消息服务器
2、可靠性，RabbitMQ的持久化支持，保证了消息的稳定性；
3、RabbitMQ使用了Erlang开发语言，高并发、高可用、集群部署简单等特性；
【3、RabbitMQ能做什么？】
1、业务解耦：下订单、扣减库存、生成订单、发红包、发短信、异步操作、日志处理、跨平台通信等。
2、流量消峰：控制请求量。
3、路由灵活：RabbitMQ有丰富的Exchange(交换器)，通过关键字Routingkey判断消息的具体队列(Queue)。
1.2、RabbitMQ消息发送原理
1、生产者生产消息，发送给服务器端的Exchange交换器。
2、Exchange收到消息，根据用户发送的RoutingKey，将消息转发给匹配的Queue1或Queue2。
3、Queue1或Queue2收到消息后，将消息发送给订阅者(消费者1或消费者2)。
4、消费者收到消息，发送ACK给队列确认收到消息。
5、消费者收到ACK确认消息，然后删除队列中缓存的对应消息。
1.3、RabbitMQ在项目中的应用
A系统和B系统之间如果不是使用同一架构或者语言编写的，这个时候可以通过RabbitMQ进行通信。
如A系统可以发送JSON类型的数据，B系统获取数据的时候可以解析JSON,达到跨系统交互。
2、Springboot整合RabbitMQ
2.1、配置工程包信息
核心包：spring-cloud-starter-bus-amqp
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.7.17</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>com.txc</groupId>
<artifactId>springbootrabbitmqdemo</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>springbootrabbitmqdemo</name>
<description>springbootrabbitmqdemo</description>
<properties>
<java.version>1.8</java.version>
</properties>
<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>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework.amqp</groupId>
<artifactId>spring-rabbit-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<configuration>
<excludes>
<exclude>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</exclude>
</excludes>
</configuration>
</plugin>
</plugins>
</build>
</project>
2.2、在application.yml文件中配置连接信息
spring:
rabbitmq:
addresses: localhost #IP地址
username: guest #用户名
password: guest #密码
dynamic: true #默认创建一个AmqpAdmin的Bean 默认:true2.3、在工程中创建RabbitMQ消息接收程序
@RabbitListener(queuesToDeclare = @Queue("myQueue "))作用：
1、让监听关联到myQueue队列中
2、queuesToDeclare能够实现当myQueue队列不存在的时候，自动创建
3、queuesToDeclare：后面的参数需要的是数组类型使用@Queue创建
@Configuration
public class RabbitMQReceive {
@RabbitListener(queuesToDeclare = @Queue("myQueue"))
public void process(String message){
System.out.println("======消费消息====="+message);
}
}
2.4、在工程中创建RabbitMQ消息发送程序
创建控制层，模拟向RabbitMQ消息中间件发送消息。
通过convertAndSend向RabbitMQ发送消息。
@Controller
public class TestRabbitMQController {
@Resource
private AmqpTemplate amqpTemplate;
@RequestMapping("/sendMessageToQueue")
@ResponseBody
public void sendMessageToQueue(){
amqpTemplate.convertAndSend("myQueue","{'code':'200','msg':'你想发的消息。'}");
}
}
2.5、测试结果
访问地址：http://localhost:8080/sendMessageToQueue
3、创建Exchange(交换器)绑定Queue
3.1、Exchange交换器的使用场景
我们要实现如果是华为的订单就发送到huaweiQueue队列中，如果是联想的订单就发送到lenovoQueue队列中。
主要就是通过RoutingKey(huaweiKey、lenovoKey)来实现。
3.2、在工程中创建RabbitMQ接收器
通过@RabbitListener实现创建huaweiQueue队列和computerExchange交换器，并通过huaweiKey实现队列和交换器绑定。
在不指定交换器类型的情况下，默认的交换器类型是direct
@RabbitListener(bindings = @QueueBinding(
exchange = @Exchange("computerExchange"),
key = "huaweiKey",
value = @Queue("huaweiQueue")
))
public void process1(String message){
System.out.println("======消费消息====="+message);
}
3.3、在工程中创建RabbitmQ消息发送程序
convertAndSend参数说明：convertAndSend(“交换器名称”,”绑定key”,”需要发送的消息”);
@RequestMapping("/sendMessageToExchange")
@ResponseBody
public void sendMessageToExchange(){
amqpTemplate.convertAndSend("computerExchange","huaweiKey","{'code':'200','msg':'测试Exchange和Queue绑定'}");
}
3.4、测试结果
访问地址：http://localhost:8080/sendMessageToExchange
到此这篇关于Springboot整合RabbitMQ消息中间件的使用的文章就介绍到这了,更多相关Springboot RabbitMQ消息中间件内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
这篇文章主要为大家详细介绍了SQL注入漏洞的原理,表现形式以及如何防范这种攻击,文中的示例代码讲解详细,希望可以帮助开发者构建更安全的Java应用2025-05-05
这篇文章主要介绍了通过实例了解JavaBean开发及使用过程解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2020-08-08
这篇文章主要介绍了解读@RabbitListener起作用的原理，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2023-03-03
这篇文章主要介绍了Java中Set是不是无序的问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2023-07-07
这篇文章主要介绍了SpringCloud的Eureka模块详解,Spring Cloud 封装了 Netflix 公司开发的 Eureka 模块来实现服务治理,就是提供了微服务架构中各微服务实例的快速上线或下线且保持各服务能正常通信的能力的方案总称,需要的朋友可以参考下2023-07-07
SpringBoot中Tomcat和SpringMVC整合源码分析
Tomcat和SpringMVC都是通过这样的方式进行集成的，SpringBoot出现之前SpringMVC项目是直接部署在Tomcat服务器中的，这篇文章主要介绍了SpringBoot中Tomcat和SpringMVC整合源码分析,需要的朋友可以参考下2022-07-07
这篇文章主要给大家介绍了关于Java强制类型转换原理(父类转子类、子类转父类)的相关资料,所谓的强制类型转换,其实是自动类型转换的逆过程,在数据类型兼容的情况下,将容量大的数据类型转换为容量小的数据类型,需要的朋友可以参考下2023-12-12
这篇文章主要介绍了java根据扩展名获取系统图标和文件图标示例,需要的朋友可以参考下2014-03-03
详解java.lang.reflect.Modifier.isInterface()方法
这篇文章主要介绍了详解java.lang.reflect.Modifier.isInterface()方法的相关资料,这里提供实例帮助大家理解这个方法的使用，需要的朋友可以参考下2017-09-09
这篇文章主要给大家总结介绍了关于Java实现多数据源的几种方式,最近项目中的工作流需要查询多个数据源的数据,数据源可能是不同种类的,需要的朋友可以参考下2023-08-08
最新评论