绵阳梓潼网站制作公司

如何将Laravel改成Swoole版

这篇文章主要讲解了“如何将Laravel改成Swoole版”，文中的讲解内容简单清晰，易于学习与理解，下面请大家跟着小编的思路慢慢深入，一起来研究和学习“如何将Laravel改成Swoole版”吧！

创新互联是一家集网站建设,福贡企业网站建设,福贡品牌网站建设,网站定制,福贡网站建设报价,网络营销,网络优化,福贡网站推广为一体的创新建站企业，帮助传统企业提升企业形象加强企业竞争力。可充分满足这一群体相比中小企业更为丰富、高端、多元的互联网需求。同时我们时刻保持专业、时尚、前沿，时刻以成就客户成长自我，坚持不断学习、思考、沉淀、净化自己，让我们为更多的企业打造出实用型网站。

前言

不建议生产环境使用

创建一个新的 laravel 项目

laravel new swoole-laravel

将 Laravel 改成 Swoole 版

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

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 () 这些内容，也是我们之前学习过的内容，也就不多做解释了。

全部代码

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(), "
";
    print_r(Swoole\Coroutine::stats());
    Swoole\Coroutine::sleep(10);
    echo "
";
    echo getmypid(), "
";
//    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(), "
";
    print_r(Swoole\Coroutine::stats());
    echo "
";
    echo getmypid(), "
";
});

现在再次访问首页和这个 /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 也都不同了吧，如果没有阻塞，会优先切换进程，如果所有进程都有阻塞，则再循环创建协程进行进程内的处理。

感谢各位的阅读，以上就是“如何将Laravel改成Swoole版”的内容了，经过本文的学习后，相信大家对如何将Laravel改成Swoole版这一问题有了更深刻的体会，具体使用情况还需要大家实践验证。这里是创新互联，小编将为大家推送更多相关知识点的文章，欢迎关注！


文章题目：如何将Laravel改成Swoole版
当前URL：http://myzitong.com/article/gijcjj.html

其他资讯