HTTP Server

框架提供 HTTP Server，除非有特殊需求，否则能够满足日常大部分操作，与 PHP 内置web服务器同样操作。

设置 HTTPServer 仅需要对 class 选项进行调整即可。如下:

  1. <?php
  2. return [
  3.     'host' => 'http://0.0.0.0:9527',
  4.     'class' => \FastD\Servitization\Server\HTTPServer::class,
  5.     'options' => [
  6.         'pid_file' => __DIR__.'/../runtime/pid/'.app()->getName().'.pid',
  7.         'worker_num' => 10,
  8.         'task_worker_num' => 20,
  9.     ],
  10.     'processes' => [
  11.     ],
  12.     'listeners' => [
  13.     ],
  14. ];

通过服务器命令启动服务:

  1. $ php bin/server start

核心实现逻辑代码:

  1. <?php
  3. namespace FastD\Servitization\Server;
  5. use FastD\Http\Response;
  6. use FastD\Http\SwooleServerRequest;
  7. use FastD\Servitization\OnWorkerStart;
  8. use FastD\Swoole\Server\HTTP;
  9. use Psr\Http\Message\ServerRequestInterface;
  10. use swoole_http_request;
  11. use swoole_http_response;
  13. class HTTPServer extends HTTP
  14. {
  15.     use OnWorkerStart;
  17.     public function onRequest(swoole_http_request $swooleRequet, swoole_http_response $swooleResponse)
  18.     {
  19.         $request = SwooleServerRequest::createServerRequestFromSwoole($swooleRequet);
  21.         $response = $this->doRequest($request);
  22.         foreach ($response->getHeaders() as $key => $header) {
  23.             $swooleResponse->header($key, $response->getHeaderLine($key));
  24.         }
  25.         foreach ($response->getCookieParams() as $key => $cookieParam) {
  26.             $swooleResponse->cookie($key, $cookieParam);
  27.         }
  29.         $swooleResponse->status($response->getStatusCode());
  30.         $swooleResponse->end((string) $response->getBody());
  31.         app()->shutdown($request, $response);
  32.     }
  34.     public function doRequest(ServerRequestInterface $serverRequest)
  35.     {
  36.         return app()->handleRequest($serverRequest);
  37.     }
  38. }

当服务器收到请求的时候，会首先调用 onRequest 方法，在 onRequest 中，处理逻辑与fpm下一致.