PHP 进阶之路 - 用 PHP 来实现一个动态 Web 服务器

JohnLui 发布于2019-06-27 11:22 / 1260人阅读

摘要：先从静态的文本服务器开始，以访问服务器的为例客户端通过发送一个请求到服务器，如果服务器监听的端口号是，那么在本机自身测试访问的地址就是。

最近老铁开了直播，欢迎来捧场！PHP 进阶之路适合从业两到三年遇到瓶颈的老铁，疗效好，见效快。

本文所实现的服务器仅仅是演示和理解原理所用，力求简单易懂。有兴趣的朋友可以继续深入改造

要是现实一个 web 服务器，那么就需要大概了解 web 服务器的运行原理。先从静态的文本服务器开始，以访问 web 服务器的1.html为例

1.客户端通过发送一个 http 请求到服务器，如果服务器监听的端口号是9002，那么在本机自身测试访问的地址就是http://localhost:9002/1.html。

2.服务器监听着9002端口，那么在收到请求了请求之后，就能从 http head 头中获取到请求里需要访问的 uri 资源在web 目录中的位置。

3.服务器读取需要访问的资源文件，然后填充到 http 的实体中返回给客户端。

示意图如下：

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()) . "
";
        }
        $ret = socket_bind($sock, $this->ip, $this->port);
        if (!$ret) {
            echo "BIND FAILED:" . socket_strerror(socket_last_error()) . "
";
            exit;
        }
        echo "OK
";
        $ret = socket_listen($sock);
        if ($ret < 0) {
            echo "LISTEN FAILED:" . socket_strerror(socket_last_error()) . "
";
        }
        do {
            $new_sock = null;
            try {
                $new_sock = socket_accept($sock);
            } catch (Exception $e) {
                echo $e->getMessage();
                echo "ACCEPT FAILED:" . socket_strerror(socket_last_error()) . "
";
            }
            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()) . "
";
            }
        } 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."
";
        // 静态文件的处理
        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 = "File Not Found ";
        return "HTTP/1.1 404 File Not Found
Content-Type: text/html
Content-Length: ".strlen($content)."

".$content;
    }
    /**
     * 加上头信息
     * @param $string
     * @return string
     */
    private function add_header($string){
        return "HTTP/1.1 200 OK
Content-Length: ".strlen($string)."
Server: mengkang

".$string;
    }
}
$server = new server("127.0.0.1", web_config::PORT);

代码已经上传 github https://github.com/zhoumengka...

如上代码所述，只要在终端执行该文件，那么一个静态的 web 服务器就启动啦。

下图为我访问我 web 目录下的1.jpg文件的截图

简单的静态 web 服务器已经完成了，下面的问题就是怎么让其支持动态内容的输出了。是不是只需要在 web 服务器内部执行完某个程序之后，把得到的结果返回给客户端就行呢？但是这样 web 服务器的代码就和业务代码耦合在一起了，怎么解决一个 web 服务器，可以运用在各个业务场景下呢？

CGI 的出现解决了这一问题。那么 CGI 是什么呢？下面这段话复制的：

CGI是外部应用程序（CGI程序）与Web服务器之间的接口标准，是在CGI程序和Web服务器之间传递信息的规程。CGI规范允许Web服务器执行外部程序，并将它们的输出发送给Web浏览器，CGI将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后缀则表示是动态访问，这一点有点儿类似于 nginx 里配置 location 来寻找 php 脚本程序一样。都是一种检查是否应该请求 cgi 程序的规则。为了和 Web 服务器区别开来，我用 C 写了一个查询用户信息的 cgi 程序，根据用户 id 查询用户资料。

大致的访问逻辑如下图

演示代码地址：https://github.com/zhoumengka...

如果要运行该 demo 需要做如下操作

1.修改config.php里的项目根目录WEB_ROOT

2.编译cgi-demouser.c，编译命令gcc -o user.cgi user.c，然后将user.cgi文件放入你配置的项目根目录下面

3.在终端执行php start.php ,这样该 web 服务器就启动了

4.通过 http://localhost:9003/user.cgi?id=1 就可以访问看到如下效果了

其实只是在静态服务器的基础上做了一些 cgi 的判断是请求的转发处理，把github 上的三个文件的代码合并到一个文件里方便大家观看

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()) . "
";
        }
 
        $ret = socket_bind($sock, $this->ip, $this->port);
        if (!$ret) {
            echo "BIND FAILED:" . socket_strerror(socket_last_error()) . "
";
            exit;
        }
        echo "OK
";
 
        $ret = socket_listen($sock);
        if ($ret < 0) {
            echo "LISTEN FAILED:" . socket_strerror(socket_last_error()) . "
";
        }
 
        do {
            $new_sock = null;
            try {
                $new_sock = socket_accept($sock);
            } catch (Exception $e) {
                echo $e->getMessage();
                echo "ACCEPT FAILED:" . socket_strerror(socket_last_error()) . "
";
            }
            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()) . "
";
            }
        } 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."
";
        $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 = "File Not Found ";
        return "HTTP/1.1 404 File Not Found
Content-Type: text/html
Content-Length: ".strlen($content)."

".$content;
    }
    /**
     * 加上头信息
     * @param $string
     * @return string
     */
    private function add_header($string){
        return "HTTP/1.1 200 OK
Content-Length: ".strlen($string)."
Server: mengkang

".$string;
    }
}

$server = new server("127.0.0.1", web_config::PORT);

最近老铁开了直播，欢迎来捧场！

PHP 进阶之路 - 亿级 pv 网站架构的技术细节与套路

PHP 进阶之路 - 后端多元化之快速切入 Java 开发

GPU云服务器云服务器做一个php动态网页 php实现动态菜单发布一个用PHP 用php输出一个菱形

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/21027.html

PHP 进阶之路 - 后端多元化之快速切入 Java 开发

摘要：以实现自己熟悉的东西为导向比如我们做后端开发，首先是常用的循环迭代条件判断增删改成。它是由实现的，不保证元素的顺序，也就是说所说元素插入的顺序与输出的顺序不一致。下面是我直播的文字版，直播地址：https://segmentfault.com/l/15...代码：https://github.com/zhoumengka...整个项目我们我又细分了6个版本来演进，希望更加便于大家对比...

Cristic 2019-08-15 11:00 评论0 收藏0
PHP 进阶之路 - 后端多元化之快速切入 Java 开发

摘要：以实现自己熟悉的东西为导向比如我们做后端开发，首先是常用的循环迭代条件判断增删改成。它是由实现的，不保证元素的顺序，也就是说所说元素插入的顺序与输出的顺序不一致。下面是我直播的文字版，直播地址：https://segmentfault.com/l/15...代码：https://github.com/zhoumengka...整个项目我们我又细分了6个版本来演进，希望更加便于大家对比...

xi4oh4o 2019-06-27 17:08 评论0 收藏0
PHP 进阶之路 - 深入理解 FastCGI 协议以及在 PHP 中的实现

摘要：与传统模式的区别之一则是服务器不是直接执行程序了，而是通过与响应器进程管理器进行交互，服务器需要将接口数据封装在遵循协议包中发送给响应器程序。正是由于进程管理器是基于通信的，所以也是分布式的，服务器和响应器服务器分开部署。广告很多工程师在工作1~3年的时候最容易遇到瓶颈，不知道自己应该学习什么，面试总是吃闭门羹。那么 PHP 后面应该怎么学呢？安利一波我的系列直播《PHP 进阶之...

chavesgu 2019-06-27 16:48 评论0 收藏0
PHP 进阶之路 - 亿级 pv 网站架构实战之性能压榨

摘要：业务和架构不分家，架构是建立在对业务的理解之上的。主键最好保持顺序递增，随机主键会导致聚簇索引树频繁分裂，随机增多，数据离散，性能下降。没有索引的更新，可能会导致全表数据都被锁住。本博客并非全部原创，其实是一个知识的归纳和汇总，里面我引用了很多网上、书上的内容。也给出了相关的链接。本文涉及的知识点比较多，大家可以根据关键字去搜索相关的内容和购买相应的书籍进行系统的学习。不对的地方...

SnaiLiu 2019-06-28 13:18 评论0 收藏0
PHP 进阶之路 - 揭开 PHP 线程安全的神秘面纱

摘要：如果现有子进程中的线程总数不能满足负载，控制进程将派生新的子进程。为解决线程的并发问题，引入了线程安全资源管理器。的全拼，用来存放各个线程的链表。 PHP 进阶之路 - 零基础构建自己的服务治理框架（上） PHP 进阶之路 - 零基础构建自己的服务治理框架（下） PHP 进阶之路 - 亿级 pv 网站架构的技术细节与套路 PHP 进阶之路 - 亿级 pv 网站架构实战之性能压榨注...

pepperwang 2019-06-27 16:54 评论0 收藏0