MySQL NOWAIT 与 SKIP LOCKED 处理并发取件队列

并发消费者从 MySQL 任务表取件时，关键不是把锁等待时间调大，而是先判断业务要“拿不到就换一条”，还是“这条拿不到就立即返回”。前一种用 FOR UPDATE SKIP LOCKED，后一种用 FOR UPDATE NOWAIT。两者都只应放在短事务里，领取成功后尽快提交状态，再把耗时处理移到事务外。

先把取件队列设计成可安全筛选的数据

下面用 InnoDB 表表示待处理任务。status 控制生命周期，available_at 让延迟任务不会提前被取走，主键保证并发更新有明确目标。实际项目还应为筛选条件准备联合索引，减少锁定范围。

CREATE TABLE task_queue (
  id BIGINT PRIMARY KEY,
  status VARCHAR(16) NOT NULL,
  available_at DATETIME NOT NULL,
  payload JSON NOT NULL,
  claimed_at DATETIME NULL,
  KEY idx_ready (status, available_at, id)
) ENGINE=InnoDB;

-- 用固定状态和时间条件缩小候选集，避免无关行被长时间扫描
SELECT id, payload
FROM task_queue
WHERE status = 'ready' AND available_at 

这条语句的目标不是读出全表一致快照，而是在当前事务里找一批可立即领取的行。排序字段要稳定，否则多个消费者虽然都能返回结果，却很难解释任务优先级。

可换任务时优先使用 SKIP LOCKED

队列消费者通常不要求拿到某一个具体的 id，只要能领取一批 ready 任务即可。此时一个消费者锁住任务 101，另一个消费者执行 SKIP LOCKED，会把 101 排除，继续尝试 102、103。领取后应立即把状态从 ready 改成 processing 并提交。

START TRANSACTION;

-- 只锁定本次消费者拿到的行，锁冲突时直接寻找别的任务
SELECT id
FROM task_queue
WHERE status = 'ready' AND available_at 

这里的返回集是“当下没有被其他事务锁住的候选”，不是全局公平队列。长事务、失败重试、优先级饥饿都要在业务层补上，例如为超时的 processing 任务设置回收机制。MySQL 官方也明确提醒，跳过锁的查询会得到不一致视图，不适合普通事务查询，但可用于队列表。

必须拿到目标行时用 NOWAIT

如果业务已经选定某个任务，或者需要快速判断它是否正在被其他消费者处理，就不应该悄悄换一条。NOWAIT 会在行锁不可得时立即返回错误，应用可将它映射为“稍后重试”或“任务已被占用”，而不是让请求线程排队。

START TRANSACTION;

-- 指定任务不能被替换；锁冲突时立即返回 ER_LOCK_NOWAIT 类错误
SELECT id, status, payload
FROM task_queue
WHERE id = 101
FOR UPDATE NOWAIT;

-- 只有成功拿到锁并确认状态后，才改变任务归属
UPDATE task_queue
SET status = 'processing', claimed_at = NOW()
WHERE id = 101 AND status = 'ready';

-- 发生任何异常都回滚，释放本事务已经取得的锁
COMMIT;

NOWAIT 不等于不会失败：它只是把等待变成即时错误。代码要区分锁冲突、任务状态已经变化、死锁和连接异常；其中死锁应按事务整体重试，不能只重复最后一条 SQL。

生产落地时核对这张选择表

最后检查四件事：表是否为 InnoDB；领取条件是否有合适索引；事务是否在外部调用前提交；复制配置是否允许这类语句。NOWAIT 与 SKIP LOCKED 只对行级锁有意义，且 MySQL 文档将它们标记为 statement-based replication 不安全。不要因为 SQL 能执行，就把它直接套到库存扣减、财务余额或需要完整视图的查询上。

常见问题

SKIP LOCKED 会保证任务严格按时间顺序吗？

不会。它优先返回当前可锁的行，前面的任务若被长事务占用可能暂时被越过，需要业务层做重试或超时回收。

NOWAIT 和把锁等待超时设为零一样吗？

不要混为一谈。NOWAIT 是锁定读取语义的一部分，明确要求遇锁立即报错；通用等待超时还会受会话和语句范围影响。

领取后能在事务里调用远程接口吗？

不建议。远程接口会拉长持锁时间，放大冲突；更稳妥的做法是短事务标记 processing，提交后处理，失败时再用状态和重试记录恢复。

一句话收尾：能换任务就用 SKIP LOCKED，必须拿到目标就用 NOWAIT；两者的共同前提都是短事务、明确状态和可恢复的失败路径。