C++マルチスレッドソケットはクライアントデータを受信できません

Question

マルチスレッドソケットサーバーを作成したいと思います。サーバーはうまく動作していますが、コードをワーカー関数に移動しようとすると、クライアントデータを読み取るときにサーバーが機能しなくなります。

オリジナルコード： main.cppに

int sock; 

main(){ 
    SocketServer *ss = new SocketServer(8888); 
    pthread_t thread; 
    if(ss != NULL){ 
     while(true){    
      sock = ss->Accept();  
      pthread_create(&thread, NULL, SocketThread, &(*ss));  
      pthread_detach(thread);  
     } 
    } 
} 

static void* SocketThread(void* lp){  
    SocketServer *ss = (SocketServer*) lp; 
    char* out; 
    ss->GetRequest(sock, out); 
} 

オリジナル出力：リード前
main.cppに

int sock; 

main(){ 
    SocketServer *ss = new SocketServer(8888); 
    pthread_t thread; 
    if(ss != NULL){ 
     while(true){    
      sock = ss->Accept(); 
      char* out; 
      ss->GetRequest(sock, out); 
     } 
    } 
} 

SocketServer.cpp

void SocketServer::GetRequest(int msgsock, char* out){ 
    char buf[1024]; 
    int rval; 
    std::cout<<"before read\n"; 
    if ((rval = read(msgsock, buf, 1024)) < 0){ 
     perror("reading socket"); 
    }else{ 
     strcpy(out,buf); 
    } 
    std::cout<<"after read\n"; 
} 

スレッドを追加した後

新しい出力読んだ後：
を

Answer 1

を読む前にこれが壊れている：それはエラーを通知しない限り、

if ((rval = read(msgsock, buf, 1024)) < 0){ 
    perror("reading socket"); 
}else{ 
    strcpy(out,buf); 

あなたがrvalを無視しています。それは次のようになります。

if ((rval = read(msgsock, buf, 1024)) < 0){ 
    perror("reading socket"); 
else if (rval == 0) { 
    // peer closed the connection 
    close(msgsock); // or closesocket(), depending on your platform 
    break; 
}else{ 
    strncpy(out,buf,rval); 

、これも壊れている：

sock = ss->Accept();  
pthread_create(&thread, NULL, SocketThread, &(*ss)); 

スレッドは、クライアントがリスニングソケットには関心を持っていない処理するために始めました。必要なのは、がソケットsockであり、次の呼び出しでオーバーライドされないように取得する必要があります。通常、sockは受け入れループ内のローカル変数であり、pthread_create()を介して渡されます。