2

サーバープログラムでマルチスレッドを使用して、ブラウザからリクエストを受け取ったときにサーバーがtxtファイルを開いてブラウザに送信して表示するようにしようとしています。私がする必要があるのは、次のようなブラウザー (クライアント) からの要求があるたびに、メイン内で送受信を行う別の関数を用意することです: 127.0.0.1:3490/index.txtメイン関数のみで1つのリクエストを実行しますが、スレッド関数にすべてを入れてブラウザに送信するのに問題があります。

以下は私のコードです。

#include <stdio.h>
#include<stdlib.h>
#include <winsock.h>
#include <stddef.h>
#define NUM_THREADS 10
#define MYPORT 3490
void *PrintData(void *thread);  
int main() {
    WSADATA wsaData;
    SOCKET s;
    unsigned fd;
    struct sockaddr_in my_addr;
  WSAStartup(MAKEWORD(1, 1), &wsaData);
  my_addr.sin_family = AF_INET;
  my_addr.sin_port = htons(MYPORT);
  my_addr.sin_addr.s_addr = INADDR_ANY;
  memset(my_addr.sin_zero, '\0', sizeof(my_addr.sin_zero) );

  s=socket(PF_INET,SOCK_STREAM, 0);
  if(s<0) printf("socket failed\n");
  if ( (bind(s, (struct sockaddr *)&my_addr, sizeof(my_addr)) ) !=0){ printf("Bind failed!\n");}
  listen(s,10);

    while(1) {
        fd=accept(s,NULL,NULL);
         printf("Client connected\r\n");
        CreateThread(NULL,(DWORD)NULL,(LPTHREAD_START_ROUTINE)PrintData,(void*)fd,(DWORD)NULL,NULL);  // creating threads
    }
    closesocket(fd);    
    WSACleanup();
}

void *PrintData(void *thread){
   char *header="HTTP/1.1 200 OK\r\nContent-Type: text/html\r\n\r\n";
    char data[512];
    char filename[256];
    FILE *f; 
    printf("It's me, thread!\n");
    SOCKET curr_client = (SOCKET)thread;
    int res;
    while(1){
        res=recv(curr_client,data,512,0);              
        ///data[res]=0;                         
        Sleep(10);
        if(res == 0) printf("error: res == 0");

        sscanf(data,"GET /%s ",filename);  
        printf("Get: %s %d\n", filename, res);
        send(curr_client,header,strlen(header),0);  
        f=fopen(filename,"rb");            
        if(f == NULL){ fputs("Can not find the file!", stderr); }
        while(!feof(f)){
            printf("heloooo");
            int retVal = fread(data, 1, sizeof(data), f);
            ///printf("data is : %s\n", data);
            send(curr_client, data, sizeof(data), 0); 
        }
    }
    fclose(f);
    ExitThread((DWORD)NULL);
}
4

2 に答える 2

0
while(1) {
fd=accept(s,NULL,NULL);             
n=recv(fd,data,512,0);              
data[n]=0;                        
sscanf(data,"GET /%s ",filename);  
printf("Get: %s %d\n", filename, n);      
send(fd,header,strlen(header),0);  
f=fopen(filename,"rb");             
if(f == NULL){ fputs("file error", stderr); } 
fread(data, 1, sizeof(data), f); 
returnVal = send(fd, data, strlen(data), 0); 
if(returnVal<0) printf("Your tester failes!\n\n"); 
fclose(f);
closesocket(fd);                   
}
于 2012-10-19T08:00:22.783 に答える
0

fdまず、メイン関数で閉じないでください。ループが無限であるため、現在はまったく閉じません。これは、リソース リークがあることを意味します。スレッド関数で最後に行うことは、 を呼び出すことclosesocket(curr_client);です。

第二に、スレッド内で永遠にループし、ループから抜け出すことはありません。ファイルの読み取り中にエラーが発生した場合、ファイルの終わりに到達した場合、またはソケットとの間で送受信中にエラーが発生した場合は、無限ループから抜け出す必要があります。これは、サーバーが各要求の後に接続を閉じる必要があるという HTTP 仕様に従っています。

于 2012-08-01T06:06:56.823 に答える