Redis BLMOVE 怎样在队列之间安全转移任务

如果待处理任务在 queue:todo，处理中的任务在 queue:doing，Redis BLMOVE 可以把一个元素从前者弹出并同时压入后者。它把“取出”和“放入”放在同一个列表移动命令里，适合需要阻塞等待新任务的消费者。

官方地址：https://redis.io/docs/latest/commands/blmove/

最小写法是：

# 从待处理列表左侧取出，放到处理中列表右侧；最多等待 5 秒
BLMOVE queue:todo queue:doing LEFT RIGHT 5

返回值是被移动的元素；在有限等待超时且没有元素可取时，客户端会得到空值。理解这两个结果，是避免“任务没转移却被当成成功”的关键。

先把 BLMOVE 的五个参数拆开

命令格式为 BLMOVE source destination timeout。前两个参数是来源列表和目标列表，第三个参数决定从来源哪一端弹出，第四个参数决定压入目标哪一端，最后一个参数是阻塞等待秒数。

例如 LEFT RIGHT 不是“从左到右扫描”，而是“从 source 左端弹出，再把元素压到 destination 右端”。写反其中一个方向，任务顺序就会改变。

按队列场景选择方向组合

把 queue:todo 看成从左到右排列的待处理任务时，常用的先进先出写法是 LEFT RIGHT：从旧任务所在的左端取出，再放到处理中列表右端。若你的列表约定新任务在左端，则应把来源方向改成 RIGHT。

# 先进先出：约定旧任务在 todo 左端，处理中任务追加到 doing 右端
BLMOVE queue:todo queue:doing LEFT RIGHT 5

# 后进先出：从 todo 右端取最新任务，仍追加到 doing 右端
BLMOVE queue:todo queue:doing RIGHT RIGHT 5

目标端方向只影响新元素落在目标列表哪一侧。它不会改变来源列表的其他元素，也不会替你确认任务处理成功；成功处理通常还需要另一个明确的确认或状态更新协议。

timeout 决定空队列时等多久

来源列表暂时为空时，BLMOVE 会等待元素出现。timeout 使用秒，允许小数；设为 0 表示不因超时主动返回，适合由客户端取消或连接生命周期控制的长驻消费者。设为正数则只等待指定时长，超时后返回空值。

# 最多等待 2.5 秒；拿不到任务时按“本轮无任务”处理
BLMOVE queue:todo queue:doing LEFT RIGHT 2.5

# 持续等待；消费者需要自行设计取消连接或退出机制
BLMOVE queue:todo queue:doing LEFT RIGHT 0

不要把空值当作已经搬运了一个空字符串。应用层应区分“收到元素”和“等待超时”，并决定是重试、让出线程、记录指标还是结束本轮轮询。

返回值和列表边界怎么处理

移动成功时，返回被弹出并压入目标列表的元素。若等待超时，返回空值；如果来源列表最后一个元素被移动，来源 key 会被删除。这样做不会删除目标列表，目标列表也可能原本不存在，移动时由 Redis 创建。

# 伪代码示意：注释说明调用方的分支，不依赖具体客户端库
item = BLMOVE(queue:todo, queue:doing, LEFT, RIGHT, 5)
if item == nil {
    # 超时没有拿到任务；不要把它记录成“已进入处理中”
    record_no_task()
} else {
    # item 已经位于目标列表，继续执行处理协议
    handle(item)
}

如果任务内容本身允许为空字符串，客户端还要结合库的返回类型判断“空值”和“空字符串”是否可区分。对关键任务，建议把任务 ID 作为元素，并在业务层保存处理状态、重试次数和最终确认信息。

常见问题

BLMOVE 和 LMOVE 有什么区别？

LMOVE 不等待来源列表，BLMOVE 在来源为空时可以阻塞等待。两者的方向参数语义一致，选择哪一个取决于消费者是否需要等待新元素。

timeout 写成 0 会立即返回吗？

不会。Redis 文档把 0 定义为无限等待；如果客户端不希望长时间占用连接，应使用有限 timeout 或由客户端取消控制。

来源列表被删了，任务是不是丢失了？

来源列表最后一个元素被移动后 key 被删除是正常结果。任务是否完成不能只看来源 key 是否存在，应看 BLMOVE 返回值以及后续处理状态。

小结：先确认任务在来源列表哪一端，再分别选择弹出方向和压入方向；用有限 timeout 处理暂时无任务，用返回元素与空值区分成功转移和等待超时。这样 BLMOVE 才能稳定承担“待处理→处理中”的列表移动职责。