HTTPサーバでのPOSTが来た際の処理

Question

POSTリクエストが来た際に標準入力からcgiにパラメータを渡すということはわかりますが
具体的にどのように処理をしていいのかわかりません。教えてください
また、今回のプログラムはGET、POSTの両方でcgiにパラメータを渡して処理できるHTTPサーバを目指しています。プログラムに不備があれば指摘してくれればと思います。

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <sys/fcntl.h>              
#include <sys/wait.h>
#include <sys/types.h>
#include <arpa/inet.h>

#define MAXPENDING 5

void DieWithError(char *errorMessage);
int CreateTCPServerSocket(unsigned short port);
int AcceptTCPConnection(int servSock);
int sendMessage(int fd, char *msg);
void sendHeader(int clntSock);
int http(int clntSock);
void cgiMethod(int clntSock, char *uri_file, char *value);


/* ========================== */

int main( int argc,char *argv[] ) 
{
    int servSock;
    int clntSock;
    unsigned short ServPort;
    
    int clnt_len;
    int rc = 0;
    pid_t processID;
    unsigned int ProcessCount = 0;
    
    struct sockaddr_in serv_addr;           
    struct sockaddr_in clnt_addr;
    
    // serverPort
    if( argc != 2 )
    {
        fprintf(stderr, "Usage: %s <server port>\n",argv[0]);
        exit(1);
    }
    
    ServPort = atoi(argv[1]);
    servSock = CreateTCPServerSocket(ServPort);
    
    while(1) 													
    {
        clntSock = AcceptTCPConnection(servSock);
		
        if ( (processID = fork()) < 0 )
        {
            fprintf(stderr, "error: fork() failed");
            return 1;
        }
        else if ( processID == 0 )
        {
            close(servSock);
            http(clntSock);
            return 0;
        }
        
        // 親プロセス
        printf("with process1: %d\n", (int) processID);
        close(clntSock);                                           
        ProcessCount++;                                      
        
        //プロセスの回収
        while( ProcessCount )
        {
            processID = waitpid((pid_t) -1, NULL, WNOHANG);
            if(processID < 0)
            {                                                       
                fprintf(stderr, "error: waitpid() failed");
                break;
            }
            else if(processID == 0)                                
                break;
            else
                ProcessCount--;
        }
    }
}

/* ========================== */


/* errerMessage */
void DieWithError(char *errorMessage){
    perror(errorMessage);
    exit(1);
}

/* soket,bind,listen */
int CreateTCPServerSocket(unsigned short port){
    
    int sock;
    struct sockaddr_in echoServAddr;
    
    if((sock = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP)) < 0)
        DieWithError("socket() failed");
    
    // 構造体の初期化
    memset(&echoServAddr, 0, sizeof(echoServAddr));
    
    echoServAddr.sin_family = AF_INET;
    echoServAddr.sin_addr.s_addr = htonl(INADDR_ANY);
    echoServAddr.sin_port = htons(port);
    
    // localAddrへbind
    if(bind(sock, (struct sockaddr *) &echoServAddr, sizeof(echoServAddr)) < 0)
        DieWithError("bind() failed");
    
    if(listen(sock, MAXPENDING) < 0)
        DieWithError("listen() failed");
    
    return sock;
}

/* Accept */
int AcceptTCPConnection(int servSock){
    int clntSock;
    struct sockaddr_in echoClntAddr;
    unsigned int clntLen;
    
    clntLen = sizeof(echoClntAddr);
    
    if((clntSock = accept(servSock, (struct sockaddr *) &echoClntAddr, &clntLen)) < 0)
        DieWithError("accept() failed");
    
    printf("Handling client %s\n", inet_ntoa(echoClntAddr.sin_addr));
    
    return clntSock;
}

void sendHeader( int clntSock ) {
    sendMessage( clntSock, "HTTP/1.1 200 OK\r\n" );
    sendMessage( clntSock, "Content-type: text/html; charset=UTF-8\r\n" );
    sendMessage( clntSock, "\r\n" );
}

