前言
不建議生產環境使用
建立一個新的 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 也都不同了吧,如果沒有阻塞,會優先切換程序,如果所有程序都有阻塞,則再回圈建立協程進行程序內的處理。
以上就是嘗試怎麼將Laravel改成Swoole版的詳細內容,更多請關注TW511.COM其它相關文章!