将Laravel改成Swoole版

前言

不建议生产环境使用

创建一个新的laravel项目

laravel new swoole-laravel

将Laravel改成Swoole版

Laravel 的根目录创建一个 swoole_server.php 文件,然后把 public/index.php 中的代码复制过来

<?php

use Illuminate\Contracts\Http\Kernel;
use Illuminate\Http\Request;

define('LARAVEL_START', microtime(true));

require __DIR__.'/../vendor/autoload.php';

$app = require_once __DIR__.'/../bootstrap/app.php';

$kernel = $app->make(Kernel::class);

$response = $kernel->handle(
    $request = Request::capture()
)->send();

$kernel->terminate($request, $response);

第一步,框架文件的加载是肯定的,而且应该是在主进程中就加载好的,不需要子进程或者协程再去重复加载。因此,上面的 require 都不太需要动。

第二步,我们要启动一个 HTTP 的 Swoole 服务,这个之前已经讲过很多次了,注意,在 onRequest 中,我们应该将 $kernel 相关的代码放入进去。

$http = new Swoole\Http\Server('0.0.0.0', 9501);

$http->on('Request', function ($req, $res) use($app) {
    try {
        $kernel = $app->make(Kernel::class);

        $response = $kernel->handle(
            $request = Request::capture()
        )->send();

        $kernel->terminate($request, $response);
    }catch(\Exception $e){
        print_r($e->getMessage());
    }
});
echo "服务启动", PHP_EOL;
$http->start();

这样就可以了吗?要不你先试试看。正常情况下可能你是获得不了任何的输入和输出的,这是为啥?

第三步,解决输入问题,其实就是超全局变量在 Swoole 中是不起作用的,所以 $_GET 之类的变量都会失效,Laravel 中 Request 相关的对象都无法获得数据了。这怎么办呢?我们从 onRequest 的参数中拿这些数据,然后再放回到当前进程协程中的 $_GET 中就好啦。

$http->on('Request', function ($req, $res) use($app) {
    $_SERVER = [];
    if(isset($req->server)){
        foreach($req->server as $k => $v){
            $_SERVER[strtoupper($k)] = $v;
        }
    }
    $_GET = [];
    if(isset($req->get)){
        foreach ($req->get as $k => $v){
            $_GET[$k] = $v;
        }
    }
    $_POST = [];
    if(isset($req->post)){
        foreach ($req->post as $k => $v){
            $_POST[$k] = $v;
        }
    }
    try {
        $kernel = $app->make(Kernel::class);

        $response = $kernel->handle(
            $request = Request::capture()
        )->send();

        $kernel->terminate($request, $response);
    }catch(\Exception $e){
        print_r($e->getMessage());
    }
});

上面三段代码,分别解决了 $_SERVER$_GET$_POST 的问题。现在你再试试,参数是可以接收到了,但输出怎么是打印在控制台的?

第四步,解决输出问题,将框架中的所有输出放到输出缓冲区,然后再用 Swoole 的 Response 返回。

$http->on('Request', function ($req, $res) use($app) {
    $_SERVER = [];
    if(isset($req->server)){
        foreach($req->server as $k => $v){
            $_SERVER[strtoupper($k)] = $v;
        }
    }
    $_GET = [];
    if(isset($req->get)){
        foreach ($req->get as $k => $v){
            $_GET[$k] = $v;
        }
    }
    $_POST = [];
    if(isset($req->post)){
        foreach ($req->post as $k => $v){
            $_POST[$k] = $v;
        }
    }
    //把返回放到一个缓冲区里
    ob_start();
    try {
        $kernel = $app->make(Kernel::class);

        $response = $kernel->handle(
            $request = Request::capture()
        )->send();

        $kernel->terminate($request, $response);
    }catch(\Exception $e){
        print_r($e->getMessage());
    }
    $ob = ob_get_contents();
    ob_end_clean();
    $res->end($ob);
});

最后的 ob_start() 这些内容,也是我们之前学习过的内容,也就不多做解释了。

全部代码

<?php

use Illuminate\Contracts\Http\Kernel;
use Illuminate\Http\Request;

define('LARAVEL_START', microtime(true));

require __DIR__.'/vendor/autoload.php';

$app = require_once __DIR__.'/bootstrap/app.php';

$http = new Swoole\Http\Server('0.0.0.0', 9501);

$http->on('Request', function ($req, $res) use($app) {
    $_SERVER = [];
    if(isset($req->server)){
        foreach($req->server as $k => $v){
            $_SERVER[strtoupper($k)] = $v;
        }
    }
    $_GET = [];
    if(isset($req->get)){
        foreach ($req->get as $k => $v){
            $_GET[$k] = $v;
        }
    }
    $_POST = [];
    if(isset($req->post)){
        foreach ($req->post as $k => $v){
            $_POST[$k] = $v;
        }
    }
    //把返回放到一个缓冲区里
    ob_start();
    try {
        $kernel = $app->make(Kernel::class);

        $response = $kernel->handle(
            $request = Request::capture()
        )->send();

        $kernel->terminate($request, $response);
    }catch(\Exception $e){
        print_r($e->getMessage());
    }
    $ob = ob_get_contents();
    ob_end_clean();
    $res->end($ob);
});

echo "服务启动", PHP_EOL;
$http->start();

至此,我们最简单的框架改造就完成了,赶紧试试效果吧。

运行

php swoole_server.php

访问

http://47.113.xxx.xx:9501/

试试协程效果

先定义一个路由。或者我们直接改造一下默认的路由。

Route::get('/', function () {
    echo Swoole\Coroutine::getCid(), "<br/>";
    print_r(Swoole\Coroutine::stats());
    Swoole\Coroutine::sleep(10);
    echo "<br/>";
    echo getmypid(), "<br/>";
//    return view('welcome');
});

