thinkphp 5.1 默认同步写日志会阻塞http响应，qps超200易触发too many open files或延迟飙升，必须将log::write()替换为kafka异步日志：先部署kafka单机实例并配置log.dirs，再安装librdkafka、rdkafka扩展及mjaschen/php-kafka-client包；接着注册kafka日志驱动，重写write()方法将结构化日志（含request_id、trace_id等）json编码后发送至tp-log-topic（需提前创建，分区≥3、副本因子=2，acks=-1且enable.idempotence=true）；最后编写独立消费者command/kafkalogconsumer.php，手动提交offset确保不丢日志，并用supervisor双进程托管，压测验证吞吐达1200+/sec且consumer lag≤5。
ThinkPHP 5.1 默认同步写日志会卡住 HTTP 响应，QPS 超 200 就可能触发 Too many open files 错误或响应延迟飙升，必须把 Log::write() 的调用替换成向 Kafka 发送结构化日志消息，由独立消费者进程异步落盘。
安装 Kafka 服务与 PHP 扩展
先在服务器部署 Kafka 单机实例：下载 kafka_2.13-3.7.0.tgz → 解压后修改 config/server.properties 中 log.dirs=/data/kafka-logs → 启动 ZooKeeper（bin/zookeeper-server-start.sh -daemon config/zookeeper.properties）→ 再启动 Kafka（bin/kafka-server-start.sh -daemon config/server.properties）。
接着装 PHP 客户端扩展：编译安装 librdkafka 1.8.2 → 执行 pecl install rdkafka → 在 php.ini 中追加 extension=rdkafka.so → 重启 PHP-FPM。
最后安装 Composer 包：在 TP5.1 项目根目录运行 composer require mjaschen/php-kafka-client:dev-master，该客户端轻量、无依赖、支持 SASL/SSL，比原生 rdkafka 扩展更易封装日志上下文。
配置 Kafka 日志驱动并替换 Log::write()
在 application/common.php 中注册新日志驱动：
Log::setDriver('kafka', function () {
return new \app\common\log\KafkaLogger();
});
创建 app/common/log/KafkaLogger.php，继承 think\Log，并重写 write() 方法：把 $message、$level、$file、$line 和 Request ID、trace_id、user_id 等上下文打包成 JSON，调用 $producer->produce('tp-log-topic', RD_KAFKA_PARTITION_UA, json_encode($payload))。
【必须设置 acks=-1 且 enable.idempotence=true】，否则网络抖动时日志会丢失或重复；topic 名称 tp-log-topic 需提前用 kafka-topics.sh 创建，分区数 ≥ 3，副本因子设为 2。
编写独立消费者进程消费日志消息
新建 command/KafkaLogConsumer.php，继承 think\Console\Command：
第一步：初始化 RdKafka\Consumer 实例，设置 group.id=log-consumer-group、enable.auto.commit=false、auto.offset.reset=earliest；
第二步：订阅 tp-log-topic 主题；
第三步：进入 while 循环，调用 $consumer->consume(1000) 获取消息（超时 1 秒防空转）；
第四步：对每条消息，解析 JSON → 提取 level 字段 → 拼接文件路径 RUNTIME_PATH.'log/'.date('Ym/d.').$level.'.log' → 用 file_put_contents($file, $msg."\n", FILE_APPEND | LOCK_EX) 写入；
第五步：手动提交 offset（$consumer->commit($message)），仅当写文件成功后才 commit，否则跳过该消息并记录 error 日志——这能避免消费者崩溃导致消息永久丢失。
启动消费者并验证队列吞吐
方法一：前台运行调试，执行 php think kafka_log_consumer；
方法二：用 supervisor 托管，配置 command=php /var/www/project/think kafka_log_consumer，autostart=true，numprocs=2（双进程防单点阻塞）；
方法三：压测验证，用 ab -n 5000 -c 500 "http://your-domain.com/test-log" 触发高频日志，观察 Kafka Manager 中 tp-log-topic 的 Incoming Messages/sec 是否稳定在 1200+，同时检查 consumer lag 是否始终 ≤ 5。
php免费学习视频：立即使用
踏上前端学习之旅，开启通往精通之路！从前端基础到项目实战，循序渐进，一步一个脚印，迈向巅峰！
