必须用异步无阻塞方式记录日志,禁用Log::write()等同步写法;推荐file_put_contents+LOCK_EX直写文件,并显式传递trace_id等上下文字段。

在 ThinkPHP6.0 队列任务中记录日志,核心原则是:**不能用同步写文件的 Log::write() 或框架默认日志驱动,必须走异步、无阻塞、上下文完整的方式**。否则队列消费者进程本身会被日志拖慢,甚至引发文件句柄耗尽、响应延迟等问题。
避免在 handle/fire 中调用 Log::write()
ThinkPHP 默认的 Log::write() 是同步阻塞式文件写入。队列消费者(如 php think queue:listen)是常驻进程,每条日志都会触发 fopen → fwrite → fclose,高频执行极易触达系统 ulimit -n 限制,且无法利用队列本身的异步优势。
- 不要在
handle()或fire()方法里直接写Log::write('xxx') - 不要在消费者里重新调用
Log::save()—— 它仍走同步流程 - 尤其避免在循环处理多条消息时反复调用,这是常见性能雷区
推荐方式:用 file_put_contents + 固定路径 + LOCK_EX
最轻量、最可控的做法,是在消费者中绕过框架日志层,直接用 PHP 原生函数写入,确保原子性与低开销:
- 按日期/级别分目录写入,例如:
RUNTIME_PATH . 'log/queue/' . date('Ym/d.') . 'error.log' - 使用
FILE_APPEND | LOCK_EX标志,防止并发写入错乱 - 手动拼接时间、任务类名、错误堆栈等关键信息,不依赖框架上下文
- 示例代码片段:
php
file_put_contents(
RUNTIME_PATH . 'log/queue/' . date('Ym/d.') . 'send_notice.log',
"[" . date('Y-m-d H:i:s') . "] [SendNoticeJob] 用户 {$data['to_user_id']} 推送成功\n",
FILE_APPEND | LOCK_EX
);
保留请求上下文:把关键字段随任务一起传递
队列任务是跨进程执行的,消费者拿不到原始 HTTP 请求里的 trace_id、user_id、ip 等。若需关联排查,必须在投递时显式带上:
- 投递端(如控制器)组装任务数据时,一并注入:
'trace_id' => $request->header('trace-id', uniqid('q-')) - 消费者中直接读取
$data['trace_id']并写入日志行首,便于 ELK 或 grep 追踪 - 不要试图在消费者里通过
Request::instance()获取 —— 队列进程无请求上下文
可选进阶:对接 Monolog + 异步 Handler
若项目已引入 Monolog,可通过自定义 Handler 实现更规范的日志输出:
- 新建
app/queue/handler/AsyncFileHandler.php,继承Monolog\Handler\StreamHandler - 重写
write()方法,确保每次写入都带LOCK_EX和固定路径格式 - 在消费者中初始化独立 logger:
$logger = new Logger('queue'); $logger->pushHandler(new AsyncFileHandler(...)); - 注意:仍要避开
think\facade\Log,它底层仍可能触发同步行为
php免费学习视频:立即使用
踏上前端学习之旅,开启通往精通之路!从前端基础到项目实战,循序渐进,一步一个脚印,迈向巅峰!