打印了一堆东西,不过应该都比较熟悉吧,前两个是协程 ID 和协程信息的输出,然后我们 Swoole\Coroutine::sleep() 了 10 秒,再打印一下进程 ID 。

然后我们打开浏览器,准备两个标签一起访问。

// 第一个访问的页面
1
Array
(
    [event_num] => 2
    [signal_listener_num] => 0
    [aio_task_num] => 0
    [aio_worker_num] => 0
    [aio_queue_size] => 0
    [c_stack_size] => 2097152
    [coroutine_num] => 1
    [coroutine_peak_num] => 1
    [coroutine_last_cid] => 1
)
1468

// 第二个访问的页面
2
Array
(
    [event_num] => 2
    [signal_listener_num] => 0
    [aio_task_num] => 0
    [aio_worker_num] => 0
    [aio_queue_size] => 0
    [c_stack_size] => 2097152
    [coroutine_num] => 2
    [coroutine_peak_num] => 2
    [coroutine_last_cid] => 2
)
1468

看出来了吗?每个 onRequest 事件其实都是开了一个新的协程来处理请求所以它们的协程 ID 不同。同时,第二个请求不会因为第一个请求阻塞而等到 20 秒后才返回。最后在协程状态中,我们还看到了第二个请求中显示 coroutine_num 有两个,说明当前有两个协程在处理任务。最后,进程是相同的,它们都是走的同一个进程。

试试多进程效果

默认情况下,上面的代码是一个主进程,一个 Worker 进程,然后再使用了协程能力。其实这样的效果已经能秒杀普通的 PHP-FPM 效果了。但我们要充分利用多核机器的性能,也就是说,我们来开启多进程,使用多进程+多协程的超强处理模式。最简单的方式,直接设置 HTTP 服务的进程 Worker 数量即可。

$http->set(array(
    'worker_num' => 4,
      // 'worker_num' => 1,单进程
));

现在运行起服务器,可以看到多了几个进程了。然后我们再新建一个测试路由

Route::get('/a', function () {
    echo Swoole\Coroutine::getCid(), "<br/>";
    print_r(Swoole\Coroutine::stats());
    echo "<br/>";
    echo getmypid(), "<br/>";
});

现在再次访问首页和这个 /a 页面。

// 首页一
1
Array
(
    [event_num] => 2
    [signal_listener_num] => 0
    [aio_task_num] => 0
    [aio_worker_num] => 0
    [aio_queue_size] => 0
    [c_stack_size] => 2097152
    [coroutine_num] => 1
    [coroutine_peak_num] => 1
    [coroutine_last_cid] => 1
)
1562

// 首页二
1
Array
(
    [event_num] => 2
    [signal_listener_num] => 0
    [aio_task_num] => 0
    [aio_worker_num] => 0
    [aio_queue_size] => 0
    [c_stack_size] => 2097152
    [coroutine_num] => 1
    [coroutine_peak_num] => 1
    [coroutine_last_cid] => 1
)
1563

// /a 页面
1
Array
(
    [event_num] => 2
    [signal_listener_num] => 0
    [aio_task_num] => 0
    [aio_worker_num] => 0
    [aio_queue_size] => 0
    [c_stack_size] => 2097152
    [coroutine_num] => 1
    [coroutine_peak_num] => 1
    [coroutine_last_cid] => 1
)
1564

发现没有,它们的进程 ID 也都不同了吧,如果没有阻塞,会优先切换进程,如果所有进程都有阻塞,则再循环创建协程进行进程内的处理。

参考视频
Swoole系列合集 完整29课 从0到1 新手进阶 Hyperf 框架

本作品采用《CC 协议》,转载必须注明作者和本文链接
《L01 基础入门》
我们将带你从零开发一个项目并部署到线上,本课程教授 Web 开发中专业、实用的技能,如 Git 工作流、Laravel Mix 前端工作流等。
《L05 电商实战》
从零开发一个电商项目,功能包括电商后台、商品 & SKU 管理、购物车、订单管理、支付宝支付、微信支付、订单退款流程、优惠券等
讨论数量: 25

你把你现有项目改成这样试试,问题一堆,核心还是FPM和swoole的运行模式不一样,有些实例常驻内存就会影响下一个情况

1年前 评论
my38778570 (楼主) 1年前

既然都创建新的了,不如直接用官方的support version Laravel Octane

1年前 评论
Imuyu 1年前

性能要求不高的 PHP,性能要求高的 Golang。还没生产中用过 swoole,swoole 在实际生产中,效果如何?如性能、维护...等方面

1年前 评论
my38778570 (楼主) 1年前

这样的话,其实可以使用webman,然后把lv的插件全都安过去

1年前 评论
my38778570 (楼主) 1年前
zjason (作者) 1年前

佬 你咋这么会玩 :joy:

1年前 评论
my38778570 (楼主) 1年前
隐德莱希 (作者) 1年前

确实会玩!

1年前 评论

确定读写全局变量没有并发问题?

1年前 评论
my38778570 (楼主) 1年前
肆意 1年前

待我出两篇文章教教你们

1年前 评论
my38778570 (楼主) 1年前
铁牛 1年前
王小大 1年前
Anoxia (作者) 1年前

这个跟使用workman加速项目的改造好像啊,这个号称可以直接加速老项目。 github.com/joanhey/AdapterMan

1年前 评论

重定向地址你们是怎么解决的?读图片内容再输出内容又是怎么解决的?

1年前 评论
Anoxia 1年前
Anoxia 1年前

讨论应以学习和精进为目的。请勿发布不友善或者负能量的内容,与人为善,比聪明更重要!