在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();