C中的多线程客户端 - 服务器套接字编程

Question

我在具有相同IP地址但具有不同端口的客户端和服务器的同一台计算机上以C语言实现多线程客户端 - 服务器套接字编程。我已经在C环境中使用pthread概念实现了它。但是我可以看到只有我的客户端线程正在运行，而我的服务器线程一旦到达'accept（）'例程就停止了。 我想知道可能是什么问题。如果有任何人能找出我犯了一个错误那么这将是非常有益的

我的客户端代码如下所示：

void *client_connect(void *arg) 
{ 

    int client_socket; 
    struct sockaddr_in Serv_Addr; 
    struct sockaddr_in Client_Addr; 
    int addrlen=sizeof(Client_Addr); 

    char send_buffer_client[] = {"server message"}; 
    char recv_buffer_client[1024]; 
    int nbytes; 

    client_socket = lwip_socket(AF_INET, SOCK_STREAM, 0); 
    if (client_socket < 0) ; 

    memset((char *)&Serv_Addr, 0, sizeof(Serv_Addr)); 
    Serv_Addr.sin_family = AF_INET; 
    Serv_Addr.sin_len = sizeof(Serv_Addr); 
    Serv_Addr.sin_addr.s_addr = inet_addr("1.2.3.4"); 
    Serv_Addr.sin_port = 9999; 
    memset((char *)&Client_Addr, 0, sizeof(Client_Addr)); 
    Client_Addr.sin_family = AF_INET; 
    Client_Addr.sin_len = sizeof(Client_Addr); 
    Client_Addr.sin_addr.s_addr = inet_addr("1.2.3.4"); 
    Client_Addr.sin_port = 5555; 

    lwip_connect(client_socket, (struct sockaddr *)&Serv_Addr, sizeof(Serv_Addr)); 

    while (1) { 

       do{ 
        nbytes = lwip_recv(client_socket, recv_buffer_client, sizeof(recv_buffer_client),0); 
        if (nbytes>0) lwip_send(client_socket, send_buffer_client, sizeof(send_buffer_client), 0); 

        printf("server message = %s\n", recv_buffer_client); 
       } while (nbytes>0); 

       sleep(10); 

     } 
     lwip_close(client_socket); 
} 

我的服务器代码：

void *server_connect(void *arg) 
{ 

    int server_socket; 
    struct sockaddr_in Serv_Addr; 
    struct sockaddr_in Client_Addr; 
    int addrlen=sizeof(Client_Addr); 
    int clientfd; 
    char send_buffer[] = {"Server message"}; 
    char recv_buffer[1024]; 
    int nbytes_server, client_length; 

    server_socket = lwip_socket(AF_INET, SOCK_STREAM, 0); 
    if (server_socket < 0) 
    printf("could not create server socket"); 
    else 
    printf("created SERVER socket"); 

    memset((char *)&Serv_Addr, 0, sizeof(Serv_Addr)); 
    Serv_Addr.sin_family = AF_INET; 
    Serv_Addr.sin_len = sizeof(Serv_Addr); 
    Serv_Addr.sin_addr.s_addr = inet_addr("1.2.3.4"); 
    Serv_Addr.sin_port = 9999; 


    client_length = sizeof(Client_Addr); 
    if (lwip_bind(server_socket, (struct sockaddr *)&Serv_Addr, sizeof(Serv_Addr)) < 0) {   
      printf("could not BIND"); 
    } 

    if (lwip_listen(server_socket, 20) != 0){ 
      printf("could not BIND"); 
    } 
    while (1) { 
       lwip_accept(server_socket, (struct sockaddr*)&Client_Addr, &client_length);     

       do{ 
       nbytes_server = lwip_recv(server_socket, recv_buffer, sizeof(recv_buffer),0); 
       if (nbytes_server>0){lwip_send(server_socket, send_buffer, sizeof(send_buffer), 0);} 

       printf("client message = %s\n", recv_buffer); 
       }while(nbytes_server>0); 
       sleepms(10); 
     } 
     lwip_close(server_socket); 
} 

void main(void) 
{ 
    pthread_t client_thread; 
    pthread_t server_thread; 

    pthread_create(&server_thread, NULL, server_connect, NULL); 
    pthread_create(&client_thread, NULL, client_connect, NULL); 

    while(1){ 
     sleepms(1); 
     } 
} 

请让我知道如果我做了错误的方式

问候 德布

Answer 1

如果您位于同一台计算机上，则您使用的IP地址1.2.3.4不是本地主机的典型地址，该地址应为127.0.0.1。除非实际上使用路由器或其他方式（如IP地址1.2.3.4）创建了本机的IP地址，否则该地址无法解析，即使您尝试在同一台计算机上运行客户端和服务器，他们不会找到对方，因为没有办法将1.2.3.4解析到网络上的给定机器上。

此外，您不需要将服务器锁定到特定的IP地址，只需使用netinet/in.h中的常量INADDR_ANY即可将套接字绑定到系统上的任何接口。在客户端，虽然您仍然需要正确的IP地址，但是，如果它是本地主机，则可以使用127.0.0.1。

Answer 2

（1）它看起来好像客户端和服务器都在等待接收某些东西，然后再回显它。有人必须先谈谈。

（2）我没有看到你的lwip_accept返回一个新的套接字与客户端进行通信。您最终在侦听套接字上执行recv/send。

（3）而且，这里考虑您的代码：

while (1) 
{ 
    lwip_accept(server_socket, (struct sockaddr*)&Client_Addr, &client_length); 

    do 
    { 
     nbytes_server = lwip_recv(server_socket, recv_buffer, sizeof(recv_buffer), 0); 

     if (nbytes_server > 0) 
     { 
      lwip_send(server_socket, send_buffer, sizeof(send_buffer), 0); 
     } 

     printf("client message = %s\n", recv_buffer); 
    } 
    while (nbytes_server > 0); 

    sleepms(10); 
} 

您阅读和回声的消息，但从来没有关闭套接字（可能是明智的，因为它是监听套接字！），并立即循环回到上接受阻断再次。如果客户端没有再次连接，你会被永久接受。

（4）您不需要这些sleepms（）调用。在主要中使用pthread_join（），然后摆脱其余部分。无论如何，它看起来像你所有的呼叫阻止。

Answer 3

这里的ATLEAST 3个错误：

lwip_accept（）返回一个新的socket描述符，你应该使用从客户端读取，而不是从原始服务器套接字读取（还要注意lwip_accept将阻塞，直到有人实际上是连接到服务器）。如果你是一个小端机器上

您的端口号可能会脱过，他们在网络字节顺序是通常情况下，你应该做的 Serv_Addr.sin_port = htons(9999);和同一客户端端口 - htons把从主机端短network endian

您没有发送任何数据！你的客户端等待服务器发送一些东西。但是你的服务器不发送任何东西，它等待客户端发送一些东西。什么都不会发生。

检查lwip_connect也会失败，检查errno如果你的环境提供了它，什么不顺心