c - 如何使用 tcpserver 程序中的线程通过服务器在两个客户端之间进行通信？

Question

    int main()
    {
int sock, connected, bytes_recieved , true = 1;
char send_data [1024] , recv_data[1024];
pid_t pid;
struct sockaddr_in server_addr,client_addr;
int sin_size;

if ((sock = socket(AF_INET, SOCK_STREAM, 0)) == -1) 
{
    perror("Socket");
    exit(1);
}

if (setsockopt(sock,SOL_SOCKET,SO_REUSEADDR,&true,sizeof(int)) == -1)   
{
    perror("Setsockopt");
    exit(1);
}

server_addr.sin_family = AF_INET;
server_addr.sin_port = htons(5000);
server_addr.sin_addr.s_addr = INADDR_ANY;
bzero(&(server_addr.sin_zero),8);

if (bind(sock, (struct sockaddr *)&server_addr, sizeof(struct sockaddr)) == -1)
{
    perror("Unable to bind");
    exit(1);
}

if (listen(sock, 5) == -1)
{
    perror("Listen");
    exit(1);
}

printf("\nTCPServer Waiting for client on port 5000\n");
fflush(stdout);

while(1)
{
    sin_size = sizeof(struct sockaddr_in);
    connected = accept(sock, (struct sockaddr *)&client_addr,&sin_size);
    printf("\n I got a connection from (%s , %d)\n",    inet_ntoa(client_addr.sin_addr),ntohs(client_addr.sin_port));
                //fork this process into a child and parent
            pid = fork();

    //Check the return value given by fork(), if negative then error,
    //if 0 then it is the child.
            if ( pid == -1)
    {
                perror("fork()");
            }
    //loop until client closes
    if (pid == 0)
    {
                /*Child Process*/

                close(sock);

        while(1)
        {
            printf("\n SEND (q or Q to quit) : \n");
            gets(send_data);

            if (strcmp(send_data , "q") == 0 || strcmp(send_data , "Q") == 0)   
            {
                send(connected, send_data,strlen(send_data), 0);
                close(connected);
                break;
            }

            else

                send(connected, send_data,strlen(send_data), 0);
            bytes_recieved = recv(connected,recv_data,1024,0);
            recv_data[bytes_recieved] = '\0';

            if (strcmp(recv_data , "q") == 0 || strcmp(recv_data , "Q") == 0)   
            {
                close(connected);
                break;
            }
            else

            printf("\n RECIEVED DATA = from(%s,%d)\ndata=%s\n" ,inet_ntoa(client_addr.sin_addr),ntohs(client_addr.sin_port), recv_data);

            fflush(stdout);
        }
    }
}
close(sock);
return 0;}

我想使用线程进行客户端到客户端的通信。但是如何创建线程以及我必须在哪里创建线程以进行多客户端通信。我还使用 fork 来访问多个客户端。我想使用 TCP/IP 概念在 C 中制作多客户端聊天程序谢谢!!!

Answer 1

您可以在 accept() 返回时创建客户端线程，将客户端信息传递给线程函数。从您的代码来看，您似乎已经成功做到了(我还没有真正编译和检查，但看起来不错)。因此，也许您可​​以添加更多有关代码问题的信息。