1、第一步：创建一个简单springboot项目，引入redis依赖，
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis-reactive</artifactId>
</dependency>
2、第二步：写一个类，并在类里面注入redis，代码如下：
@Autowired
private RedisTemplate<String, Object> redisTemplate;
3、第三步：编写一个异步Timing类，并写一个方法，用于接收redis的list数据，代码如下：
@Component
@Async
public class Timing{
@Async
public void popMsg() throws Exception{
while (true){
long size = redisTemplate.opsForList().size("querys");
if(size != 0){
//绑定操作
BoundListOperations<String, Object> boundValueOperations = redisTemplate.boundListOps("querys");
Object o = boundValueOperations.leftPop();
log.info("消息队列的链接: {}, 当前 长度: {}", o, size);
}
Thread.sleep(1000);
}
}
}
4、第四步：写一个redis存数据的接口，redis数据类型是list，代码如下：
redisTemplate.opsForList().rightPush("querys", value);
5、第五步：写个简简单单的前端页面，用于发送数据，代码如下：
<a href="#" id="x2">发送数据</a>
<script src="lib/jquery-3.4.1/jquery-3.4.1.min.js"></script>
<script>
let i = 0;
$("#x2").click(function () {
$.ajax({
url: 'http://localhost:8081/queryDemo',
type: 'post',
data:{
value: 'i = ' + i++
},
success:function (data) {
}
})
})
</script>
6、第六步：接收数据的接口，代码如下：
@PostMapping("/queryDemo")
String queryDemo(String value){
System.out.println("接收到的数据："+ value);
redisTemplate.opsForList().rightPush("querys", value);
return "ok";
}
7、第七步：启动项目，打开html页面发送数据，可以看到redis里面的数据已经被消费了，如图：
