众所周知，redis是一个高性能的key-value数据库，在NoSQL数据库市场上，redis自己就占据了将近半壁江山，足以见到其强大之处。同时，由于redis的单线程特性，我们可以将其用作为一个消息队列。本篇文章就来讲讲如何将redis整合到spring boot中，并用作消息队列的……

一、什么是消息队列

“消息队列”是在消息的传输过程中保存消息的容器。——《百度百科》

消息我们可以理解为在计算机中或在整个计算机网络中传递的数据。

队列是我们在学习数据结构的时候学习的基本数据结构之一，它具有先进先出的特性。

所以，消息队列就是一个保存消息的容器，它具有先进先出的特性。

为什么会出现消息队列？

异步：常见的B/S架构下，客户端向服务器发送请求，但是服务器处理这个消息需要花费的时间很长的时间，如果客户端一直等待服务器处理完消息，会造成客户端的系统资源浪费；而使用消息队列后，服务器直接将消息推送到消息队列中，由专门的处理消息程序处理消息，这样客户端就不必花费大量时间等待服务器的响应了；
解耦：传统的软件开发模式，模块之间的调用是直接调用，这样的系统很不利于系统的扩展，同时，模块之间的相互调用，数据之间的共享问题也很大，每个模块都要时时刻刻考虑其他模块会不会挂了；使用消息队列以后，模块之间不直接调用，而是通过数据，且当某个模块挂了以后，数据仍旧会保存在消息队列中。最典型的就是生产者-消费者模式，本案例使用的就是该模式；
削峰填谷：某一时刻，系统的并发请求暴增，远远超过了系统的最大处理能力后，如果不做任何处理，系统会崩溃；使用消息队列以后，服务器把请求推送到消息队列中，由专门的处理消息程序以合理的速度消费消息，降低服务器的压力。

下面一张图我们来简单了解一下消息队列

由上图可以看到，消息队列充当了一个中间人的角色，我们可以通过操作这个消息队列来保证我们的系统稳定。

二、环境准备

Java环境：jdk1.8
spring boot版本：2.2.1.RELEASE
redis-server版本：3.2.100

三、相关依赖

这里只展示与redis相关的依赖，

<dependency>     <groupId>org.springframework.boot</groupId>     <artifactId>spring-boot-starter-data-redis</artifactId> </dependency> <dependency>     <groupId>org.springframework.integration</groupId>     <artifactId>spring-integration-redis</artifactId> </dependency>

这里解释一下这两个依赖：

第一个依赖是对redis NoSQL的支持
第二个依赖是spring integration与redis的结合，这里添加这个代码主要是为了实现分布式锁

四、配置文件

这里只展示与redis相关的配置

# redis所在的的地址 spring.redis.host=localhost # redis数据库索引，从0开始，可以从redis的可视化客户端查看 spring.redis.database=1 # redis的端口，默认为6379 spring.redis.port=6379 # redis的密码 spring.redis.password= # 连接redis的超时时间(ms)，默认是2000 spring.redis.timeout=5000 # 连接池最大连接数 spring.redis.jedis.pool.max-active=16 # 连接池最小空闲连接 spring.redis.jedis.pool.min-idle=0 # 连接池最大空闲连接 spring.redis.jedis.pool.max-idle=16 # 连接池最大阻塞等待时间（负数表示没有限制） spring.redis.jedis.pool.max-wait=-1 # 连接redis的客户端名 spring.redis.client-name=mall

五、代码配置

redis用作消息队列，其在spring boot中的主要表现为一个RedisTemplate.convertAndSend()方法和一个MessageListener接口。所以我们要在IOC容器中注入一个RedisTemplate和一个实现了MessageListener接口的类。话不多说，先看代码

配置RedisTemplate

配置RedisTemplate的主要目的是配置序列化方式以解决乱码问题，同时合理配置序列化方式还能降低一点性能开销。

什么鬼，面试官竟然让我用Redis实现一个消息队列！！？