首頁  >  文章  >  php框架  >  試試怎麼將Laravel改成Swoole版

試試怎麼將Laravel改成Swoole版

藏色散人
藏色散人轉載
2022-12-02 16:29:021218瀏覽

這篇文章給大家Laravel和Swoole的相關知識,主要內容是教大家怎麼將Laravel改成Swoole版(嘗試學習,不建議更改現有項目),下面一起來看看吧,希望對大家有所幫助!

前言

不建議生產環境使用

#建立一個新的laravel 專案

laravel new swoole-laravel

將Laravel 改成Swoole 版

Laravel 的根目錄建立一個swoole_server.php 文件,然後把public/index.php 中的程式碼複製過來【推薦學習:laravel影片教學

<?php
use Illuminate\Contracts\Http\Kernel;
use Illuminate\Http\Request;
define(&#39;LARAVEL_START&#39;, microtime(true));
require __DIR__.&#39;/../vendor/autoload.php&#39;;
$app = require_once __DIR__.&#39;/../bootstrap/app.php&#39;;
$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(&#39;0.0.0.0&#39;, 9501);
$http->on(&#39;Request&#39;, 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(&#39;Request&#39;, 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(&#39;Request&#39;, 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 () 這些內容,也是我們之前學習過的內容,也就不多做解釋了。

全部程式碼

start();

至此,我們最簡單的框架改造就完成了,趕快試試看效果吧。

執行

php swoole_server.php

存取

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

試試協程效果

先定義一個路由。或者我們直接改造一下預設的路由。

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

印了一堆東西,不過應該都比較熟悉吧,前兩個是協程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(
    &#39;worker_num&#39; => 4,
      // &#39;worker_num&#39; => 1,单进程
));

現在運行起伺服器,可以看到多了幾個進程了。然後我們再新建一個測試路由

Route::get(&#39;/a&#39;, 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 也都不同了吧,如果沒有阻塞,會優先切換進程,如果所有進程都有阻塞,則再循環創建協程進行進程內的處理。

以上是試試怎麼將Laravel改成Swoole版的詳細內容。更多資訊請關注PHP中文網其他相關文章!

陳述:
本文轉載於:learnku.com。如有侵權,請聯絡admin@php.cn刪除