C++套接字 - 服务器不接受多个客户端 (linux)

C++ Sockets - Server doesn't accept multiple clients (linux)

本文关键字:客户端 linux 套接字 服务器 不接受 C++      更新时间:2023-10-16

我有工作的服务器和客户端代码。服务器和客户端可以正常连接和聊天。但是当我打开另一个客户端终端时,客户端显示的是Awaiting confirmation from the server,没有其他内容。虽然服务器和客户端#1仍然可以聊天。

我搜索了多线程,但他们显示的例子或代码片段是先进的。也许一点解释或一个例子会有很大帮助!

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

client.cpp(当客户端#2连接时,代码在第40行冻结)

#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 connectionn" << 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 connectionn" << 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;
}

如何让服务器接受多个连接?

谢谢!

为了正确支持多个连接,您应该为每个传入的连接启动一个新线程。每个新连接由accept()返回的唯一套接字描述符标识。一个简单的例子:

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);
    }
}

您将需要使用selectpoll和状态机模式来执行您想要执行的操作。这意味着您需要在数据从发送数据的客户端传入时对其进行处理。请看这里的工作示例: