[原]yii+swoole 搭建一套http+websocket服务（1）

在php11版本还没出来之前。。。swoole的横空出世确实给php插上一双飞上天的翅膀，emmmm...都这么说了，那还是需要了解一下下swoole，这里分享一下为了让swoole_server跑上yii框架的心酸历程。。笑哭。。

环境：php7.3+swoole4.5.0+yii2.0.32

在让页面能够正常弹出"Congratulations!"之前，你需要了解并解决以下问题：

一，
swoole对于http请求并没有按照php-fpm那样，对超全局变量进行处理，也就是在swoole中，你没办法通过$_SERVER，$_POST，$_GET等变量获取来自客户端的请求信息，相反，swoole自己提供了一套对应获取的方法，例如：
$_GET对应的是：Swoole\Http\Request->get，
$_POST对应的是：Swoole\Http\Request->post
（其他的可以参考swoole官网：https://wiki.swoole.com/#/http_server）

所以这里会有三个问题要处理：

1，yii2需要适配swoole的这种获取方式，否则无法正常获取来自客户端的请求
2，如果swoole的框架是放在初始化的常驻进程（onWorkerStart）中，那每次请求还需要先释放这些超全局变量，否则会导致脏数据
3，yii2在web的初始化中，我们会发现框架的bootstrap会通过$_SERVER['SCRIPT_FILENAME']和$_SERVER['SCRIPT_NAME']来对@webroot和@web，所以这两个全局变量也需要拎出来额外配置

二，
header头部问题：swoole是通过Swoole\Http\Response->header来设置HTTP 响应的 Header 信息，而yii2是使用php的header()，所以如果不重新yii2的respond的组件，不仅无法正常返回客户端还会报错：headers already sent by

解决方案

其实从上面可以看到，说白了就是yii2的request组件和respond组件无法适配swoole,最友好的解决方案还是对这两个组件进行重写(如果要上生产环境)，这里顺便记录一下填坑过程中的其他方案（纯碎互相学习探讨）
1，针对request：
（最为简单明了）就是对需要用到的全局变量进行重新赋值，例如：

 $_GET=[];   //这里就是为了处理常驻进程的变量销毁，如果你不使用用onWorkerStart去初始化框架，那就可以省掉这一步骤
 if(isset($request->get)){
            foreach ($request->get as $k=>$v){
                $_GET[$k] = $v;
            }
        }

2，针对response：
（该方法简单粗暴，也一劳永逸，但最不推荐,因为是通过重启进程来实现对所有变量资源的销毁释放）在请求结束时调用swoole的这个方法：$http->close(); 另外response最大的问题来自于yii框架对header()的使用，如果你在开发环境暂时不需要用到header信息的回写，当然也可以通过php.ini()暂时禁用,另外还需要用@压制警告信息

只要处理上面所提及的问题，就可以让yii在swoole上run起来，下面是采用比较简单的思路来实现的完整的代码（至少要先跑起来），基于这段代码swoole就可以开启一个监听8880端口的web服务。。。

/**假设该文件名为：swYiiWs.php, 再假设yii2的框架路是是：/data/project/test/swoole/basic，
 *那么这个文件放置的路径：/data/project/test/swoole/basic/(swYiiWs的文件夹名称)
 */
<?php
class swYiiWs
{
    public static $wsInstance ='';
    public $host = '0.0.0.0';
    public $port = '8880';

    public $swooleConfig = [
        'document_root' => '/data/project/test/swoole/basic/web', // v4.4.0以下版本, 此处必须为绝对路径
        'enable_static_handler' => true,
    ];

    public static $yiiConfig;

    public function __construct()
    {
        if(empty(self::$wsInstance)){
            self::$wsInstance = new swoole\WebSocket\server($this->host, $this->port);
        }
    }

    public function setHttpConfig($config)
    {
        $this->config = $config;
    }

    public function loadConfig($server, $workId)
    {
        defined('YII_DEBUG') or define('YII_DEBUG', true);
        defined('YII_ENV') or define('YII_ENV', 'dev');
        defined('YII_ENV_DEV') or define('YII_ENV_DEV', 'dev');

        require __DIR__ . '/../vendor/autoload.php';
        require __DIR__ . '/../vendor/yiisoft/yii2/Yii.php';

        if (empty(self::$yiiConfig)){
            self::$yiiConfig = require __DIR__ . '/../config/web.php';
        }
    }

    public function startYii($request, $response)
    {
        /**
         *  初始化，swoole的常驻进程，处理完后没有释放前一次请求相关的变量
         */
        $_SERVER = [];
        $_GET = [];
        $_POST = [];
        //针对@webroot和@web处理
        $_SERVER['SCRIPT_FILENAME'] = dirname(__DIR__) . '/index.php';
        $_SERVER['SCRIPT_NAME'] = $request->server['request_uri'];

        if(isset($request->server)){
            foreach ($request->server as $k=>$v){
                $_SERVER[strtoupper($k)] = $v;
            }
        }
        if(isset($request->header)){
            foreach ($request->header as $k=>$v){
                $_SERVER[strtoupper($k)] = $v;
            }
        }
        if(isset($request->get)){
            foreach ($request->get as $k=>$v){
                $_GET[$k] = $v;
            }
        }
        if(isset($request->post)){
            foreach ($request->post as $k=>$v){
                $_POST[$k] = $v;
            }
        }

        if(isset($request->files)){
            foreach ($request->files as $k=>$v){
                $_FILES[$k] = $v;
            }
        }

        ob_start();
        try{
            (new yii\web\Application(self::$yiiConfig))->run();
            $content = ob_get_contents();
        }catch (Throwable $e){
            $content = $e->getMessage() . '<br>' . $e->getTraceAsString();
        }
        ob_end_flush();
        $response->end($content);  
        $http->close();  //为了将上一次的缓冲变量清除，直接通过这个方法来重启进程，非常简单粗暴
    }
    //开启websocket服务
    public function onOpen($ws, $request)
    {
        var_dump($request->fd, $request->get, $request->server);
        $ws->push($request->fd, "hello, welcome\n");
    }

    public function onMessage($ws, $frame)
    {
        echo "Message: {$frame->data}\n";
        $ws->push($frame->fd, "server: {$frame->data}");
    }

    public function onClose($ws, $fd){
    }

    public function start()
    {
        self::$wsInstance->set($this->swooleConfig);

        self::$wsInstance->on('WorkerStart', [$this, 'loadConfig']);

        self::$wsInstance->on('open', [$this, 'onOpen']);

        self::$wsInstance->on('message', [$this, 'onMessage']);

        self::$wsInstance->on('request', [$this, 'startYii']);

        self::$wsInstance->on('close', [$this, 'onClose']);

        self::$wsInstance->start();
    }
}
(new swYiiWs())->start();