redis用zset做延时消息

把执行时间作为分数，存到zset中。
定时任务，分数倒序取出第一个，小于当前时间，说明消息可以执行了

发送延时消息服务

public Object publishDelayedMsg() {OrderDTO dto = new OrderDTO();dto.setId(1);dto.setCreateTime(new Date());dto.setMoney("12.34");dto.setOrderNo("orderNo1");String s = JSON.toJSONString(dto);long executeTime = System.currentTimeMillis() + 60000L;ZSetOperations<String, String> zSetOperations = redisTemplate.opsForZSet();zSetOperations.add(RedisConstant.MQ_ZSET, s, executeTime);Long size = zSetOperations.size(RedisConstant.MQ_ZSET);Set<String> set = new HashSet<>();if (size != null && size > 0) {set = zSetOperations.range(RedisConstant.MQ_ZSET, 0, size - 1);}return set;}

controller

    //http://localhost:9040/redisZset/publishDelayedMsg@GetMapping("publishDelayedMsg")public Object publishDelayedMsg() {return redisService.publishDelayedMsg();}

消费消息服务

定时任务

    @TaskLock(RedisConstant.CONSUME_REDIS_ZSET_TASK)@Scheduled(cron = "0/10 * * * * ?")public void consumeMqZset() {redisService.consumeMqZset();}

消费消息

public void consumeMqZset() {ZSetOperations<String, String> zSetOperations = redisTemplate.opsForZSet();Set<ZSetOperations.TypedTuple<String>> typedTuples = zSetOperations.reverseRangeByScoreWithScores(RedisConstant.MQ_ZSET, 0, System.currentTimeMillis(), 0, 1);if (typedTuples == null || typedTuples.isEmpty()) {return;}ZSetOperations.TypedTuple<String> typedTuple = typedTuples.iterator().next();Double score = typedTuple.getScore();if (score == null) {return;}long l = score.longValue();if (l > System.currentTimeMillis()) {return;}String value = typedTuple.getValue();OrderDTO dto = JSON.parseObject(value, OrderDTO.class);System.out.println(dto);zSetOperations.remove(RedisConstant.MQ_ZSET, value);}

消费完消息后，删除消息

https://github.com/mingwulipo/cloud-demo.git

redis用zset做延时消息相关推荐

rocktmq 消息延时清空_使用Kotlin+RocketMQ实现延时消息的示例代码
一. 延时消息延时消息是指消息被发送以后,并不想让消费者立即拿到消息,而是等待指定时间后,消费者才拿到这个消息进行消费. 使用延时消息的典型场景,例如: 在电商系统中,用户下完订单30分钟内没支付, ...
go bson转换成json_你会不会用Go语言实现redis的延时消息队列
在学习过程中发现redis的zset还可以用来实现轻量级的延时消息队列功能,虽然可靠性还有待提高,但是对于一些对数据可靠性要求不那么高的功能要求完全可以实现.本次主要采用了redis中zset中的za ...
使用Redis Stream来做消息队列和在Asp.Net Core中的实现
Redis - Wikipedia 写在前面我一直以来使用redis的时候,很多低烈度需求(并发要求不是很高)需要用到消息队列的时候,在项目本身已经使用了Redis的情况下都想直接用Redis来做消 ...
rocketmq原理_消息中间件漫谈：RocketMQ延时消息应用及原理剖析
业务背景延时任务是非常普遍的业务场景之一,即系统某一动作触发后,经过一定时间的延时后再触发其他一个或多个动作.以订单系统为例: 下单后10分钟未支付发送支付提醒下单30分钟内未支付订单自动取消业 ...
java开发中常见的延时消息解决方案
前言延时消息(定时消息)指的在分布式异步消息场景下,生产端发送一条消息,希望在指定延时或者指定时间点被消费端消费到,而不是立刻被消费. 延时消息适用的业务场景非常的广泛,在分布式系统环境下,延时消息 ...
延时消息常见实现方案
前言延时消息(定时消息)指的在分布式异步消息场景下,生产端发送一条消息,希望在指定延时或者指定时间点被消费端消费到,而不是立刻被消费. 延时消息适用的业务场景非常的广泛,在分布式系统环境下,延时消息 ...
实现延时消息的6种方案
延时消息(定时消息)指的在分布式异步消息场景下,生产端发送一条消息,希望在指定延时或者指定时间点被消费端消费到,而不是立刻被消费. 延时消息适用的业务场景非常的广泛,在分布式系统环境下,延时消息的功能 ...
Redis、Kafka 和 Pulsar 消息队列对比
点击关注公众号,Java干货及时送达导语 | 市面上有非常多的消息中间件,rabbitMQ.kafka.rocketMQ.pulsar. redis等等,多得令人眼花缭乱.它们到底有什么异同,你应该 ...
Redis、Kafka 和 Pulsar 消息队列对比，写得太好了！
市面上有非常多的消息中间件,rabbitMQ.kafka.rocketMQ.pulsar. redis等等,多得令人眼花缭乱.它们到底有什么异同,你应该选哪个? 本文尝试通过技术演进的方式,以redi ...

redis用zset做延时消息

发送延时消息服务

消费消息服务

redis用zset做延时消息相关推荐

最新文章

热门文章