如何在Spring Boot中使用Redis的List结构实现阻塞任务队列-Redis-PHP中文网

不能直接用 lpush + brpop 是因为 spring data redis 的 rightpop 超时返回 null 未处理会导致消费者假死，且默认不支持阻塞操作的自动重试、连接保活及多 key 的 blpop，需手动实现重试循环、心跳检测、连接管理及死信隔离。

如何在spring boot中使用redis的list结构实现阻塞任务队列

为什么不能直接用 `LPUSH` + `BRPOP` 就完事？

很多同学一上来就写 redisTemplate.opsForList().leftPush("queue", task) 和 redisTemplate.opsForList().rightPop("queue", 5, TimeUnit.SECONDS)，结果发现消费者经常“假死”——任务明明进了队列，但一直没被取走。根本原因是：Spring Data Redis 的 rightPop（对应 BRPOP）在超时后返回 null，而你没处理这个边界，循环直接退出或抛异常了。

更隐蔽的问题是：如果多个消费者同时监听同一个 key，BRPOP 是公平分发的，但 Spring 的 RedisTemplate 默认不支持阻塞操作的自动重试和连接保活，网络抖动或 Redis 临时不可用会导致整个消费线程静默终止。

必须手动包装成带重试的 while 循环，且每次调用前检查连接状态
BRPOP 超时返回 null 是正常行为，不是错误，别 throw RuntimeException
不要在 @PostConstruct 里直接启线程跑阻塞消费，得交给 TaskExecutor 管理生命周期

怎么用 `RedisConnectionFactory` 获取原生命令支持 `BLPOP`？

Spring Data Redis 2.6+ 的 RedisTemplate 对阻塞操作封装较弱，尤其不支持多 key 的 BLPOP（用于优先级队列场景）。这时候得绕过模板，直连连接工厂。

关键不是“能不能”，而是“要不要”。如果你只需要单队列、无优先级、不关心原子性跨 key 操作，用 redisTemplate.opsForList().rightPop(...) 完全够用；但一旦要 BLPOP queue:high queue:low 0 这种多 key 阻塞，就必须用原生连接：

String[] keys = {"queue:high", "queue:low"};
Long timeoutSec = 0L;
RedisConnection conn = connectionFactory.getConnection();
try {
    List<byte> result = conn.bLPop(timeoutSec, keys);
    if (result != null && result.size() == 2) {
        String queueName = new String(result.get(0));
        String payload = new String(result.get(1));
        // 处理任务
    }
} finally {
    conn.close(); // 必须 close，否则连接泄漏
}</byte>