C ++套接字 – 服务器不接受多个客户端（Linux）

我有工作服务器和客户端代码。 服务器和客户端可以正确连接和聊天。 但是当我打开另一个客户端时，客户端就是说Awaiting confirmation from the server而不是别的。 虽然服务器和客户端＃1仍然可以聊天。

我search了multithreading，但他们展示的例子或代码片段是先进的。 也许一个小小的解释或例子会有很大的帮助！

下面的代码正在工作。 我有一个工作服务器，但它只接受一个连接。 如何让服务器允许多个连接？ 这样我可以使程序看起来像一个群聊。

client.cpp（当客户端＃2连接时，代码在第40行冻结）

• 如何最有效地处理大量的文件描述符？
• 接收MSG_NONBLOCK和MSG_WAITALL
• 绑定与SO_BINDTODEVICE套接字
• unix域套接字有多可靠？
• 如何查看已打开套接字连接的进程的线程ID？

 #include <iostream> #include <string.h> #include <sys/types.h> #include <sys/socket.h> #include <netinet/in.h> #include <arpa/inet.h> #include <netdb.h> #include <stdlib.h> #include <unistd.h> using namespace std; int main() { char a; int client; int portNum = 1500; int bufsize = 1024; char* buffer = new char[bufsize]; bool isExit = false; char* ip = "127.0.0.1"; struct sockaddr_in direc; if ((client = socket(AF_INET, SOCK_STREAM, 0)) < 0) { cout << "\nError creating socket..." << endl; exit(0); } cout << "\nSocket created successfully..." << endl; direc.sin_family = AF_INET; direc.sin_port = htons(portNum); inet_pton(AF_INET, ip, &direc.sin_addr); if (connect(client,(struct sockaddr *)&direc, sizeof(direc)) == 0) cout << "Connection to the server " << inet_ntoa(direc.sin_addr) << endl; cout << "Awaiting confirmation from the server..." << endl; //line 40 recv(client, buffer, bufsize, 0); cout << "\n=> Enter # to terminate the connection\n" << endl; do { cout << "Client: "; do { cin >> buffer; send(client, buffer, bufsize, 0); if (*buffer == '#') { send(client, buffer, bufsize, 0); *buffer = '*'; isExit = true; } } while (*buffer != 42); cout << "Server: "; do { recv(client, buffer, bufsize, 0); cout << buffer << " "; if (*buffer == '#') { *buffer = '*'; isExit = true; } } while (*buffer != 42); cout << endl; } while (!isExit); cout << "=> Connection terminated.\nGoodbye"; close(client); return 0; } 

server.cpp

 #include <iostream> #include <string.h> #include <sys/types.h> #include <sys/socket.h> #include <netinet/in.h> #include <arpa/inet.h> #include <stdlib.h> #include <unistd.h> using namespace std; int main() { int client, server; int bufsize = 1024; int portNum = 1500; bool isExit = false; char* buffer = new char[bufsize]; struct sockaddr_in direc; socklen_t tamano; pid_t pid; if ((client = socket(AF_INET, SOCK_STREAM, 0)) < 0) { cout << "\nError establishing socket..." << endl; exit(1); } cout << "\nSocket server has been created..." << endl; direc.sin_family = AF_INET; direc.sin_addr.s_addr = htons(INADDR_ANY); direc.sin_port = htons(portNum); if ((bind(client, (struct sockaddr*)&direc,sizeof(direc))) < 0) { cout << "\nError binding connection..." << endl; return -1; } tamano = sizeof(direc); cout << "Looking for clients..." << endl; listen(client, 1); while ((server = accept(client,(struct sockaddr *)&direc,&tamano)) > 0) { strcpy(buffer, "Server connected...\n"); send(server, buffer, bufsize, 0); cout << "Connected with the client, you are good to go..." << endl; cout << "Enter # to end the connection\n" << endl; cout << "Client: "; do { recv(server, buffer, bufsize, 0); cout << buffer << " "; if (*buffer == '#') { *buffer = '*'; isExit = true; } } while (*buffer != '*'); do { cout << "\nServer: "; do { cin >> buffer; send(server, buffer, bufsize, 0); if (*buffer == '#') { send(server, buffer, bufsize, 0); *buffer = '*'; isExit = true; } } while (*buffer != '*'); cout << "Client: "; do { recv(server, buffer, bufsize, 0); cout << buffer << " "; if (*buffer == '#') { *buffer == '*'; isExit = true; } } while (*buffer != '*'); } while (!isExit); cout << "\n=> Connection terminated... " << inet_ntoa(direc.sin_addr); close(server); cout << "\nGoodbye..." << endl; isExit = false; } close(client); return 0; } 

我如何让服务器接受多个连接？

谢谢！

 while ((accepted = accept(client,(struct sockaddr *)&direc,&tamano)) > 0) { /*Create the thread and pass the socket descriptor*/ if( pthread_create(new_thread, &thread_attributes, &handle_tcp_connection, (void *)accepted) != 0){ perror("create thread"); exit(EXIT_FAILURE); } }