PHPで動的Webサーバーを実装する方法-PHPチュートリアル-php.cn

この記事では主に PHP で動的 Web サーバーを実装する方法を紹介します。興味のある方はぜひ参考にしてください。

Web サーバーを実装する場合は、Web サーバーの動作原理を一般的に理解する必要があります。 Web サーバーにアクセスする 1.html を例として、静的テキストサーバーから始めましょう。サーバーがリッスンするポート番号が次の場合、クライアントはサーバーに http リクエストを送信します。 9002 の場合、このマシン自身のテストアクセスのアドレスは

http://localhost:9002/1.html です。 2. サーバーはポート 9002 をリッスンします。リクエストを受信した後、Web ディレクトリの http ヘッダーからアクセスする必要がある URI リソースを取得できます。。

3. サーバーは、アクセスする必要があるリソースファイルを読み取り、それを http エンティティに埋めてクライアントに返します。

概略図は次のとおりです。

php
<?php
class web_config {
 // 监听的端口号
 const PORT = 9003;
 // 项目根目录
 const WEB_ROOT = "/Users/zhoumengkang/Documents/html";
}
class server {
 private $ip;
 private $port;
 public function __construct($ip, $port) {
 $this->ip = $ip;
 $this->port = $port;
 $this->await();
 }
 private function await() {
 $sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
 if ($sock < 0) {
 echo "Error:" . socket_strerror(socket_last_error()) . "\n";
 }
 $ret = socket_bind($sock, $this->ip, $this->port);
 if (!$ret) {
 echo "BIND FAILED:" . socket_strerror(socket_last_error()) . "\n";
 exit;
 }
 echo "OK\n";
 $ret = socket_listen($sock);
 if ($ret < 0) {
 echo "LISTEN FAILED:" . socket_strerror(socket_last_error()) . "\n";
 }
 do {
 $new_sock = null;
 try {
 $new_sock = socket_accept($sock);
 } catch (Exception $e) {
 echo $e->getMessage();
 echo "ACCEPT FAILED:" . socket_strerror(socket_last_error()) . "\n";
 }
 try {
 $request_string = socket_read($new_sock, 1024);
 $response = $this->output($request_string);
 socket_write($new_sock, $response);
 socket_close($new_sock);
 } catch (Exception $e) {
 echo $e->getMessage();
 echo "READ FAILED:" . socket_strerror(socket_last_error()) . "\n";
 }
 } while (TRUE);
 }
 /**
 * @param $request_string
 * @return string
 */
 private function output($request_string){
 // 静态 GET /1.html HTTP/1.1 ...
 $request_array = explode(" ",$request_string);
 if(count($request_array) < 2){
 return $this->not_found();
 }
 $uri = $request_array[1];
 $filename = web_config::WEB_ROOT . $uri;
 echo "request:".$filename."\n";
 // 静态文件的处理
 if (file_exists($filename)) {
 return $this->add_header(file_get_contents($filename));
 } else {
 return $this->not_found();
 }
 }
 /**
 * 404 返回
 * @return string
 */
 private function not_found(){
 $content = "
<h1>File Not Found </h1>
";
 return "HTTP/1.1 404 File Not Found\r\nContent-Type: text/html\r\nContent-Length: ".strlen($content)."\r\n\r\n".$content;
 }
 /**
 * 加上头信息
 * @param $string
 * @return string
 */
 private function add_header($string){
 return "HTTP/1.1 200 OK\r\nContent-Length: ".strlen($string)."\r\nServer: mengkang\r\n\r\n".$string;
 }
}
$server = new server("127.0.0.1", web_config::PORT);

ログイン後にコピー

コードは github https://github.com/zhoumengkang/php にアップロードされています。 /tree/master/php-webserver/static

上記のコードで述べたように、ターミナルでファイルが実行されている限り、静的 Web サーバーが起動します。

下の写真は、Web ディレクトリ内の 1.jpg ファイルにアクセスしているスクリーンショットです。

単純な静的 Web サーバーが完成しました。次の質問は、動的コンテンツの出力をサポートする方法です。 Web サーバー内で特定のプログラムを実行し、結果をクライアントに返すだけでよいのでしょうか?しかし、このようにして、Web サーバーのコードはビジネスコードと結合されます。さまざまなビジネスシナリオで使用できる Web サーバーを解決するにはどうすればよいでしょうか。

CGI の登場により、この問題は解決されました。では、CGIとは何でしょうか？以下の文章をコピーします。

CGI は、外部アプリケーション (CGI プログラム) と Web サーバー間のインターフェース規格であり、CGI プログラムと Web サーバーの間で情報を転送するための手順です。 CGI 仕様により、Web サーバーが外部プログラムを実行し、その出力を Web ブラウザに送信できるようになり、Web の単純な静的ハイパーメディアドキュメントのセットが完全に新しい対話型メディアに変わります。

私は非常に混乱しています。たとえば、私たちが使用している PHP のグローバル変数

$_SERVER['QUERY_STRING']

は次のとおりです。 Web サーバーが CGI プロトコルを通じて使用するもの。たとえば、Nginx では、fastcgi 構成 コードが次のとおりであることを覚えているかもしれません:

fastcgi_param  
QUERY_STRING      
 $query_string;

ログイン後にコピー

はい、nginx は独自のグローバル変数

$query_string

を設定します。 fastcgi_param の環境変数に渡されます。 以下では、CGI の

QUERY_STRING

