Как использовать технологию мультиплексирования ввода-вывода для повышения производительности параллелизма на сервере?

Question

Я хочу сделать серверное программное обеспечение похожим на Apache на платформах Windows. , Клиент отправляет данные на указанный порт сервера, и сервер отвечает соответствующим образом. Чтобы повысить скорость клиентского доступа, я хочу использовать «select» для повышения производительности сервера, но в процессе использования возникает много проблем. Вот мой код;

Функция "create_server"

Эта функция используется для создания сокета сервера и установки его в неблокирующем режиме.

int create_server(char*ip_address,int port) {
WORD sockVersion = MAKEWORD(2, 2);
WSADATA wsaData;
if(WSAStartup(sockVersion, &wsaData) != 0)
{
    return 0;
}
int server_socket = socket(AF_INET,SOCK_STREAM, IPPROTO_TCP);
int ret = -1;
struct sockaddr_in addr;
if (server_socket == -1) {
    return -1;
}
memset(&addr, 0, sizeof(addr));
addr.sin_family = AF_INET;
addr.sin_port = htons(port);
addr.sin_addr.S_un.S_addr= INADDR_ANY;
ret = bind(server_socket,(LPSOCKADDR)&addr,sizeof(addr));
if (ret == -1) {
    perror("bind error！");
    return -2;
}
listen(server_socket,5);
SetBlock(server_socket, 0);
return server_socket;}

Функция «SetBlock»

Эта функция используется для изменения режима блокировки сокета.

int SetBlock(int sock, int isblock){
  int re = 0;
  unsigned long ul = 0;
  if (!isblock) ul = 1;
  re = ioctlsocket(sock, FIONBIO, (unsigned long*)& ul);
  if (re != 0) return 0;
  return 1;
}

Функция «главная»

int main() {
int s = create_server("127.0.0.1",6666);
int client_socket = -1;
struct sockaddr_in clientaddr;
int addrlen = sizeof(clientaddr);
char buf[1025];
int buffersize=1,result=0;
int isread = 0;
fd_set server;
struct timeval timeout;
int fd = 0;
timeout.tv_sec = 3;
timeout.tv_usec = 0;
FD_ZERO(&server);
FD_SET(s, &server);

while (1) {
    result = select(FD_SETSIZE, &server, NULL, NULL, NULL);
    if (result < 1) {
        perror("error！");
        exit(1);
    }
    if (FD_ISSET(s, &server)) {
        //if server can be readable and written do this
            client_socket = accept(s, (struct sockaddr*) & clientaddr, &addrlen);
            while (buffersize > 0) {
                    buffersize = recv(client_socket, buf, 1024, 0);
                    buf[buffersize] = '\0';
                    printf("%s", buf);
                    if (buffersize < 1024) {
                        break;
                    }
            }
            buffersize = 1;
    }

}


return 0;}

Как вы знаете, TCP требует времени для установления соединения. Я хочу использовать функцию «выбор», чтобы сократить время установки многопользовательских подключений. Я думаю, что функция «принять» - это процесс установления соединения между клиентом и сервером, но как использовать мультиплексирование ввода-вывода в этом процессе, пожалуйста, помогите мне.

Answer 1

использование select() задержит все клиентские подключения к серверу.

предложить последовательность, подобную:

create a thread pool
create a sockaddr_in
sock_t serverSock = socket()
bind()
listen()
while( 1 )
{
    sock_t clientSock = accept( serverSock, ... )
    pass clientSock to available thread and mark thread as 'busy'
}

Таким образом, связь с клиентом не «зависает» ни на select(), ни на accept()

в каждой теме:

while(1)
{
    wait until thread marked as 'busy'
    sock_t mySocket = passedSocket
    perform all communication with the specific client
    close( mySocket );
    mark thread as 'idle'
}