2

我试图在我的服务器程序中使用多线程，这样当我从浏览器收到请求时，我的服务器应该打开一个 txt 文件并将其发送到浏览器进行显示。我需要做的是有一个单独的功能，每次有来自浏览器（客户端）的请求时，它都会在我的 main 内部进行发送/接收，例如：127.0.0.1:3490/index.txt 我设法做到了一个请求仅使用我的主要功能，但我无法将所有内容放入我的线程功能并将其发送到浏览器。

我将不胜感激以下是我的代码：

#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

首先，不要fd在主函数中关闭。现在你根本不会关闭它，因为循环是无限的，这意味着你有资源泄漏。您在线程函数中做的最后一件事是调用closesocket(curr_client);.

其次，在线程中你永远循环，永远不会跳出循环。当读取文件出错，到达文件末尾，或者从/向套接字接收/发送时出错，你应该跳出无限循环。这遵循 HTTP 规范，即服务器应在每次请求后关闭连接。

于 2012-08-01T06:06:56.823 回答
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 回答