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

Question

我正在设置一个服务器-客户端应用程序（聊天），我遇到了 sockets/threads 的问题。 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);
}

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

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

Answer 1

您的 pthread_create 函数调用 不正确。

这将一个指针传递给 client_data 指针并且不是指针指向的内容：

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。

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

How to fix "Error reading from socket - bad file descriptor" while in thread on Linux using C?

c

linux

sockets

descriptor