如何將Laravel改成Swoole版

這篇文章主要講解了“如何將Laravel改成Swoole版”，文中的講解內(nèi)容簡(jiǎn)單清晰，易于學(xué)習(xí)與理解，下面請(qǐng)大家跟著小編的思路慢慢深入，一起來(lái)研究和學(xué)習(xí)“如何將Laravel改成Swoole版”吧！

前言

不建議生產(chǎn)環(huán)境使用

創(chuàng)建一個(gè)新的 laravel 項(xiàng)目

laravel new swoole-laravel

將 Laravel 改成 Swoole 版

Laravel 的根目錄創(chuàng)建一個(gè) swoole_server.php 文件，然后把 public/index.php 中的代碼復(fù)制過(guò)來(lái)

<?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);

第一步，框架文件的加載是肯定的，而且應(yīng)該是在主進(jìn)程中就加載好的，不需要子進(jìn)程或者協(xié)程再去重復(fù)加載。因此，上面的 require 都不太需要?jiǎng)印?/p>

第二步，我們要啟動(dòng)一個(gè) HTTP 的 Swoole 服務(wù)，這個(gè)之前已經(jīng)講過(guò)很多次了，注意，在 onRequest 中，我們應(yīng)該將 $kernel 相關(guān)的代碼放入進(jìn)去。

$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 "服務(wù)啟動(dòng)", PHP_EOL;
$http->start();

這樣就可以了嗎？要不你先試試看。正常情況下可能你是獲得不了任何的輸入和輸出的，這是為啥？

第三步，解決輸入問(wèn)題，其實(shí)就是超全局變量在 Swoole 中是不起作用的，所以 $_GET 之類的變量都會(huì)失效，Laravel 中 Request 相關(guān)的對(duì)象都無(wú)法獲得數(shù)據(jù)了。這怎么辦呢？我們從 onRequest 的參數(shù)中拿這些數(shù)據(jù)，然后再放回到當(dāng)前進(jìn)程協(xié)程中的 $_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 的問(wèn)題。現(xiàn)在你再試試，參數(shù)是可以接收到了，但輸出怎么是打印在控制臺(tái)的？

第四步，解決輸出問(wèn)題，將框架中的所有輸出放到輸出緩沖區(qū)，然后再用 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;
        }
    }
    //把返回放到一個(gè)緩沖區(qū)里
    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 () 這些內(nèi)容，也是我們之前學(xué)習(xí)過(guò)的內(nèi)容，也就不多做解釋了。

全部代碼

<?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;
        }
    }
    //把返回放到一個(gè)緩沖區(qū)里
    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 "服務(wù)啟動(dòng)", PHP_EOL;
$http->start();

至此，我們最簡(jiǎn)單的框架改造就完成了，趕緊試試效果吧。

運(yùn)行

php swoole_server.php

訪問(wèn)

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

試試協(xié)程效果

先定義一個(gè)路由。或者我們直接改造一下默認(rèn)的路由。

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');
});

打印了一堆東西，不過(guò)應(yīng)該都比較熟悉吧，前兩個(gè)是協(xié)程 ID 和協(xié)程信息的輸出，然后我們 Swoole\Coroutine::sleep () 了 10 秒，再打印一下進(jìn)程 ID 。

然后我們打開(kāi)瀏覽器，準(zhǔn)備兩個(gè)標(biāo)簽一起訪問(wèn)。

// 第一個(gè)訪問(wèn)的頁(yè)面
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
// 第二個(gè)訪問(wèn)的頁(yè)面
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

看出來(lái)了嗎？每個(gè) onRequest 事件其實(shí)都是開(kāi)了一個(gè)新的協(xié)程來(lái)處理請(qǐng)求所以它們的協(xié)程 ID 不同。同時(shí)，第二個(gè)請(qǐng)求不會(huì)因?yàn)榈谝粋€(gè)請(qǐng)求阻塞而等到 20 秒后才返回。最后在協(xié)程狀態(tài)中，我們還看到了第二個(gè)請(qǐng)求中顯示 coroutine_num 有兩個(gè)，說(shuō)明當(dāng)前有兩個(gè)協(xié)程在處理任務(wù)。最后，進(jìn)程是相同的，它們都是走的同一個(gè)進(jìn)程。

試試多進(jìn)程效果

默認(rèn)情況下，上面的代碼是一個(gè)主進(jìn)程，一個(gè) Worker 進(jìn)程，然后再使用了協(xié)程能力。其實(shí)這樣的效果已經(jīng)能秒殺普通的 PHP-FPM 效果了。但我們要充分利用多核機(jī)器的性能，也就是說(shuō)，我們來(lái)開(kāi)啟多進(jìn)程，使用多進(jìn)程 + 多協(xié)程的超強(qiáng)處理模式。最簡(jiǎn)單的方式，直接設(shè)置 HTTP 服務(wù)的進(jìn)程 Worker 數(shù)量即可。

$http->set(array(
    'worker_num' => 4,
      // 'worker_num' => 1,單進(jìn)程
));

現(xiàn)在運(yùn)行起服務(wù)器，可以看到多了幾個(gè)進(jìn)程了。然后我們?cè)傩陆ㄒ粋€(gè)測(cè)試路由

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

現(xiàn)在再次訪問(wèn)首頁(yè)和這個(gè) /a 頁(yè)面。

// 首頁(yè)一
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
// 首頁(yè)二
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 頁(yè)面
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

發(fā)現(xiàn)沒(méi)有，它們的進(jìn)程 ID 也都不同了吧，如果沒(méi)有阻塞，會(huì)優(yōu)先切換進(jìn)程，如果所有進(jìn)程都有阻塞，則再循環(huán)創(chuàng)建協(xié)程進(jìn)行進(jìn)程內(nèi)的處理。

感謝各位的閱讀，以上就是“如何將Laravel改成Swoole版”的內(nèi)容了，經(jīng)過(guò)本文的學(xué)習(xí)后，相信大家對(duì)如何將Laravel改成Swoole版這一問(wèn)題有了更深刻的體會(huì)，具體使用情況還需要大家實(shí)踐驗(yàn)證。這里是億速云，小編將為大家推送更多相關(guān)知識(shí)點(diǎn)的文章，歡迎關(guān)注！