c - 如何在使用 C 的 Linux 线程中修复 "Error reading from socket - bad file descriptor"？

Question

我正在设置一个服务器-客户端应用程序(聊天)，我遇到了套接字/线程问题。服务器和客户端都在 Linux 上运行。

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

这是服务器:ma​​in.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;
}

ma​​nazerUctov.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 */

ma​​nazerUctov.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);
}

当客户端发送套接字时，服务器接受它并创建一个线程，但我得到从套接字读取错误:错误的文件描述符。而且程序卡住了，连退出都不会。就我而言，套接字尚未关闭。在我实现线程之前，从套接字中读取数据工作正常。

编辑:原始代码有 500 行长，所以我对其进行了修剪，之前的错误不再存在，尽管另一个错误是 &cdata in pthread_create 。删除并解决了修整和原始代码中的问题，服务器正在运行。

Answer 1

您的 pthread_create 函数调用不正确。

这将一个指针传递给 client_data pointer 并且不是指针指向什么:

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

你想要的是:

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

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

---

一些补充说明:

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

因此，当您的线程函数退出时，它将处于未连接(即僵尸)状态。

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

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

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

这可能更容易清洁。

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