redis实现阻塞轮训队列

redis实现队列有数据丢失的风险，在一些不要求高可用的需求里，可以在不引入消息队列的情况下，实现轮训队列。

java客户端实现代码

起个轮训线程

@Override
public void run() {
while (true) {
Jedis jedis = RedisUtil.getJedis();
try {
//阻塞队列，1小时没有数据释放连接
List<String> result = jedis.blpop(60 * 60 * 1, Constants.QUERY_REPLENISH_ORDER_KEY);
if (result != null && result.size() > 1) {
String key = result.get(0);
//todo something
}
} catch (Exception e) {
LogUtil.error(e, "realTime replenish order exception");
} finally {
jedis.close();
}
}
}
使用的是blpop指令，第二个参数是队列的key值，只要队列有数据，一直消费。如果没有数据，就阻塞等待数据的到来；第一个参数是等待时间，超过这个等

redis实现阻塞轮训队列相关推荐

redis 消息队列过段时间不能下发_以Redis来谈消息队列
首先我先引入一个大家熟知的观点:Reids可以作为消息队列来使用 redis提供了两种方式来做消息队列,一种是生产者消费者模式,一种是发布订阅模式. 本篇文章将从异步,解耦,分布式,可靠四部分来探 ...
SpringBoot整合Redis实现缓存、队列、广播
[提前声明] 文章由作者:张耀峰结合自己生产中的使用经验整理,最终形成简单易懂的文章写作不易,转载请注明,谢谢! spark代码案例地址: https://github.com/Mydreaman ...
redis stream 实现消息队列
redis stream 实现消息队列 Redis5.0带来了Stream类型.从字面上看是流类型,但其实从功能上看,应该是Redis对消息队列(MQ,Message Queue)的完善实现. 基于r ...
redis list 实现消息队列多线程消费
redis list 实现消息队列多线程消费 redis list 实现消息队列多线程消费 redis list 实现消息队列多线程消费利用redis list 命令: Redis Brpop ...
Redis如何实现消息队列
消息队列的实现方式有很多种,比如有专业的rabbitmq,rocketmq,kafka等,这些mq提供了非常专业的功能实现异步发送,而且这些接入又比较复杂. Redis 利用其专有的数据结构lis ...
基于 Redis Stream 的消息队列
文章目录基于 Redis Stream 的消息队列消息队列相关命令消费者组相关命令如何使用Stream消息队列生产者写入消息 - XADD 消费者读取消息 - XGROUP 创建消费者组 - ...
你知道Redis可以实现延迟队列吗？
作者:_BKing 来源:www.cnblogs.com/xiaowei123/p/13222710.html 最近,又重新学习了下Redis,深深被Redis的魅力所折服,Redis不仅能快还能慢( ...
redis延迟队列实现_灵感来袭，基于Redis的分布式延迟队列（续）
背景上一篇(灵感来袭,基于Redis的分布式延迟队列)讲述了基于Java DelayQueue和Redis实现了分布式延迟队列,这种方案实现比较简单,应用于延迟小,消息量不大的场景是没问题的,毕竟J ...
redis延迟消息队列不准时php,Redis实现延迟消息队列
消息队列是应用中常用的一个技术点,通常我们可以借助消息队列中间件来实现,但是并不是所有的情况下,都需要使用到MQ. 如果只需要实现简单的消息队列,那么借助Redis即可. 如果对消息有着严格的可靠性等 ...

redis实现阻塞轮训队列

redis实现阻塞轮训队列相关推荐

最新文章

热门文章