如何在C语言中判断socket是否已经断开

要在C语言中判断socket是否已经断开，可以通过以下方式实现：

1. 使用heartbeat机制：

可以使用心跳机制来判断socket是否已经断开。在socket连接建立之后，不断地在两端之间发送心跳包，如果一段时间内没有收到对端的心跳回复，则认为连接已经断开。

以下是使用heartbeat机制的示例代码：

#include <stdio.h>
#include <string.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <errno.h>

#define SERVER_IP "127.0.0.1"
#define SERVER_PORT 8080
#define HEARTBEAT_INTERVAL 10 // 心跳间隔，单位：秒
#define HEARTBEAT_TIMEOUT 20  // 心跳超时，单位：秒

int main() {
    int sockfd = -1;
    struct sockaddr_in server_addr;

    sockfd = socket(AF_INET, SOCK_STREAM, 0);
    if (sockfd < 0) {
        perror("socket");
        return -1;
    }

    memset(&server_addr, 0, sizeof(server_addr));
    server_addr.sin_family = AF_INET;
    server_addr.sin_addr.s_addr = inet_addr(SERVER_IP);
    server_addr.sin_port = htons(SERVER_PORT);

    if (connect(sockfd, (struct sockaddr*)&server_addr, sizeof(server_addr)) < 0) {
        perror("connect");
        close(sockfd);
        return -1;
    }

    printf("Connected to server: %s:%d\n", SERVER_IP, SERVER_PORT);

    // 启动心跳线程
    pthread_t heartbeat_thread;
    pthread_create(&heartbeat_thread, NULL, heartbeat, (void*)&sockfd);

    // 此处可以进行socket通信
    ...

    // 等待心跳线程结束
    pthread_join(heartbeat_thread, NULL);

    close(sockfd);

    return 0;
}

void* heartbeat(void* arg) {
    int sockfd = *(int*)arg;

    while (1) {
        if (send(sockfd, "heartbeat", sizeof("heartbeat"), 0) < 0) {
            fprintf(stderr, "Failed to send heartbeat packet: %s\n", strerror(errno));
            return NULL;
        }

        sleep(HEARTBEAT_INTERVAL);

        // 检查是否收到心跳回复，如果超时则认为socket已经断开
        char buffer[1024] = {0};
        struct timeval timeout;
        fd_set read_fds;

        FD_ZERO(&read_fds);   
        FD_SET(sockfd, &read_fds);  

        timeout.tv_sec = HEARTBEAT_TIMEOUT;
        timeout.tv_usec = 0;

        if (select(sockfd + 1, &read_fds, NULL, NULL, &timeout) == 0) {
            fprintf(stderr, "Heartbeat timeout, socket disconnected\n");
            return NULL;
        }

        if (recv(sockfd, buffer, sizeof(buffer), 0) <= 0) {
            fprintf(stderr, "Failed to receive heartbeat reply: %s\n", strerror(errno));
            return NULL;
        }
    }

    return NULL;
}

1. 使用select函数：

使用select函数可以监控socket的读事件，如果select返回值为0，则表示socket已经断开。

以下是使用select函数的示例代码：

#include <stdio.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <string.h>
#include <errno.h>

#define SERVER_IP "127.0.0.1"
#define SERVER_PORT 8080

int main() {
    int sockfd = -1;
    struct sockaddr_in server_addr;

    sockfd = socket(AF_INET, SOCK_STREAM, 0);
    if (sockfd < 0) {
        perror("socket");
        return -1;
    }

    memset(&server_addr, 0, sizeof(server_addr));
    server_addr.sin_family = AF_INET;
    server_addr.sin_addr.s_addr = inet_addr(SERVER_IP);
    server_addr.sin_port = htons(SERVER_PORT);

    if (connect(sockfd, (struct sockaddr*)&server_addr, sizeof(server_addr)) < 0) {
        perror("connect");
        close(sockfd);
        return -1;
    }

    printf("Connected to server: %s:%d\n", SERVER_IP, SERVER_PORT);

    while (1) {
        fd_set read_fds;
        struct timeval timeout;

        FD_ZERO(&read_fds);
        FD_SET(sockfd, &read_fds);

        timeout.tv_sec = 5;
        timeout.tv_usec = 0;

        if (select(sockfd + 1, &read_fds, NULL, NULL, &timeout) <= 0) {
            fprintf(stderr, "Socket disconnected\n");
            break;
        }

        // 接收来自服务器的消息
        ...
    }

    close(sockfd);

    return 0;
}

使用上述两种方式可以有效判断socket是否已经断开，根据不同的需求选择不同的实现方式。