fcgi程序两种编写风格

fcgi进程可以写成单线程的，也可以写成多线程的。

单线程就是main函数中有一个死循环，一直等待接受请求，有请求过来时，就处理请求，并返回结果，没有并发性。

多线程也分两种模式：一种是main函数起多个线程，每个线程都独立接受请求。另一种是main函数起一个accpet线程接受请求，多个do_session线程处理请求，这种模式需要一个任务队列的支持。

模式不同，采用的系统架构就不同。下面就这三种模型，给出编码架构设计。

单线程模式：

#include <fcgi_stdio.h>
#include <stdlib.h>
#include <string>

int main()
{
    while(FCGI_Accept() >= 0)
    {
        string strGetData;
        int iContentLength;
        if (getenv("QUERY_STRING"))
        {
            strGetData = getenv("QUERY_STRING");
        }
        if (getenv("CONTENT_LENGTH"))
        {
            iContentLength = ::atoi(getenv("CONTENT_LENGTH"));
        }
        char* data = (char*)::malloc(iContentLength + 1);
        ::memset(data, 0, iContentLength + 1);
        FCGI_fgets(data, iContentLength + 1, FCGI_stdin);
        FCGI_printf("Content-type:text/html\r\n\r\n");
        FCGI_printf(data);
    }
    return 0;
}

多线程模式，每个线程都独立接受请求：

#include <fcgi_stdio.h>
#include <stdlib.h>
#include <pthread.h>
#include <string>

void* pthread_func(void *arg);

int main()
{
    int iThreadNum = 10;
    for (int index = 0; index != iThreadNum; ++ index)
    {
        pthread_t pthread_id;
        pthread_create(&pthread_id, NULL, pthread_func, NULL);
    }

    pthread_join();
    return 0;
}

void* pthread_func(void *arg)
{
    FCGX_Request *request = NULL;
    while (1)
    {
        int rc = FCGX_Accept_r(request);
        if (rc < 0)
        {
            continue;
        }

        string strRequestMethod;
        string strGetData;
        string strPostData;
        int iPostDataLength;

        if (FCGX_GetParam("QUERY_STRING", request->envp))
        {
            strGetData = FCGX_GetParam("QUERY_STRING", request->envp);
        }
        if (FCGX_GetParam("REQUEST_METHOD", request->envp))
        {
            iPostDataLength = ::atoi(FCGX_GetParam("CONTENT_LENGTH", _pRequest->envp));
            char* data = (char*)malloc(iPostDataLength + 1);
            ::memset(data, 0, iPostDataLength + 1);
            FCGX_GetStr(data, iPostDataLength, _pRequest->in);
            strPostData = data;
            free(data);
        }

        FCGX_PutS("Content-type: text/html\r\n\r\n", _pRequest->out);
        FCGX_PutS(strPostData.c_str(), _pRequest->out);
    }
}

多线程模式，一个accpet线程，多个do_session线程：

#include <fcgi_stdio.h>
#include <stdlib.h>
#include <pthread.h>
#include <string>

void* do_accept(void *arg);
void* do_session(void *arg);

int main()
{
    pthread_t pthread_id;
    pthread_create(&pthread_id, NULL, do_accept, NULL);
    int iThreadNum = 10;
    for (int index = 0; index != iThreadNum; ++ index)
    {
        pthread_t pthread_id;
        pthread_create(&pthread_id, NULL, do_session, NULL);
    }

    pthread_join();
    return 0;
}

void* do_accept(void *arg)
{
    FCGX_Request *request = NULL;
    while (1)
    {
        int rc = FCGX_Accept_r(request);
        if (rc < 0)
        {
            continue;
        }
        httpRequest.put(request); //httpRequest 是一个生产者消费者模型，此处是放入任务
    }
}

void* do_session(void *arg)
{
    while(1)    
    {
        FCGX_Request *request = NULL;
        while (!request)
        {
            request = httpRequest.get(); //此处是取出任务
        }

        string strRequestMethod;
        string strGetData;
        string strPostData;
        int iPostDataLength;

        if (FCGX_GetParam("QUERY_STRING", request->envp))
        {
            strGetData = FCGX_GetParam("QUERY_STRING", request->envp);
        }
        if (FCGX_GetParam("REQUEST_METHOD", request->envp))
        {
            iPostDataLength = ::atoi(FCGX_GetParam("CONTENT_LENGTH", _pRequest->envp));
            char* data = (char*)malloc(iPostDataLength + 1);
            ::memset(data, 0, iPostDataLength + 1);
            FCGX_GetStr(data, iPostDataLength, _pRequest->in);
            strPostData = data;
            free(data);
        }

        FCGX_PutS("Content-type: text/html\r\n\r\n", _pRequest->out);
        FCGX_PutS(strPostData.c_str(), _pRequest->out);
    }
}

工作到目前为止，只见了这三种模型，如果哪位好友有其他的模型，欢迎指点一下，在下不胜感激~~~