如何用C写一个web服务器之基础功能

服务器架构

目标架构

以 nginx 的思想来考虑本服务器架构，初步考虑如下图：

如何用C写一个web服务器之基础功能

当然 php 进程也可以替换为其他的脚本语言，可以更改源码中的 command 变量实现。

服务器有一个 master 进程，其有多个子进程为 worker 进程，master 进程受理客户端的请求，然后分发给 worker 进程，worker 进程处理 http 头信息后将参数传递给 php 进程处理后，将结果返回到上层，再响应给客户端。

也考虑过使用 php-fpm 的 worker 进程池方式，那样的话 php-fpm 进程也要仿写了，目前还不熟悉其内部构造，如果可以简单化，自然向其靠拢。目前对 PHP 的 SAPI 接口不熟，了解一下再考虑。

当前状态

当前状态的服务器还极其简单，总结下来有以下地方待优化：

当前还是单进程，需要改成多进程，最终为 worker 进程池方式；
优化 socket IO 模型，考虑 epoll、事件驱动方式；
只支持 HTTP GET 请求方法，未进行太多的异常处理来定义 http 状态码；
与 php 进程的交互方式，考虑如 nginx 使用 unix domain socket 方式。
协议目前只考虑了 http，后续会考虑一些基于 TCP 的协议；

虽然简单，但服务器已经有基本的功能了：

它监听本地地址的 8080 端口，将接收到的 http 头中的 path 信息提出出来交给 php 进程，php 进程将参数信息处理后返回给服务器，服务器拼装 http 响应信息再将结果返回给客户端。

下面介绍各个功能的实现：

功能实现

socket系列方法

在介绍函数之间先用一张图来介绍一次 http 请求中客户端与服务器之间的交互：

如何用C写一个web服务器之基础功能

如图：服务器创建要进行：

1.调用 socket() 创建一个连接；int socket(int domain, int type, int protocol);

2.调用 bind() 给套接字命名，绑定端口；int bind( int socket, const struct sockaddr *address, size_t address_len);

3.调用 listen() 监听此套接字；int listen(int socket, int backlog);

4.调用 accept() 接受客户端的连接；int accept(int socket, struct sockaddr *address, size_t *address_len);

5.调用 recv() 接收客户端的信息；int recv(int s, void *buf, int len, unsigned int flags);

6.调用 send() 将响应信息发送给客户端；int send(int s, const void * msg, int len, unsigned int falgs);

socket 间的接收和发送信息在 C 中有几个系列：write() / read() 、send() / recv() 、sendto() / recvfrom()、 sendmsg() / recvmsg(),可以自行选用。

另外函数参数释义和要点，都被我注释在代码中了，感兴趣的可以拉下来看一下，这些在网上也多有介绍，这里不再赘述。

服务器与 PHP cli 交互

然后是 C 进程和 php 进程的交互，考虑到简单易用，目前在 C 进程中直接执行 php 脚本：

一开始使用 system() 函数: int system(const char *command);

system 函数会 fork 一个子进程，在子进程中以 cli 方式执行 php 脚本，并将错误码或返回值返回。由于其结果类型不可控，编译时会报一个 warning。而且它将结果返回给父进程时，还会在标准输出中打印结果，在服务器执行时会抛出异常。

于是找到了另一个方法 popen， FILE * popen(const char * command, const char * type);：

popen 同样会 fork 一个子进程来执行 command ，然后建立管道连到子进程的标准输出设备或标准输入设备，然后返回一个文件指针。随后进程便可利用此文件指针来读取子进程的输出设备或是写入到子进程的标准输入设备中。

其 type 参数便是控制连接到子进程的标准输入还是标准输出。我们想要子进程的标准输出，于是传入 type参数为字符 “r” (read)。同理，如果想写入子进程标准输入的话，可以传值 “w”（write）。

另外在接收缓冲区内容的时候也出现了一点小意外：由于使用的 fgets() 方法会以换行符为一段的结尾，在接收 php 进程输出时遇到换行会结束，这里使用了一个中间字符串数组line来接收每一行的信息，将每一行的信息拼装到结果中。

代码如下：

char * execPHP(char *args){
    // 这里不能用变长数组，需要给command留下足够长的空间，以存储args参数，不然拼接参数时会栈溢出
    char command[BUFF_SIZE] = "php /Users/mfhj-dz-001-441/CLionProjects/cproject/tinyServer/index.php ";
    FILE *fp;
    static char buff[BUFF_SIZE]; // 声明静态变量以返回变量指针地址
    char line[BUFF_SIZE];
    strcat(command, args);
    memset(buff, 0, BUFF_SIZE); // 静态变量会一直保留，这里初始化一下
    if((fp = popen(command, "r")) == NULL){
        strcpy(buff, "服务器内部错误");
    }else{
        // fgets会在获取到换行时停止，这里将每一行拼接起来
        while (fgets(line, BUFF_SIZE, fp) != NULL){
        strcat(buff, line);
        };
    }

    return buff;
}