2016-02-16 307 views
3

我创建了一个连接到C++服务器的C++客户端。 它连接并正确发送数据到服务器。 我创建了一个单独的线程来接收来自服务器的数据,这里是我无法弄清楚的问题。 我得到这个错误:C++客户端中的WSAGetLastError 10038

WSAGetLastError 10038 

我发现这个错误,因为描述符不是一个套接字。

服务器发送方法正常工作,我用telnet客户端测试它。

这是我的客户端代码:

#include <winsock2.h> 
#include <windows.h> 
#include <fcntl.h> 
#include <string.h> 
#include <stdlib.h> 
#include <errno.h> 
#include <stdio.h> 
#include <conio.h> 
#include<iostream> 

using namespace std; 
int hsock; 
void *SocketHandler(void*); 

int main(int argv, char** argc){ 

    //The port and address you want to connect to 
    int host_port= 2000;//1101; 
    char* host_name="10.188.126.198"; 
    pthread_t recept; 


    //Initialize socket support WINDOWS ONLY! 
    unsigned short wVersionRequested; 
    WSADATA wsaData; 
    int err; 
    wVersionRequested = MAKEWORD(2, 2); 
    err = WSAStartup(wVersionRequested, &wsaData); 
    if (err != 0 || (LOBYTE(wsaData.wVersion) != 2 || 
      HIBYTE(wsaData.wVersion) != 2)) { 
     fprintf(stderr, "Could not find useable sock dll %d\n",WSAGetLastError()); 
     return 0; 
    } 

    //Initialize sockets and set any options 

    int * p_int ; 
    hsock = socket(AF_INET, SOCK_STREAM, 0); 
    if(hsock == -1){ 
     printf("Error initializing socket %d\n",WSAGetLastError()); 
     return 0; 
    } 

    p_int = (int*)malloc(sizeof(int)); 
    *p_int = 1; 
    if((setsockopt(hsock, SOL_SOCKET, SO_REUSEADDR, (char*)p_int, sizeof(int)) == -1)|| 
     (setsockopt(hsock, SOL_SOCKET, SO_KEEPALIVE, (char*)p_int, sizeof(int)) == -1)){ 
     printf("Error setting options %d\n", WSAGetLastError()); 
     free(p_int); 
     return 0; 
    } 
    free(p_int); 

    //Connect to the server 
    struct sockaddr_in my_addr; 

    my_addr.sin_family = AF_INET ; 
    my_addr.sin_port = htons(host_port); 

    memset(&(my_addr.sin_zero), 0, 8); 
    my_addr.sin_addr.s_addr = inet_addr(host_name); 

    int *csock ; 
      csock = (int*)malloc(sizeof(int)); 

    if((*csock =connect(hsock, (struct sockaddr*)&my_addr, sizeof(my_addr))) == SOCKET_ERROR){ 
     fprintf(stderr, "Error connecting socket %d\n", WSAGetLastError()); 
     return 0; 
     } 

    cout<<"Client connect to :"<< htons(host_port)<<endl; 

    //Create thread to receive data from the server 
// the problem is here as I think 
    pthread_create(&recept,NULL,SocketHandler,(void *)csock); 


/// Send data to the server  
    char buffer[1024]; 
    int buffer_len = 1024; 
    int bytecount; 

    int c; 

    while(true){ 
      memset(buffer, '\0', buffer_len); 
      for(char* p=buffer ; (c=getch())!=13 ; p++){ 
       printf("%c", c); 
       *p = c; 
      } 


       if((bytecount=send(hsock, buffer, strlen(buffer),0))==SOCKET_ERROR){ 
        fprintf(stderr, "Error sending data %d\n", WSAGetLastError()); 
        return 0; 
       } 
       printf("Sent bytes %d\n", bytecount); 

    } 

    closesocket(hsock); 

return 0; 

} 
void *SocketHandler(void* lp){ 
    int *csock= (int*)lp; 
    cout<<"Start Listening Thread"<<endl; 

    char buffer[1024]; 
    int buffer_len = 1024; 
    int bytecount; 
     memset(buffer, 0, buffer_len); 

    while(1){ 

    memset(buffer, 0, buffer_len); 
    if((bytecount = recv(*csock, buffer, buffer_len, 0))==SOCKET_ERROR){ 
     fprintf(stderr, "Error receiving data %d\n", WSAGetLastError()); 
     break; 
    } 
     printf("Received bytes %d\nReceived string \"%s\"\n", bytecount, buffer); 

    } 

    free(csock); 
    return 0; 
} 
+2

检查[连接](https://msdn.microsoft.com/en- us/library/windows/desktop/ms737625(v = vs.85).aspx)的返回值:_If没有错误发生,连接返回零。否则,它会返回SOCKET_ERROR,并且可以通过调用WSAGetLastError._来检索特定的错误代码。您将其分配给'* csock',然后对其执行'recv'。 – CristiFati

+0

正如我所说,客户端连接正确,并且可以将数据发送到服务器。问题出在recv方法的线程上。 – Kamel

+4

确切地说。 'connect'成功,并返回_0_。所以:'* csock = 0;'然后你有'if((bytecount = recv(* csock,buffer,...'你在_0_上调用'recv',通常是_stdin_。 – CristiFati

回答

2

您发送到线程是csock参数...

int *csock ; 
csock = (int*)malloc(sizeof(int)); 
... 
pthread_create(&recept,NULL,SocketHandler,(void *)csock); 

,然后你用csock作为插座(在线程中)...

int *csock= (int*)lp; 
... 
if((bytecount = recv(*csock, buffer, buffer_len, 0))==SOCKET_ERROR) { 

我认为你需要使用hsock为您的插座,而不是*csock ...

BTW: 在Windows中,应该说是一个插座,不是int ...

希望它可以帮助...