本文小编为大家详细介绍“redis中怎么用list做消息队列”，内容详细，步骤清晰，细节处理妥当，希望这篇“redis中怎么用list做消息队列”文章能帮助大家解决疑惑，下面跟着小编的思路慢慢深入，一起来学习新知识吧。

leftPush消息入队，rightPop对应，消息出队。

rightPop(RedisConstant.MQ_LIST, 0L, TimeUnit.SECONDS)阻塞出队，0表示永久阻塞

@ServicepublicclassRedisService{@AutowiredprivateRedisTemplate<String,String>redisTemplate;publicObjectpublish(){OrderDTOdto=newOrderDTO();dto.setId(1);dto.setCreateTime(newDate());dto.setMoney("12.34");dto.setOrderNo("orderNo1");Strings=JSON.toJSONString(dto);ListOperations<String,String>listOperations=redisTemplate.opsForList();//leftPush和rightPop对应，左边入队，右边出队listOperations.leftPush(RedisConstant.MQ_LIST,s);//因为出队是阻塞读取的，所以上一步入队后，数据立刻就被驱走了，下一步size=0Longsize=listOperations.size(RedisConstant.MQ_LIST);List<String>list=newArrayList<>();if(size!=null&&size>0){list=listOperations.range(RedisConstant.MQ_LIST,0,size-1);}returnlist;}}

测试

@RestController@RequestMapping("redisList")publicclassRedisListController{@AutowiredprivateRedisServiceredisService;@GetMapping("publish")publicObjectpublish(){returnredisService.publish();}}消费消息服务，定时任务

@ComponentpublicclassRedisConsumeTask{@AutowiredprivateRedisServiceredisService;@TaskLock(RedisConstant.CONSUME_REDIS_LIST)@Scheduled(cron="0/10****?")publicvoidconsumeMqList(){redisService.consumeMqList();}}@Service@Slf4jpublicclassRedisService{@AutowiredprivateRedisTemplate<String,String>redisTemplate;publicvoidconsumeMqList(){ListOperations<String,String>listOperations=redisTemplate.opsForList();//0时间，表示阻塞永久//待机一小时后，再次发消息，消费不了了，阻塞有问题啊。还得轮寻啊//Strings=listOperations.rightPop(RedisConstant.MQ_LIST,0L,TimeUnit.SECONDS);Strings=listOperations.rightPop(RedisConstant.MQ_LIST);if(s==null){return;}log.info("{}={}",RedisConstant.MQ_LIST,s);OrderDTOdto=JSON.parseObject(s,OrderDTO.class);log.info("dto={}",dto);}}日志

@Component@AspectpublicclassTaskLockAop{@AutowiredprivateRedisLockRegistryredisLockRegistry;@Around("execution(@TaskLock**(..))")publicObjecttaskAround(ProceedingJoinPointpjp)throwsThrowable{TaskLocktaskAnnotation=((MethodSignature)pjp.getSignature()).getMethod().getAnnotation(TaskLock.class);StringlockKey=taskAnnotation.value();Locklock=redisLockRegistry.obtain(lockKey);try{lock.tryLock(30L,TimeUnit.SECONDS);System.out.println("任务开始,"+lockKey+","+newDate());returnpjp.proceed();}finally{lock.unlock();System.out.println("任务结束,"+lockKey+","+newDate());}}}测试

http://localhost:9040/redisList/publish

["{“createTime”:1574394538430,“id”:1,“money”:“12.34”,“orderNo”:“orderNo1”}"]

下面一直阻塞，任务开始了，不收到消息，永远不会结束。
阻塞有问题，改用轮询了。

先启动发送消息服务，发送消息。后启动消费消息服务，可以消费消息。这一点，比发布订阅要稳定。

读到这里，这篇“redis中怎么用list做消息队列”文章已经介绍完毕，想要掌握这篇文章的知识点还需要大家自己动手实践使用过才能领会，如果想了解更多相关内容的文章，欢迎关注亿速云行业资讯频道。