消费Redis利用队列实现不重复消费（redis队列不重复）

思路：

Redis除了有专用的记录存储以外，还可以担任消息队列的角色，消费者可以通过一些操作来实现不重复消费。

对于普通的消息队列，有两种不重复消费的方法，分别是发布 / 订阅模式和拉取 / 确认模式，但 Redis 不支持这两种方式，它更适合必须在一个窗口中执行的短暂任务。

那么，我们如何使用 Redis 实现不重复消费呢？可以使用Redis LIST 功能，在LIST中存储已消费和待消费的消息，以及根据情况在有限时间内让消息不被重复消费，比如如下代码：

// 首先将未消费的消息存储到 Redis
// 将待消费的消息存放到Redis List队列中
List MSGList = new LinkedList();
// 设置消息有效期1小时
Long timeout = 3600L;
for(String msg:wtingMessage){
    // 将消息放入队列 
    msgList.add(msg);
    // 并设置超时时间
    redisTemplate.expire(msg,timeout,TimeUnit.SECONDS);
}
redisTemplate.opsForList().rightPushAll(KEY,msgList);

接下来，我们可以使用Redis的BLPOP方法来实现不重复消费，将从队列中获取消息并在短时间内执行，如下代码所示：

// 从队列中获取消息 
String msg = redisTemplate.opsForList().rightPop(KEY);
// 将消息可用队列中删除
redisTemplate.opsForList().remove(KEY,1,msg);
// 在限时之内，对消息进行消费
consumerMsg(msg);

另外，如果消息消费者没有能在规定的时间内消费完消息，则可以重新将消息放回队列中，如下代码所示：

// 消息消费没有在规定的时间内消费完，则可以重新将消息放回队列中
msgList.add(msg);
// 重新设置消息的超时时间
redisTemplate.expire(msg,timeout, TimeUnit.SECONDS);
//将消息放回队列
redisTemplate.opsForList().rightPushAll(Key, msgList);

以上就是通过 Redis 队列实现不重复消费的思路。经过以上操作，消息在有限时间内只会被消费一次，有效地完成了实现不重复消费的需求。

成都创新互联科技有限公司，经过多年的不懈努力，公司现已经成为一家专业从事IT产品开发和营销公司。广泛应用于计算机网络、设计、SEO优化、关键词排名等多种行业！

文章题目：消费Redis利用队列实现不重复消费（redis队列不重复）
URL分享：http://www.shufengxianlan.com/qtweb/news43/342443.html

网站建设、网络推广公司-创新互联，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 创新互联