redis用list做消息队列

leftPush消息入队，rightPop对应，消息出队。
rightPop(RedisConstant.MQ_LIST, 0L, TimeUnit.SECONDS)阻塞出队，0表示永久阻塞

生产消息服务

@Service
public class RedisService {@Autowiredprivate RedisTemplate<String, String> redisTemplate;public Object publish() {OrderDTO dto = new OrderDTO();dto.setId(1);dto.setCreateTime(new Date());dto.setMoney("12.34");dto.setOrderNo("orderNo1");String s = JSON.toJSONString(dto);ListOperations<String, String> listOperations = redisTemplate.opsForList();//leftPush和rightPop对应，左边入队，右边出队listOperations.leftPush(RedisConstant.MQ_LIST, s);//因为出队是阻塞读取的，所以上一步入队后，数据立刻就被驱走了，下一步size=0Long size = listOperations.size(RedisConstant.MQ_LIST);List<String> list = new ArrayList<>();if (size != null && size > 0) {list = listOperations.range(RedisConstant.MQ_LIST, 0, size - 1);}return list;}
}

测试

@RestController
@RequestMapping("redisList")
public class RedisListController {@Autowiredprivate RedisService redisService;@GetMapping("publish")public Object publish() {return redisService.publish();}
}

消费消息服务，定时任务

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

日志

@Component
@Aspect
public class TaskLockAop {@Autowiredprivate RedisLockRegistry redisLockRegistry;@Around("execution(@TaskLock * * (..))")public Object taskAround(ProceedingJoinPoint pjp) throws Throwable {TaskLock taskAnnotation = ((MethodSignature)pjp.getSignature()).getMethod().getAnnotation(TaskLock.class);String lockKey = taskAnnotation.value();Lock lock = redisLockRegistry.obtain(lockKey);try {lock.tryLock(30L, TimeUnit.SECONDS);System.out.println("任务开始, " + lockKey + ", " + new Date());return pjp.proceed();} finally {lock.unlock();System.out.println("任务结束, " + lockKey + ", " + new Date());}}}

测试

http://localhost:9040/redisList/publish

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

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

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

关联项目https://github.com/mingwulipo/cloud-demo.git

redis用list做消息队列相关推荐

使用Redis Stream来做消息队列和在Asp.Net Core中的实现
Redis - Wikipedia 写在前面我一直以来使用redis的时候,很多低烈度需求(并发要求不是很高)需要用到消息队列的时候,在项目本身已经使用了Redis的情况下都想直接用Redis来做消 ...
php redis查看队列长度,php redis做消息队列解决流量削峰常用的5个指令
线上的秒杀等业务场景,需要类似的解决方案,需要平安度过同时抢购带来的流量峰值的问题.如果此时还用mysql做消息队列是什么容易挂掉的,如果死轻量级的秒杀我们完全可以用redis来应对. 削峰从本质上来 ...
使用redis做消息队列mq的总结
总结目前使用redis做消息队列的的方式有3中,list, publish/subscribe, stream list做mq的总结使用方法 1. 生产者可以 lpush 写 ...
redis 怎么做消息队列适合的场景
redis也可以作为消息队列来使用,而且具备搭建简单,使用简易快捷的特点适合的场景: 1.数据场景简单且单一 2.对数据的丢失是有容忍度的 3.对消费数据的正确消费是有容忍度的目前实现redis消 ...
Redis 使用 List 实现消息队列的利与弊
作者 | 码哥字节来源 | 码哥字节分布式系统中必备的一个中间件就是消息队列,通过消息队列我们能对服务间进行异步解耦.流量消峰.实现最终一致性. 目前市面上已经有 RabbitMQ.RochetM ...
java redis延迟队列_基于redis实现的延迟消息队列
delay-queue redis实现延迟消息队列需求背景最近在做一个排队取号的系统在用户预约时间到达前XX分钟发短信通知在用户预约时间结束时要判断用户是否去取号了,不然就记录为爽约在用户取 ...
Pyspider 使用带认证redis集群作为消息队列
文章目录概述 pyspider message_queue 源码解读 pyspider的message_queue的配置文件使用redis集群时的配置文件使用redis单点,带认证时的messa ...
RabbitMQ,Apache的ActiveMQ,阿里RocketMQ,Kafka,ZeroMQ,MetaMQ,Redis也可实现消息队列，RabbitMQ的应用场景以及基本原理介绍，RabbitMQ
RabbitMQ,Apache的ActiveMQ,阿里RocketMQ,Kafka,ZeroMQ,MetaMQ,Redis也可实现消息队列,RabbitMQ的应用场景以及基本原理介绍,RabbitMQ ...
14. Redis 发布订阅-实现消息队列
Redis 除了做缓存, 也可以做消息队列, 实现简单的消息的发布和订阅.Redis 消息订阅支持精确订阅和模糊订阅两种模式! 1. Redis 消息队列 1.1 Redis 消息队列特点当有新消息 ...

redis用list做消息队列

生产消息服务

消费消息服务，定时任务

日志

测试

redis用list做消息队列相关推荐

最新文章

热门文章