尝试怎么将Laravel改成Swoole版

本篇文章给大家laravelswoole的相关知识,主要内容是教大家怎么将laravel改成swoole版(尝试学习,不建议更改现有项目),下面一起来看看吧,希望对大家有所帮助!

前言

不建议生产环境使用

创建一个新的 laravel 项目

laravel new swoole-laravel

将 Laravel 改成 Swoole 版

Laravel 的根目录创建一个 swoole_server.php 文件,然后把 public/index.php 中的代码复制过来【推荐学习:laravel视频教程

<?php use IlluminateContractshttpKernel; use IlluminateHttpRequest; 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-&gt;handle(     $request = Request::capture() )-&gt;send(); $kernel-&gt;terminate($request, $response);

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

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

$http = new SwooleHttpServer('0.0.0.0', 9501); $http-&gt;on('Request', function ($req, $res) use($app) {     try {         $kernel = $app-&gt;make(Kernel::class);         $response = $kernel-&gt;handle(             $request = Request::capture()         )-&gt;send();         $kernel-&gt;terminate($request, $response);     }catch(Exception $e){         print_r($e-&gt;getMessage());     } }); echo "服务启动", PHP_EOL; $http-&gt;start();

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

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

$http-&gt;on('Request', function ($req, $res) use($app) {     $_SERVER = [];     if(isset($req-&gt;server)){         foreach($req-&gt;server as $k =&gt; $v){             $_SERVER[strtoupper($k)] = $v;         }     }     $_GET = [];     if(isset($req-&gt;get)){         foreach ($req-&gt;get as $k =&gt; $v){             $_GET[$k] = $v;         }     }     $_POST = [];     if(isset($req-&gt;post)){         foreach ($req-&gt;post as $k =&gt; $v){             $_POST[$k] = $v;         }     }     try {         $kernel = $app-&gt;make(Kernel::class);         $response = $kernel-&gt;handle(             $request = Request::capture()         )-&gt;send();         $kernel-&gt;terminate($request, $response);     }catch(Exception $e){         print_r($e-&gt;getMessage());     } });

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

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

$http-&gt;on('Request', function ($req, $res) use($app) {     $_SERVER = [];     if(isset($req-&gt;server)){         foreach($req-&gt;server as $k =&gt; $v){             $_SERVER[strtoupper($k)] = $v;         }     }     $_GET = [];     if(isset($req-&gt;get)){         foreach ($req-&gt;get as $k =&gt; $v){             $_GET[$k] = $v;         }     }     $_POST = [];     if(isset($req-&gt;post)){         foreach ($req-&gt;post as $k =&gt; $v){             $_POST[$k] = $v;         }     }     //把返回放到一个缓冲区里     ob_start();     try {         $kernel = $app-&gt;make(Kernel::class);         $response = $kernel-&gt;handle(             $request = Request::capture()         )-&gt;send();         $kernel-&gt;terminate($request, $response);     }catch(Exception $e){         print_r($e-&gt;getMessage());     }     $ob = ob_get_contents();     ob_end_clean();     $res-&gt;end($ob); });

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

全部代码

<?php use IlluminateContractsHttpKernel; use IlluminateHttpRequest; define(&#39;LARAVEL_START&#39;, microtime(true)); require __DIR__.&#39;/vendor/autoload.php&#39;; $app = require_once __DIR__.&#39;/bootstrap/app.php&#39;; $http = new SwooleHttpServer(&#39;0.0.0.0&#39;, 9501); $http->on('Request', function ($req, $res) use($app) {     $_SERVER = [];     if(isset($req-&gt;server)){         foreach($req-&gt;server as $k =&gt; $v){             $_SERVER[strtoupper($k)] = $v;         }     }     $_GET = [];     if(isset($req-&gt;get)){         foreach ($req-&gt;get as $k =&gt; $v){             $_GET[$k] = $v;         }     }     $_POST = [];     if(isset($req-&gt;post)){         foreach ($req-&gt;post as $k =&gt; $v){             $_POST[$k] = $v;         }     }     //把返回放到一个缓冲区里     ob_start();     try {         $kernel = $app-&gt;make(Kernel::class);         $response = $kernel-&gt;handle(             $request = Request::capture()         )-&gt;send();         $kernel-&gt;terminate($request, $response);     }catch(Exception $e){         print_r($e-&gt;getMessage());     }     $ob = ob_get_contents();     ob_end_clean();     $res-&gt;end($ob); }); echo "服务启动", PHP_EOL; $http-&gt;start();

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

运行

php swoole_server.php

访问

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

试试协程效果

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

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

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

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

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

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

试试多进程效果

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

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

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

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

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

// 首页一 1 Array (     [event_num] =&gt; 2     [signal_listener_num] =&gt; 0     [aio_task_num] =&gt; 0     [aio_worker_num] =&gt; 0     [aio_queue_size] =&gt; 0     [c_stack_size] =&gt; 2097152     [coroutine_num] =&gt; 1     [coroutine_peak_num] =&gt; 1     [coroutine_last_cid] =&gt; 1 ) 1562 // 首页二 1 Array (     [event_num] =&gt; 2     [signal_listener_num] =&gt; 0     [aio_task_num] =&gt; 0     [aio_worker_num] =&gt; 0     [aio_queue_size] =&gt; 0     [c_stack_size] =&gt; 2097152     [coroutine_num] =&gt; 1     [coroutine_peak_num] =&gt; 1     [coroutine_last_cid] =&gt; 1 ) 1563 // /a 页面 1 Array (     [event_num] =&gt; 2     [signal_listener_num] =&gt; 0     [aio_task_num] =&gt; 0     [aio_worker_num] =&gt; 0     [aio_queue_size] =&gt; 0     [c_stack_size] =&gt; 2097152     [coroutine_num] =&gt; 1     [coroutine_peak_num] =&gt; 1     [coroutine_last_cid] =&gt; 1 ) 1564

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

© 版权声明
THE END
喜欢就支持一下吧
点赞5 分享