如何在单独的线程中处理套接字请求，线程似乎阻塞了主进程

Posted 2023-03-15

【中文标题】如何在单独的线程中处理套接字请求，线程似乎阻塞了主进程

【英文标题】：How do I handle socket requests in separate threads, thread seems to be blocking main process

【发布时间】：2022-01-12 07:57:51

【问题描述】：

我正在尝试用 C++ 创建一个简单的 HTTP 服务器。我希望在单独的线程中同时处理每个请求，但是当我创建一个线程并在开始时放置一个简单的sleep(10) 导致一些延迟时，在第一个线程完成之前无法向服务器发出另一个请求。我做错了什么？

到目前为止，这是我的代码：

#include <unistd.h>
#include <stdio.h>
#include <sys/socket.h>
#include <stdlib.h>
#include <netinet/in.h>
#include <string>
#include <ostream>
#include <iostream>
#include <thread>

using namespace std;

void send_response (int socket)

    sleep (10);

    char buffer[2048] = 0;

    int request = recv (socket, buffer, 2048, 0);

    if (request == -1) 
        perror ("error");
    

    string message = "Hello from server";
    string length = to_string (message.length ());

    string hello = "HTTP/1.1 200 OK\nContent-Type: text/plain\nContent-Length: " + length + "\n\n" + message;

    send (socket, hello.c_str (), hello.length (), 0);

    close (socket);


int main(int argc, char const *argv[])

    struct sockaddr_in address;
    int opt = 1;
    socklen_t addrlen = sizeof (address);

    int server_fd = socket (AF_INET, SOCK_STREAM, 0);

    if (server_fd == 0) 
        perror ("socket failed");
        exit (EXIT_FAILURE);
    

    if (setsockopt (server_fd, SOL_SOCKET, SO_REUSEADDR | SO_REUSEPORT, &opt, sizeof (opt))) 
        perror ("setsockopt");
        exit (EXIT_FAILURE);
    

    address.sin_family = AF_INET;
    address.sin_addr.s_addr = INADDR_ANY;
    address.sin_port = htons (8080);

    if (bind (server_fd, (struct sockaddr *)(&address), sizeof (address)) < 0) 
        perror ("bind failed");
        exit (EXIT_FAILURE);
    

    if (listen (server_fd, 3) < 0) 
        perror ("listen");
        exit (EXIT_FAILURE);
    

    while (true) 
        int new_socket = accept (server_fd, (struct sockaddr *)(&address), &addrlen);

        if (new_socket < 0) 
            perror ("accept");
            exit (EXIT_FAILURE);
        

        thread response (&send_response, new_socket);

        response.detach ();

        cout << "request handled" << endl;
    

    return 0;

我不需要等待线程完成或从线程中取回任何数据，我只希望它启动，做一些工作，然后将一些东西发送回客户端。我希望每个线程都会做大量的工作，这就是我使用 sleep 的原因。

编辑：似乎循环已准备好并等待第二个连接，并将成功接受一个新连接并创建一个新线程来处理它，但前提是第二个连接来自不同的IP地址。因此，如果我从 127.0.0.1:8080 和不同的本地 IP 地址（如 192.168.1.91）访问服务器，则两个连接都将通过两个线程同时运行。但是，如果我只是打开两个选项卡，都位于 127.0.0.1:8080，一次只能接受一个连接，另一个将停止。看来我需要代码来处理来自同一 IP 地址的多个连接，但在 Google 上搜索此类问题并没有给我任何好的结果。

【问题讨论】：

我希望每个线程都会做大量的工作，这就是我使用睡眠的原因你是什么意思？

我认为问题在于线程对象的范围 - 它在 while 循环内。所以在一次迭代之后，对象就会超出范围。

我的意思是每个线程都需要几秒钟才能完成，我不希望客户端因为 12 系统上的一个核心忙于处理一个请求而等待。

你是对的，函数不需要通过地址传递。我这样做是因为文档说第一个参数是“指向函数的指针、指向成员的指针或任何类型的可移动构造函数对象”，所以我传递了地址。不过，这对代码是否工作没有影响。

能否在第二个请求挂起时附加调试器并中断？这应该告诉你主线程在做什么。

【参考方案1】：

好吧，我的错，一切都按预期工作。使用wget 从同一 IP 发送多个请求会导致创建多个线程并同时处理请求。在 Chrome 中，由于某种原因，从同一 IP 打开多个选项卡会导致它们以串行方式发送，但在 Firefox 中，它们是并行发送并同时到达和处理的。这很奇怪，但我会把它归结为 Chrome 的奇怪之处。