1、第一步：创建一个简单springboot项目，引入redis依赖，<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis-reactive</artifactId></dependency>
2、第二步：写一个类，并在类里面注入redis，代码如下：@Autowiredprivate RedisTemplate<String, Object> redisTemplate;
3、第三步：编写一个异步Timing类，并写一个方法，用于接收redis的list数据，代码如下：@Component@Asyncpublic class Timing{@Asyncpublic 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里面的数据已经被消费了，如图：