をブリッジとして使用し、クライアントから要求された URI 内の情報を CGI プログラムに渡します。 putenv を使用して、QUERY_STRING をリクエストの環境変数に保存します。 Web サーバーでアクセスされるリソースが

.cgi

であることに同意します。これは、php を見つけるために nginx で場所を設定するのと似ています。手順は同じです。 CGI プログラムをリクエストする必要があるかどうかを確認するのはすべてのルールです。 Web サーバーと区別するために、ユーザー情報を照会し、ユーザー ID に基づいてユーザー情報を照会する CGI プログラムを C で作成しました。 おおよそのアクセスロジックは以下の通りです

デモを実行したい場合は以下の操作を行う必要があります

#config.php

WEB_ROOT## のプロジェクトルートディレクトリを変更します。 #2.cgi-demo\user.c

をコンパイルし、コマンド gcc -o user.cgi user.c をコンパイルしてから user.cgi 設定したプロジェクトのルートディレクトリにファイルを置きます。3 php start.php を実行します。

ターミナルで次のようにします。 Web サーバーが開始されます。http://localhost:9003/user.cgi? id=1 訪問中に次のような効果が見られました。

実際、静的サーバーに基づいて CGI を作成したところです。リクエストが転送され、github 上の 3 つが処理されたと判断されました。ファイルのコードは、誰もが視聴できるように 1 つのファイルにマージされています。

php
<?php
class web_config {
 // 监听的端口号
 const PORT = 9003;
 // 项目根目录
 const WEB_ROOT = "/Users/zhoumengkang/Documents/html";
 // 系统支持的 cgi 程序的文件扩展名
 const CGI_EXTENSION = "cgi";
}
class server {
 private $ip;
 private $port;
 public function __construct($ip, $port) {
 $this->ip = $ip;
 $this->port = $port;
 $this->await();
 }
 private function await() {
 $sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
 if ($sock < 0) {
 echo "Error:" . socket_strerror(socket_last_error()) . "\n";
 }
 $ret = socket_bind($sock, $this->ip, $this->port);
 if (!$ret) {
 echo "BIND FAILED:" . socket_strerror(socket_last_error()) . "\n";
 exit;
 }
 echo "OK\n";
 $ret = socket_listen($sock);
 if ($ret < 0) {
 echo "LISTEN FAILED:" . socket_strerror(socket_last_error()) . "\n";
 }
 do {
 $new_sock = null;
 try {
 $new_sock = socket_accept($sock);
 } catch (Exception $e) {
 echo $e->getMessage();
 echo "ACCEPT FAILED:" . socket_strerror(socket_last_error()) . "\n";
 }
 try {
 $request_string = socket_read($new_sock, 1024);
 $response = $this->output($request_string);
 socket_write($new_sock, $response);
 socket_close($new_sock);
 } catch (Exception $e) {
 echo $e->getMessage();
 echo "READ FAILED:" . socket_strerror(socket_last_error()) . "\n";
 }
 } while (TRUE);
 }
 /**
 * @param $request_string
 * @return string
 */
 private function output($request_string){
 // 静态 GET /1.html HTTP/1.1 ...
 // 动态 GET /user.cgi?id=1 HTTP/1.1 ...
 $request_array = explode(" ",$request_string);
 if(count($request_array) < 2){
 return "";
 }
 $uri = $request_array[1];
 echo "request:".web_config::WEB_ROOT . $uri."\n";
 $query_string = null;
 if ($uri == "/favicon.ico") {
 return "";
 }
 if (strpos($uri,"?")) {
 $uriArr = explode("?", $uri);
 $uri = $uriArr[0];
 $query_string = isset($uriArr[1]) ? $uriArr[1] : null;
 }
 $filename = web_config::WEB_ROOT . $uri;
 if ($this->cgi_check($uri)) {
 $this->set_env($query_string);
 $handle = popen(web_config::WEB_ROOT.$uri, "r");
 $read = stream_get_contents($handle);
 pclose($handle);
 return $this->add_header($read);
 }
 // 静态文件的处理
 if (file_exists($filename)) {
 return $this->add_header(file_get_contents($filename));
 } else {
 return $this->not_found();
 }
 }
 /**
 * 设置环境变量 给 cgi 程序使用
 * @param $query_string
 * @return bool
 */
 private function set_env($query_string){
 if($query_string == null){
 return false;
 }
 if (strpos($query_string, "=")) {
 putenv("QUERY_STRING=".$query_string);
 }
 }
 /**
 * 判断请求的 uri 是否是合法的 cgi 资源
 * @param $uri
 * @return bool
 */
 private function cgi_check($uri){
 $info = pathinfo($uri);
 $extension = isset($info["extension"]) ? $info["extension"] : null;
 if( $extension && in_array($extension,explode(",",web_config::CGI_EXTENSION))){
 return true;
 }
 return false;
 }
 /**
 * 404 返回
 * @return string
 */
 private function not_found(){
 $content = "<h1>File Not Found </h1>";
 return "HTTP/1.1 404 File Not Found\r\nContent-Type: text/html\r\nContent-Length: ".strlen($content)."\r\n\r\n".$content;
 }
 /**
 * 加上头信息
 * @param $string
 * @return string
 */
 private function add_header($string){
 return "HTTP/1.1 200 OK\r\nContent-Length: ".strlen($string)."\r\nServer: mengkang\r\n\r\n".$string;
 }
}
$server = new server("127.0.0.1", web_config::PORT);

ログイン後にコピー

概要:上記がこの内容の全体です。この記事が皆さんの学習に役立つことを願っています。