int sendMessage(int fd, char *msg){
    int msg_len;
    msg_len = strlen(msg);
        
    if ( write(fd, msg, msg_len) != msg_len )
    {
        fprintf(stderr, "error: writing.");
    }
    return msg_len;
}

int http(int clntSock){
    int len;
    int read_fd;
    char buf[1024];
    pid_t processID;                    
    unsigned int ProcessCount = 0;
    
    char method_name[16];
    char uri_addr[256];
    char http_ver[64];
    char *uri_file;
    char *value;
    
    if(read(clntSock, buf, 1024) <= 0 )                  
    {
        fprintf(stderr, "error: reading a request.\n");
        exit(1);
    } 
	
    sscanf(buf, "%s %s %s", method_name, uri_addr, http_ver);
    //printf("%s %s %s\n", method_name, uri_addr, http_ver);
    
	uri_file = uri_addr + 1;
    
    if (strcmp(method_name, "GET") == 0)
    {
        if (strstr(uri_addr, ".cgi") != NULL)
        {
            uri_file = strtok(uri_file, "?");      
            value = strtok(NULL, "");
            cgiMethod(clntSock, uri_file, value);            
            close(clntSock);              
        }
        else{
            if ((read_fd = open(uri_file, O_RDONLY, 0666)) < 0)
            {
                sendMessage(clntSock, "404 Not Found");
                return 1;
            }
            
            sendHeader(clntSock);
            
            while ((len = read(read_fd, buf, 1024)) > 0)
            {
                if (write(clntSock, buf, len) != len)
                {
                    fprintf(stderr, "error: writing a response.\n");
                    break;
                }
            }
            close(read_fd);
        }
    }
    else if ( strcmp(method_name, "POST" ) == 0) {
    
        //
        //ここをどのように書くかわからない
        //

        close(clntSock);
    }
	else {
        sendMessage(clntSock, "501 Not Implemented");
        exit(1);
    }
}

void cgiMethod(int clntSock, char *uri_file, char *value){
    
    pid_t processID;
    unsigned int ProcessCount = 0;
    int fd[2];
    int len;
    char buf[1024];
    
    
    pipe(fd);
    
    if((processID = fork()) < 0)
    {
        fprintf(stderr, "error: fork() failed");
        exit(1);
    }
    else if(processID == 0)				
    {
        close(fd[0]);
        dup2(fd[1], 1);
        
        setenv("QUERY_STRING" ,value, 1);
        
        if (execl(uri_file, "", NULL) < 0)
        {
            fprintf(stderr, "error: execl() failed\n");
            exit(1);
        }

        close(clntSock);              
        ProcessCount++;
        exit(0);
    }
    
    close(fd[1]);
    
    sendHeader(clntSock);
    while((len = read(fd[0], buf, sizeof(buf))) > 0)      
    {
        if(write(clntSock, buf, len) != len)             
        {   
            fprintf(stderr, "error: writing a response.\n");
            break;
        }
    }
    
    // プロセスの回収
    printf("with process2: %d\n", (int) processID);
    
    while(ProcessCount)
    {
        processID = waitpid((pid_t) -1, NULL, WNOHANG);
        if(processID < 0)
        {                                                       
            fprintf(stderr, "error: waitpid() failed");
            break;
        }
        else if(processID == 0)                                
            break;
        else
            ProcessCount--;
    }
    
    close(fd[0]);
}

Answer 1

clntSockからreadしたものを、先頭からきちんとHTTPプロトコルに従って解析して、リクエストボディ部分をPOSTデータとします。

あと、アドバイスとしては、read(clntSock,buf,1024)するのでなく、fdopenを使って、

FILE *fp;
～～～
if(!(fp=fdopen(clntSock,"r"))){
  エラー処理
}
if(!fgets(buf,1024,fp)){
  エラー処理
}

のようにfgetsで行単位で読んだ方が、リクエストやリクエストヘッダの解析をするときに楽です。
空行の後ろが、ボディ。
ボディを読むときは、fgetsでなくfreadで。