FastCGI分布式架构解析

在构建高效能Web服务的过程中，FastCGI技术因其能够显著提升应用性能而被广泛采用。本文将基于Lighttpd Web服务器，详细阐述如何利用FastCGI实现分布式架构。

### 架构概述

设想一个场景：有一台中心服务器（记作Server A），其上安装并运行了Lighttpd Web服务器。此服务器的主要职责是对客户端的所有请求进行初步处理和分发。此外，还有若干台工作服务器，每台服务器上都运行着一个或多个FastCGI进程。这些进程负责接收从Server A转发来的请求，并执行相应的业务逻辑处理。

### Lighttpd 配置详解

为了使Lighttpd能够正确地将请求转发给FastCGI进程，需要对其进行适当的配置。具体来说，如果FastCGI进程运行在与Lighttpd相同的服务器上，则应使用Unix域套接字；若FastCGI进程位于不同的服务器，则需指定IP地址和端口号。

```plaintext
server.document-root = "/mnt/hgfs/share/test/fcgi/"
server.port = 9090
socket_dir = "/tmp/"
server.username = "weifeilong"
server.groupname = "weifeilong"
server.errorlog = "/mnt/hgfs/share/test/fcgi/err.log"
mimetype.assign = (
".html" => "text/html",
".txt" => "text/plain",
".jpg" => "image/jpeg",
".png" => "image/png"
)
static-file.exclude-extensiOns= ( ".fcgi", ".php", ".rb", "~", ".inc" )
index-file.names = ( "index.html" )
server.modules += ("mod_fastcgi")
fastcgi.server = (
"/fellow" => (
"test.fastcgi.handler" => (
"host" => "127.0.0.1", // 对于远程FastCGI进程，此处应填写对应的IP地址
"port" => "9090",
# "socket" => socket_dir + "test.fastcgi.socket", // 当FastCGI与Lighttpd同机时使用
"check-local" => "disable",
# "bin-path" => "/mnt/hgfs/share/test/fcgi/test.fastcgi",
"max-procs" => 10,
)
)
)
```

### FastCGI 进程实现

接下来，我们将展示一个简单的FastCGI进程示例，该进程监听特定的IP地址和端口，准备接收来自Lighttpd的请求。

```c
#include
#include
#include
#include
#include

#define LISTENSOCK_FILENO 0
#define LISTENSOCK_FLAGS 0

int main(int argc, char** argv) {
openlog("testfastcgi", LOG_CONS | LOG_NDELAY, LOG_USER);
int err = FCGX_Init();
if (err) {
syslog(LOG_INFO, "FCGX_Init failed: %d", err);
return 1;
}
FCGX_Request cgi;
int sock = FCGX_OpenSocket("127.0.0.1:9090", 10); // 监听127.0.0.1:9090端口
err = FCGX_InitRequest(&cgi, sock, LISTENSOCK_FLAGS);
if (err) {
syslog(LOG_INFO, "FCGX_InitRequest failed: %d", err);
return 2;
}
while (1) {
err = FCGX_Accept_r(&cgi);
if (err) {
syslog(LOG_INFO, "FCGX_Accept_r stopped: %d", err);
break;
}
char* header = (char*) alloca(200);
strcpy(header, "Status: 200 OK\r\nContent-Type: text/html\r\n\r\n");
FCGX_PutStr(header, strlen(header), cgi.out);
char response[1024];
if (!strncmp("GET", FCGX_GetParam("REQUEST_METHOD", cgi.envp), strlen("GET"))) {
FCGX_PutStr("GET", strlen("GET"), cgi.err);
if (!strncmp("action=getInfo", FCGX_GetParam("QUERY_STRING", cgi.envp), strlen("action=getInfo"))) {
snprintf(response, sizeof(response), "{\"action\": \"getInfo\"}\n");
}
} else if (!strncmp("POST", FCGX_GetParam("REQUEST_METHOD", cgi.envp), strlen("POST"))) {
char *post_data = (char*)malloc(1024);
FCGX_GetStr(post_data, 1024, cgi.in);
FCGX_PutStr(post_data, 1024, cgi.err);
if (!strncmp("action=resetInfo", post_data, strlen("action=resetInfo"))) {
snprintf(response, sizeof(response), "{\"action\": \"resetInfo\"}\n");
}
}
FCGX_PutStr(response, strlen(response), cgi.out);
}
return 0;
}
```

在完成上述配置和编程后，首先确保所有FastCGI进程已经启动，之后再启动Lighttpd服务。这样，当用户访问相关页面时，Lighttpd会自动将请求转发至相应的FastCGI进程，由后者完成具体的处理任务。