消费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 队列实现不重复消费的思路。经过以上操作，消息在有限时间内只会被消费一次，有效地完成了实现不重复消费的需求。