c++ - 对FCGI概念感到困惑

我目前正在尝试实现一个在Linux上运行的小型FastCGI多线程应用程序。我使用fastcgi.com中的库。现在，我不确定我是否真的了解Web服务器和我的应用程序之间的FCGI通信原理。

首先，我在应用程序中创建一个新的套接字。我返回文件描述符。

int socketIn = 0;
struct sockaddr_un local;
int length = 0;
int value = 1;

memset(&local, 0, sizeof(local));

local.sun_family = AF_UNIX;

strcpy(local.sun_path, socketPath);

length = strlen(local.sun_path) + sizeof(local.sun_family);

/* delete old unix socket */
if(-1 == unlink(socketPath))
{
    switch (errno)
    {
        case ENOENT:
        {
        }break;

        default:
        {
            printf("\n[Error]\tCould not remove old socket.");
            return -1;
        }
    }
}

/* create new socket */
if (-1 == (socketIn = socket(AF_UNIX, SOCK_STREAM, 0)))
{
    printf("\n[Error]\tCould not create socket.");
    return -2;
}

/* bind socket */
if (-1 == bind(socketIn, (struct sockaddr *)&local, length))
{
    printf("\n[Error]\tCould not bind socket.");
    return -4;
}

return socketIn;

之后，我初始化FCGI库:FCGX_Init();
现在，我开始创建线程:

#define THREAD_COUNT 2

static int counts[THREAD_COUNT];

struct thread_data{
   int  thread_id;
   int  fcgiSocket;
};

struct thread_data thread_data_array[THREAD_COUNT];

int main(int argc, char** argv)
{
   int i;
   pthread_t id[THREAD_COUNT];
   for (i = 1; i < THREAD_COUNT; i++)
   {
      thread_data_array[i].thread_id = i;
      thread_data_array[i].fcgiSocket = fcgi.fcgiSocket;
      pthread_create(&id[i], NULL, doit, &thread_data_array[i]);
   }

   thread_data_array[0].thread_id = 0;
   thread_data_array[0].fcgiSocket = fcgi.fcgiSocket;

   doit((void *)&thread_data_array[0]);

   return 0;
}

最后是我的线程代码:

static void *doit(void *a)
{
    struct thread_data *my_data;
    my_data = (struct thread_data *) a;
    int rc, i;
    pid_t pid = getpid();
    FCGX_Request request;
    char *server_name;

    FCGX_InitRequest(&request, my_data->fcgiSocket, 0);

    for (;;)
    {
        static pthread_mutex_t accept_mutex = PTHREAD_MUTEX_INITIALIZER;
        static pthread_mutex_t counts_mutex = PTHREAD_MUTEX_INITIALIZER;

        /* Some platforms require accept() serialization, some don't.. */
        pthread_mutex_lock(&accept_mutex);
        rc = FCGX_Accept_r(&request);
        pthread_mutex_unlock(&accept_mutex);

        if (rc < 0)
            break;

        server_name = FCGX_GetParam("SERVER_NAME", request.envp);

        FCGX_FPrintF(request.out,
            "Content-type: text/html\r\n"
            "\r\n"
            "<title>FastCGI Hello! (multi-threaded C, fcgiapp library)</title>"
            "<h1>FastCGI Hello! (multi-threaded C, fcgiapp library)</h1>"
            "Thread %d, Process %ld<p>"
            "Request counts for %d threads running on host <i>%s</i><p><code>",
            my_data->thread_id, pid, THREAD_COUNT, server_name ? server_name : "?");

        pthread_mutex_lock(&counts_mutex);
        ++counts[my_data->thread_id];
        for (i = 0; i < THREAD_COUNT; i++)
            FCGX_FPrintF(request.out, "%5d " , counts[i]);
        pthread_mutex_unlock(&counts_mutex);

        FCGX_Finish_r(&request);
    }

    return NULL;
}

现在我担心我使用的插座。这三个线程将全部写入同一套接字。还有其他更好的方法来解决多线程FCGI应用程序的问题吗？

最佳答案

我回复的是旧帖子，但也许其他人可以从中受益。



没有什么可担心的!

根据Fast CGI规范，每个请求都有关联的ID，并且当线程将响应写回套接字时，它将请求的ID与其服务关联。因此，即使线程以不同的顺序写入，Web服务器也知道哪个响应是针对哪个请求的。规格在这里-

http://www.fastcgi.com/drupal/node/6?q=node/22

只要消息的大小小于PIPE_BUF，就可以保证对套接字的写操作是原子的。 libfcgi将写大小限制为PIPE_BUF。您可以在以下文件中进行检查-

http://www.fastcgi.com/mod_fastcgi/mod_fastcgi.h

#define FCGI_MAX_MSG_LEN  PIPE_BUF

希望这个解释消除疑惑!

关于c++ - 对FCGI概念感到困惑，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/14211689/