如何使用 C 在 Linux 上的线程中修复“从套接字读取错误 - 错误的文件描述符”？

Question

我正在设置服务器客户端应用程序（聊天），并且遇到了套接字/线程问题。服务器和客户端都运行在Linux上。

我希望服务器能够为多个用户提供服务，为此我想使用pthread.h中的线程中的线程，因此每个登录用户都有自己的线程。

这是服务器： main.c

#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <pthread.h>
#include "manazerUctov.h"

int pocetVlakienZOP = 0;

int main(int argc, char *argv[])
{
    pthread_t* vlaknaZiadosti = 
    (pthread_t*)malloc(sizeof(pthread_t)*POCET_UZIVATELOV);

    int sockfd, newsockfd;
    socklen_t cli_len;
    struct sockaddr_in serv_addr, cli_addr;
    int n;

    // Program
    if (argc < 2) {
        fprintf(stderr, "usage %s port\n", argv[0]);
        return 1;
    }

    bzero((char*) &serv_addr, sizeof (serv_addr));
    serv_addr.sin_family = AF_INET;
    serv_addr.sin_addr.s_addr = INADDR_ANY;
    serv_addr.sin_port = htons(atoi(argv[1]));

    sockfd = socket(AF_INET, SOCK_STREAM, 0);
    if (sockfd < 0) {
        perror("Error creating socket\n");
        return 1;
    }
    printf("Socket OK\n");

    if (bind(sockfd, (struct sockaddr*) &serv_addr, sizeof (serv_addr)) < 0) {
        perror("Error binding socket address\n");
        return 2;
    }
    printf("Bind OK\n");

    listen(sockfd, 5);
    while (1) {

        cli_len = sizeof (cli_addr);

        newsockfd = accept(sockfd, (struct sockaddr*) &cli_addr, &cli_len);
        if (newsockfd < 0) {
            perror("ERROR on accept\n");
            return 3;
        }
        printf("Accept OK\n");
        client_data* cdata = (client_data*) malloc(sizeof (client_data));
        cdata->socket = newsockfd;

        pthread_t vlakno;
        vlaknaZiadosti[pocetVlakienZOP++] = vlakno;
        pthread_create(&vlakno, NULL, &serveClient, &cdata);
    }

    close(sockfd);
    return 0;
}

manazerUctov.h：

#ifndef MANAZERUCTOV_H
#define MANAZERUCTOV_H

#ifndef POCET_UZIVATELOV
#define POCET_UZIVATELOV 256
#endif

#ifdef __cplusplus
extern "C" {
#endif

typedef struct {
    char *buffer;
    char* msg;                         
    int socket;
} client_data;

void* serveClient(void* pdata);

#ifdef __cplusplus
}
#endif

#endif /* MANAZERUCTOV_H */

manazerUctov.c这里，读取函数给出错误：

#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include "manazerUctov.h"

void* serveClient(void *pdata) {
    char buffer[256];
    client_data* client = (client_data*)pdata;
    bzero(buffer, 256);

    int n = read(client->socket, buffer, 255);
    if (n < 0) {
        perror("Error reading from socket\n");
        return NULL;
    }

    printf("Read from socket\n");
    close(client->socket);
}

当客户端发送套接字时，服务器接受它并创建一个线程，但我收到Error read from socket: bad file detector。并且程序卡住了，甚至不会退出。就我而言，套接字尚未关闭。在我实现线程之前，从套接字读取工作正常。

编辑：原始代码有 500 行长，所以我修剪了它，以前的错误不再存在，尽管另一个错误是pthread_create中的&cdata。删除并解决了修剪后的代码和原始代码中的问题，并且服务器正在工作。

Answer 1

您的pthread_create函数调用不正确。

这将指针传递给client_data 指针，而不是指针所指向的内容：

pthread_create(&my_thread, NULL, &my_function, &cdata);

你想要的是：

pthread_create(&my_thread, NULL, &my_function, cdata);

因此，cdata->socket您将获得指针值的低 32 位作为文件描述符，而不是获取 。

一些附加说明：

因为您有一个循环作用域pthread_t my_thread;，所以它在循环的每次迭代中都会消失，因此主线程将无法对其执行操作pthread_join。

所以，当你的线程函数退出时，它将处于未连接（即僵尸）状态。

此外，在每次迭代中，每次pthread_create调用都可能指向my_thread相同的地址。我不确定这会对其他线程原语产生什么影响，但我会保持警惕。

您可能想将 添加pthread_t mythread;到分配的结构中。这样，就保证了它有一个唯一的地址。并且，主线程可以跟踪它已分配的结构。

处理此问题的另一种方法是让您的线程函数pthread_detach在顶部执行 a [或在pthread_create调用中添加适当的属性]

这可能更容易清洁。

另外，请确保您的线程函数关闭其套接字并free在退出之前对结构指针执行 a 操作。