当前位置：首页 > 文章列表 > 数据库 > MySQL > MySQL 多个消费者怎么用 SKIP LOCKED 领取任务

MySQL 多个消费者怎么用 SKIP LOCKED 领取任务

来源：17golang原创 2026-09-06 08:38:43 0浏览收藏

多个消费者共同读取 MySQL 任务表时，核心写法是把领取动作放进短事务：先用 SELECT ... FOR UPDATE SKIP LOCKED 锁定一条待处理任务，再在同一事务里把它改成 processing，最后提交。其他消费者遇到这条已锁记录会直接跳过，继续尝试下一条，而不是排队等待。

要点速览

SKIP LOCKED 适合队列式表，不适合要求完整一致视图的普通查询。
领取和状态更新必须在同一个 InnoDB 事务中，提交后再执行耗时业务。
没有任务、消费者崩溃、复制模式和长任务超时，都要有明确的恢复策略。

先把任务表设计成可并发领取

先准备一个状态清晰、能快速筛选的队列表。下面的字段足够演示领取路径，生产环境还可以增加重试次数、租约截止时间和错误摘要。

CREATE TABLE task_queue (
    id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT,
    payload JSON NOT NULL,
    status ENUM('pending', 'processing', 'done', 'failed') NOT NULL DEFAULT 'pending',
    claimed_by VARCHAR(64) NULL,
    claimed_at DATETIME NULL,
    PRIMARY KEY (id),
    KEY idx_queue_status_id (status, id) -- 让领取条件和排序共享索引
) ENGINE = InnoDB;

status, id 联合索引对应 WHERE status = 'pending' ORDER BY id。它不是为了保证绝对公平，而是让消费者有稳定的扫描顺序；被锁住的旧任务会被跳过，后面的任务可以先被领取。

字段或条件	作用	领取时的判断
`status`	表达任务生命周期	只选择 `pending`
`id`	稳定排序和唯一定位	领取后用主键更新
`claimed_by`	记录消费者身份	便于审计与排障
`claimed_at`	记录租约或超时起点	恢复卡住任务时使用

MySQL SKIP LOCKED 任务队列中的任务表字段、状态索引与消费者连接关系 — 图1：任务状态、联合索引和多个消费者连接共同构成可并发领取的队列表结构。

在短事务里用 FOR UPDATE SKIP LOCKED 抢一条

每个消费者都要使用自己的数据库连接，并显式开启事务。锁定读只有在事务未提交时才有意义；如果开启自动提交，锁可能在语句结束时就释放，领取和标记就无法形成一个原子动作。

START TRANSACTION;

-- 只找待处理且当前没有被其他消费者锁住的任务
SELECT id, payload
  FROM task_queue
 WHERE status = 'pending'
 ORDER BY id
 LIMIT 1
 FOR UPDATE SKIP LOCKED;

-- 应用拿到 id 后，在同一事务内完成状态转移
UPDATE task_queue
   SET status = 'processing',
       claimed_by = 'worker-a',
       claimed_at = NOW()
 WHERE id = 12345
   AND status = 'pending'; -- 防止状态已经变化时误更新

COMMIT; -- 提交后才释放领取锁

应用层要检查查询是否返回了行，以及 UPDATE 的影响行数。查询没有结果时说明当前没有可领取任务，可以短暂退避后重试；不要把它当成异常死循环。两个消费者同时执行时，已被第一个事务锁住的记录会从第二个结果集中消失，但第二个消费者仍可能读到更靠后的任务。

MySQL 官方说明了这个语义：SKIP LOCKED 不等待行锁，直接从结果集中移除被锁行；因此返回的是不一致视图，只适合队列一类允许跳过锁行的场景。它只对行级锁生效，使用语句复制时还要单独评估安全性。