1. 介紹
由于CGI解釋器的反復(fù)加載會使CGI性能低下秩彤，F(xiàn)astCGI可以將CGI解釋器保持在內(nèi)存中嘹叫， 提高性能
相關(guān)地址：https://fastcgi-archives.github.io
2. Fastcgi特點：
- 性能
- 簡單迷雪，容易移植
- 語言無關(guān)
- 進程隔離
- 通用性碘勉，主流WebServer都支持，nginx奇瘦、apache都支持
- 支持分布式計算棘催，F(xiàn)astCGI提供遠程運行應(yīng)用程序的功能，這對于分發(fā)負載和管理外部Web站點非常有用（這點待驗證是否好用耳标，我希望的能支持異步處理）
3. 原理
- 簡單來說醇坝，利用后面說的spawn-fcgi（fastcgi的管理程序）啟動fastcgi，支持啟動多實例次坡，并通過socket進行數(shù)據(jù)綁定
- WebServer（如：nginx）在收到請求后呼猪，根據(jù)配置中配置要轉(zhuǎn)發(fā)的fastcgi地址，發(fā)到固定的地址砸琅，例如：fastcgi綁定的是127.0.0.1：8088
- fastcgi Accept并處理數(shù)據(jù)后宋距，將響應(yīng)數(shù)據(jù)通過Socket返回給WebServer，并斷開連接症脂，這時表示一次處理完成
管理程序 -- spawn-fcgi
下載地址：http://redmine.lighttpd.net/projects/spawn-fcgi/wiki
-f 指定調(diào)用 FastCGI的進程的執(zhí)行程序位置
-a 綁定到 地址addr乡革。
-p 綁定到 端口 port。
-s 綁定到 unix domain socket
-C 指定產(chǎn) 生的FastCGI的進程數(shù)摊腋， 默認為 5沸版。 （ 僅用 于PHP）
-P 指定產(chǎn) 生的進程的PID文件路徑。
-F 指定產(chǎn) 生的FastCGI的進程數(shù)（ C的CGI用 這個）
例子：./spawn-fcgi -a 127.0.0.1 -p 8088 -F 500 -f cgi（啟動500個cgi程序兴蒸，監(jiān)聽的端口為8088视粮，綁定地址為127.0.0.1）
4. nginx如何配置
- fastcgi_pass
fastcgi_pass address;
address為后端的fastcgi server的地址
可用位置：location,if in location - fastcgi_index
fastcgi_index name;
fastcgi默認的主頁資源
示例：fastcgi_index index.php; - fastcgi_param
fastcgi_param parameter value [if_not_empty];
設(shè)置傳遞給FastCGI服務(wù)器的參數(shù)值，可以是文本橙凳，變量或組合
5. 阻塞與非阻塞模式
fastcgi示例 -- 阻塞模式
#include "fcgi_stdio.h"
#include <stdlib.h>
void main(void)
{
int count = 0;
while(FCGI_Accept() >= 0)
printf("Content-type: text/html\r\n"
"\r\n"
"<title>FastCGI Hello!</title>"
"<h1>FastCGI Hello!</h1>"
"Request number %d running on host <i>%s</i>\n",
++count, getenv("SERVER_NAME"));
}
fastcgi示例 -- 生產(chǎn)者蕾殴，消費者模式（可實現(xiàn)非阻塞）
非阻塞的實現(xiàn)，將會話狀態(tài)與requests進行binding即可
ZEN_Message_Queue_Deque<ZEN_MT_SYNCH, uint32_t> t_que(100000);
// 這步非常關(guān)鍵岛啸，因為FCGX_Accept_r中的數(shù)據(jù)流綁定是直接和request的ptr進行綁定的
// 所以在未處理完數(shù)據(jù)的前提下钓觉，requests的生命周期要和會話的生命周期一致
FCGX_Request requests[1000];
uint32_t use_idx[1000];
void *do_session(void *arg)
{
int ret = 0;
while (1)
{
uint32_t idx = 0;
ret = t_que.try_dequeue(idx);
if (ret != 0)
{
// no data sleep 1ms
usleep(1000);
continue;
}
FCGX_Request &request = requests[idx];
std::string out = "Content-type:application/json\r\n\r\n";
Json::Value root;
root["ret"] = 1000;
root["t_id"] = (int)gettid();
out.append(root.toStyledString());
FCGX_FPrintF(request.out, out.c_str());
FCGX_Finish_r(&request);
use_idx[idx] = 0;
}
return NULL;
}
int get_free()
{
static uint32_t idx = 0;
for (; idx < 1000; idx ++)
{
if (use_idx[idx] == 0)
{
use_idx[idx] = 1;
return idx;
}
}
return -1;
}
int main(int argc, char **argv)
{
pthread_t pthread_id;
int iThreadNum = 10;
for (int index = 0; index != iThreadNum; ++ index)
{
pthread_create(&pthread_id, NULL, do_session, NULL);
}
memset(use_idx, 0, sizeof(use_idx));
int ret = FCGX_Init();
if (ret != 0)
{
printf("init fail\n");
return -1;
}
while (1)
{
int idx = get_free();
if (idx < 0)
{
continue;
}
FCGX_Request &request = requests[idx];
ret = FCGX_InitRequest(&request, 0, 0);
if (ret != 0)
{
printf("init fail\n");
return -1;
}
ret = FCGX_Accept_r(&request);
if (ret < 0)
{
continue;
}
t_que.enqueue(idx);
}
return 0;
}
