不能直接用框架默认pdo连接跑分布式任务，因任务进程长生命周期易致连接超时、事务残留、字符集错乱或泄漏；pdo::attr_persistent在协程/子进程下跨协程共享socket引发状态污染，正确做法是每个任务实例新建并销毁连接，高并发下须配按任务类型隔离的连接池。
为什么不能直接用框架默认 PDO 连接跑分布式任务
分布式任务框架（如基于 Swoole 的 EasyTask、Swoole-Process 管理的定时/异步任务）在长生命周期进程中复用数据库连接时，容易触发连接超时、事务残留、字符集错乱或连接泄漏。PDO 默认连接在脚本结束时才释放，但任务进程可能运行数小时甚至数天，PDO::ATTR_PERSISTENT 在协程或子进程环境下不可靠——它会跨协程共享底层 socket，导致状态污染。
常见错误现象包括：
PDOException: MySQL server has gone away- 任务执行中突然读到旧数据（主从延迟未感知）
- 多个任务并发写同一张日志表时出现死锁（因事务未显式关闭）
正确做法是：每个任务实例启动时新建连接，执行完立即销毁；高并发场景下必须配合连接池（如 easyswoole/pdo-mysql），且连接池需按任务类型隔离（例如“调度器连接池”和“执行器连接池”不能混用）。
任务驱动表设计必须包含哪些字段
分布式任务框架依赖数据库持久化任务元信息，不是简单存个 job 表就能跑起来。核心表至少要支持重试、分片、幂等、优先级和可观测性，以下字段为硬性要求：
-
id：主键，建议用BIGINT UNSIGNED AUTO_INCREMENT（避免 UUID 在范围查询和索引上的性能损耗） -
job_name：任务标识符，如"send_welcome_email"，用于路由到对应处理器 -
payload：JSON 格式，存参数，NOT NULL DEFAULT '{}'，务必限制长度（如TEXT或MEDIUMTEXT） -
status：枚举值，'pending'|'running'|'success'|'failed'|'cancelled'，不建议用数字编码（难调试） -
attempts：当前重试次数，TINYINT UNSIGNED DEFAULT 0，防止无限重试打崩下游 -
max_attempts：最大允许重试次数，可动态覆盖全局配置 -
reserved_at：被某个 worker 拿走的时间戳，用于检测假死（如 > 300 秒未更新则视为失败） -
available_at：可用于执行的最早时间（支持延迟任务），INT UNSIGNED存 Unix timestamp -
created_at和finished_at：审计必备，不要只靠updated_at
额外建议字段：worker_id（绑定具体进程 ID）、trace_id（对接链路追踪）、priority（TINYINT，1–10，避免低优任务饿死）。
MySQL 与 Redis 如何分工做任务驱动
纯 MySQL 做任务队列在高吞吐下会遇到锁竞争和 SELECT ... FOR UPDATE 性能瓶颈；纯 Redis 又缺乏事务回滚与复杂查询能力。真实项目中应分层使用：
- Redis 作为「任务分发总线」：用
LPUSH/BRPOPLPUSH实现低延迟入队与出队，配合SETNX做 worker 注册与心跳 - MySQL 作为「任务事实库」：所有状态变更、重试记录、执行日志、失败堆栈都落库，供后台管理页和告警系统消费
- 关键同步点：worker 从 Redis 取出任务后，立刻在 MySQL 插入一条
status = 'running'记录，并带上reserved_at；执行完毕再原子更新状态和finished_at
这种组合下，Redis 不承担持久化责任，MySQL 不承担高并发轮询压力——但要注意：MySQL 更新状态时必须加唯一索引（如 (job_name, id)）防止重复插入，且更新语句必须带 WHERE status = 'pending' 条件，避免覆盖已处理任务。
连接池配置里最容易被忽略的三个参数
以 easyswoole/pdo-mysql 为例，很多人只配 min/max，却栽在下面三个参数上：
-
intervalCheckTime：连接健康检查间隔，默认 30000ms。若设太大（如 300000），失效连接会长期滞留池中，导致任务随机失败；建议 ≤ 10000 -
maxIdleTime：空闲连接最大存活时间，默认 60s。若任务突发流量后回落，大量连接不会及时释放，撑爆 MySQL 的max_connections；建议设为 30–45s -
timeout：获取连接的等待超时，单位毫秒。默认 3000，但在高负载下易触发PoolEmpty异常；应结合业务 SLA 设置（如核心任务 ≤ 500ms，非核心 ≤ 2000ms）
还有一个隐藏坑：不同任务类型（如“短信发送”和“报表生成”）如果共用一个连接池，慢任务会阻塞快任务的连接获取。必须按业务维度拆池，哪怕多占点内存。
php免费学习视频：立即使用
踏上前端学习之旅，开启通往精通之路！从前端基础到项目实战，循序渐进，一步一个脚印，迈向巅峰！
