詳解PHP實現HTTP服務器過程
PHP並非不能實現HTTP服務,一般來講,這叫網絡編程或Socket編程。在學習到其他語言的這部分的時候,一般的思路就是如何監聽TCP實現一個服務器,並處理HTTP協議。
PHP也可以這樣做,同時一般伴隨著高性能這樣的關鍵字出現。
原生Socket編程
我們可以通過PHP的Socket函數,很簡單的實現出HTTP服務。
function run() { //創建服務端的socket套接流,net協議為IPv4,protocol協議為TCP $socket = socket_create(AF_INET,SOCK_STREAM,SOL_TCP); /*綁定接收的套接流主機和端口,與客戶端相對應*/ if(socket_bind($socket,"0.0.0.0", 9502) == false){ echo 'server bind fail:'.socket_strerror(socket_last_error());exit(); } //監聽套接流 if(socket_listen($socket,4)==false){ echo 'server listen fail:'.socket_strerror(socket_last_error());exit(); } //非阻塞 socket_set_nonblock($socket); call_user_func('onAccept',$socket); } run();
然後通過Socket處理收到的數據以及作出響應:
function onMessage($connection) { //拼裝返回的html內容 $content = '<html><title>hello,world</title><body>hello,world,http</body></html>'; //拼裝頭信息 $header = ''; $header .= "HTTP/1.1 200 OK\r\n"; $header .= "Date: ".gmdate('D, d M Y H:i:s T')."\r\n"; $header .= "Content-Type: text/html;charset=utf-8\r\n"; $header .= "Content-Length: ".strlen($content)."\r\n\r\n";//必須2個\r\n表示頭部信息結束 $header .= $content; socket_write($connection,$header,strlen($header)); } function onAccept($socket) { //接收客戶端傳遞過來的信息 while(true) { $accept_resource = socket_accept($socket); if($accept_resource !== false) { $string = socket_read($accept_resource,1024); echo 'server receive is :'.$string.PHP_EOL; if($string != false) { call_user_func('onMessage',$accept_resource); } } } }
流行項目
實際上,PHP有很多在項目都在實現HTTP服務器,而且他們一般也都宣稱是高性能的。
Workerman系
Workerman是一款純PHP開發的開源高性能的PHP 應用容器。幾乎能夠實現任何類型的網絡編程,並且內置瞭一個HTTP協議。
$worker = new Worker('http://0.0.0.0:1221');
Workerman的官方在21年出品瞭Webman,一個基於Workerman實現的高性能HTTP服務框架。替代傳統PHP-FPM架構,提供高性能的HTTP服務。可以用來開發網站、接口、微服務。
Webman實際上是一個開發框架,項目的目錄結構都已經設定好瞭,按照文檔開發就行,最後隻要通過命令就能運行起來。
php start.php start
Webman支持是一個MVC框架,支持命名空間自動加載,所以代碼像這樣:
<?php namespace app\controller; use support\Request; class UserController { public function hello(Request $request) { $default_name = 'webman'; // 從get請求裡獲得name參數,如果沒有傳遞name參數則返回$default_name $name = $request->get('name', $default_name); // 向瀏覽器返回字符串 return response('hello ' . $name); } }
除瞭高性能等特點,他的上手難度很低,並且風格與現代的MVC風格一致,支持PSR標準,代碼精簡高效。如果你是ThinkPHP的開發者,你會發現很容易上手Webman。
Swoole系
說道高性能HTTP服務,總是繞不開swoole的,他也是國內最早火熱起來的PHP高性能解決方案。
使用swoole實現HTTP服務的代碼也很簡單:
$http = new Swoole\Http\Server('0.0.0.0', 9501); $http->on('Request', function ($request, $response) { $response->header('Content-Type', 'text/html; charset=utf-8'); $response->end('<h1>Hello Swoole. #' . rand(1000, 9999) . '</h1>'); }); $http->start();
swoole實際上是一個PHP的擴展,近幾年基於他發展起瞭很多的高性能框架,比如easyswoole、Hyperf、Swoft、MixPHP等等。它們都基於Swoole實現框架,可以很容易的創建完整度很成熟的系統。
ReactPHP系
ReactPHP 是用於 PHP 事件驅動編程的底層庫。也可以用來實現各類網絡編程,包括HTTP服務。用它實現HTTP服務也很簡單:
require __DIR__ . '/vendor/autoload.php'; $http = new React\Http\HttpServer(function (Psr\Http\Message\ServerRequestInterface $request) { return React\Http\Message\Response::plaintext( "Hello World!\n" ); }); $socket = new React\Socket\SocketServer('127.0.0.1:8080'); $http->listen($socket); echo "Server running at http://127.0.0.1:8080" . PHP_EOL;
它是一個底層庫,一般而言,所有PSR的框架都可以基於他運行,替換PHP-FPM。所以他也提供瞭各個流行框架的接入方案,包括laravel、symfony等,基於ReactPHP,開發瞭一個PHP-PM項目。
PHP-PM 是 PHP 應用程序的進程管理器、增壓器和負載平衡器。
可以直接通過命令運行:
ppm start –bootstrap=laravel –app-env=prod –debug=0 –logging=0 –workers=20
實際上ReactPHP是個很有趣的項目,比如IP電視服務器、終端shell、Mqtt的server、PHP版的Redis、一個GUI框架、比特幣P2P網絡等等,以後有機會給大傢介紹介紹。
AMPHP系
AMPHP 是 PHP 的高質量、事件驅動庫的集合,在設計時考慮瞭纖維和並發性。
基於AMPHP實現的HTTP服務框架叫amphp/http-server
。使用它也可以快速實現一個穩定高性能的HTTP服務。
use Amp\Http\Server\RequestHandler\ClosureRequestHandler; use Amp\Http\Server\SocketHttpServer; use Amp\Http\Server\Request; use Amp\Http\Server\Response; use Amp\Http\Status; use Amp\Socket\Server; use Psr\Log\NullLogger; // Run this script, then visit http://localhost:1337/ in your browser. Amp\Loop::run(function () { $sockets = [ Server::listen("0.0.0.0:1337"), Server::listen("[::]:1337"), ]; $server = new SocketHttpServer($sockets, new ClosureRequestHandler(function (Request $request) { return new Response(Status::OK, [ "content-type" => "text/plain; charset=utf-8" ], "Hello, World!"); }), new NullLogger); yield $server->start(); // Stop the server gracefully when SIGINT is received. // This is technically optional, but it is best to call Server::stop(). Amp\Loop::onSignal(SIGINT, function (string $watcherId) use ($server) { Amp\Loop::cancel($watcherId); yield $server->stop(); }); });
AMPHP也實現瞭很多有趣的項目,比如Mysql的客戶端,能夠實現連接池等特性。
swow
swow是一個基於協程的跨平臺並發I/O引擎,關註並發IO。
官方給出的HTTP例子代碼行數比較多,主要是展示瞭HTTP請求支持的每個階段的操作方法,代碼也是很簡潔的。
declare(strict_types=1); use Swow\Buffer; use Swow\Coroutine; use Swow\Http\Parser; use Swow\Http\ParserException; use Swow\Socket; use Swow\SocketException; $host = getenv('SERVER_HOST') ?: '127.0.0.1'; $port = (int) (getenv('SERVER_PORT') ?: 9764); $backlog = (int) (getenv('SERVER_BACKLOG') ?: 8192); $multi = (bool) (getenv('SERVER_MULTI') ?: false); $bindFlag = Socket::BIND_FLAG_NONE; $server = new Socket(Socket::TYPE_TCP); if ($multi) { $server->setTcpAcceptBalance(true); $bindFlag |= Socket::BIND_FLAG_REUSEPORT; } $server->bind($host, $port, $bindFlag)->listen($backlog); while (true) { try { $connection = $server->accept(); } catch (SocketException $exception) { break; } Coroutine::run(static function () use ($connection): void { $buffer = new Buffer(Buffer::COMMON_SIZE); $parser = (new Parser())->setType(Parser::TYPE_REQUEST)->setEvents(Parser::EVENT_BODY); $parsedOffset = 0; $body = null; try { while (true) { $length = $connection->recv($buffer, $buffer->getLength()); if ($length === 0) { break; } while (true) { $parsedOffset += $parser->execute($buffer, $parsedOffset); if ($parser->getEvent() === $parser::EVENT_NONE) { $buffer->truncateFrom($parsedOffset); $parsedOffset = 0; break; /* goto recv more data */ } if ($parser->getEvent() === Parser::EVENT_BODY) { $body ??= new Buffer(Buffer::COMMON_SIZE); $body->write(0, $buffer, $parser->getDataOffset(), $parser->getDataLength()); } if ($parser->isCompleted()) { $response = sprintf( "HTTP/1.1 200 OK\r\n" . "Connection: %s\r\n" . "Content-Length: %d\r\n\r\n" . '%s', $parser->shouldKeepAlive() ? 'Keep-Alive' : 'Closed', $body ? $body->getLength() : 0, $body ?: '' ); $connection->send($response); $body?->clear(); break; /* goto recv more data */ } } if (!$parser->shouldKeepAlive()) { break; } } } catch (SocketException $exception) { echo "No.{$connection->getFd()} goaway! {$exception->getMessage()}" . PHP_EOL; } catch (ParserException $exception) { echo "No.{$connection->getFd()} parse error! {$exception->getMessage()}" . PHP_EOL; } $connection->close(); }); }
總結
以上是一些非常流行的PHP框架和項目,但還有其他很多實現瞭高性能HTTP服務的項目。這裡不多做介紹瞭。雖然我們談到PHP的時候,很少談到網絡編程,甚至在入門教程中根本就沒有網絡編程這節課。但是使用PHP做網絡編程的各項應用已經很火熱瞭。
在入門其他語言是一定有一節課程是學習網絡編程的,做PHP教程的也應該考慮考慮增加這部分課程瞭。
到此這篇關於詳解PHP實現HTTP服務器過程的文章就介紹到這瞭,更多相關PHP HTTP服務器內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet!
推薦閱讀:
- 淺談swoole的作用與原理
- Python 實現一個簡單的web服務器
- Java面試題沖刺第六天–網絡編程1
- python socket多線程實現客戶端與服務器連接
- Node.js中的HTTP Server對象與GET、POST請求