mall/bin/http.conf.php

<?php
use Workerman\Connection\TcpConnection;
TcpConnection::$defaultMaxPackageSize = 10485760;
return [
    'name' => 'chidian', //服务名
    'ip' => '0.0.0.0', //监听地址
    'port' => 6504, //监听地址
    'init_php' => __DIR__.'/base.php', //初始文件
    'php_run' => function($req, $connection = null) {
        // 心跳及空闲示例
        $lifetimeTimer = \HttpForPHP\WorkerLifetimeTimer::instance(3, 15);
        $lifetimeTimer->onHeartbeat = function () { //间隔数据库连接检测
            \Yii::$app->db->createCommand('select 1')->queryOne();
        };
        $lifetimeTimer->onIdle = function () { //空闲释放
            \Yii::$app->db->close();
        };
        $lifetimeTimer->run();
        // 处理插件路由
        $getParams = $req->get();
        $route = isset($getParams['r']) ? $getParams['r'] : null;
        if ($route && strpos($route, 'plugin') !== false) {
            if (preg_match('/client\/v(\d+)\/plugin\/(.*)/', $route, $matches)) {
                // 客户端插件
                $_GET['r'] = sprintf('client/v%d/plugin/callback', $matches[1]);
                $_GET['callback'] = $matches[2];
            } else {
                // 后台插件
                $callback = str_replace('admin/plugins/', '', $route);
                $_GET['r'] = 'admin/plugins/callback';
                $_GET['callback'] = $callback;
            }
        }

        ob_start();
        $app = Yii::$app;

        // 设置请求头
        $headers = \HttpForPHP\SrvBase::$instance->getHeader($req);
        foreach ($headers as $name=>$value){
            $app->request->headers->set($name, $value);
        }
        // 设置请求参数
        $app->request->setHostInfo($req->header('Chidian-Host', null));
        $app->request->setBaseUrl(null);
        $app->request->setScriptUrl(null);
        $app->request->setPathInfo(null);
        $app->request->setUrl(null);
        $app->request->setQueryParams($_GET);
        $app->request->setBodyParams($_POST);
        $app->request->setRawBody(\HttpForPHP\SrvBase::$instance->getRawBody($req));

        try{
            $checkCache = cache()->exists('wokerman_update');
            if ($checkCache) {
                posix_kill(posix_getppid(), SIGUSR1);
                cache()->delete('wokerman_update');
            }
            $app->checkAuthByWokerman($req);
            $app->run();
        } catch (\Exception $e) {
            $msg = $e->getMessage();
            $failReloadMsg = [
                'MySQL server has gone away',
                'Failed to write to socket', #Failed to write to socket. 0 of 34 bytes written.
                'Failed to read from socket',
                'Error while sending QUERY',
                'read error on connection to', #read error on connection to 192.168.0.186:6379
            ];
            #因m异常断开重启进程
            foreach ($failReloadMsg as $fail) {
                if (strpos($msg, $fail) !== false) {
                    \HttpForPHP\Log::write(sprintf('line:%s, file:%s, err:%s, trace:%s',$e->getLine(), $e->getFile(), $e->getMessage(), $e->getTraceAsString()), 'err');
                    \HttpForPHP\SrvBase::$instance->stopWorker();
                    break;
                }
            }

            if ($msg != 'Page not found.' && $msg != '页面未找到。') {
                \HttpForPHP\Log::write(sprintf('line:%s, file:%s, err:%s, trace:%s',$e->getLine(), $e->getFile(), $e->getMessage(), $e->getTraceAsString()), 'err');
            }

            echo \HttpForPHP\Helper::toJson(\HttpForPHP\Helper::fail($e->getCode().':'.$msg));
        }
        $content = ob_get_clean();

        // 常驻服务需要清除信息
        $app->request->getHeaders()->removeAll();
        $app->response->clear();

        if ($connection === null) { //是异步任务
            //\HttpForPHP\Log::write($content, 'task');
        } else {
            $code = \Yii::$app->response->getStatusCode();
            $header = ['Access-Control-Allow-Origin' => '*']; //'Content-Type'=>'application/json; charset=utf-8',
            if (\Yii::$app->response->headers->count()) { //header头处理
                \Yii::$app->response->headers->set('Access-Control-Allow-Origin', '*');
                foreach (\Yii::$app->response->headers as $name => $values) {
                    $name = str_replace(' ', '-', ucwords(str_replace('-', ' ', $name)));
                    $header[$name] = end($values);
                }
                unset($header['Link']);
            } else {
                $header['Content-Type'] = 'application/json; charset=utf-8';
            }
            $header['X-Req'] = 'chidian';

            // 发送http
            \HttpForPHP\SrvBase::$instance->httpSend($connection, $code, $header, $content);
        }
        unset($content);

        return true;
    }, //自定义php运行函数
    'setting' => [
        'count' => cpu_count() * 4,    // 异步非阻塞CPU核数的1-4倍最合理 同步阻塞按实际情况来填写 如50-100
        #'task_worker_num' => 10, //异步任务进程数 配置了异步处理才能生效  异步处理耗时过多的会阻塞后续的异步处理请求
        #'max_request' => 500, //最大请求数 默认0 进程内达到此请求重启进程 可能存在不规范的代码造成内存泄露 这里达到一定请求释放下内存
        'stdoutFile' => __DIR__ . '/wokerman/http.log', //终端输出
        'pidFile' => __DIR__ . '/wokerman/http.pid',
        'logFile' => __DIR__ . '/wokerman/http.log', //日志文件
        # 'user' => 'www', //设置worker/task子进程的进程用户 提升服务器程序的安全性
    ]
];