tcp EAGAIN

TCP EAGAIN是一个错误码，表示在非阻塞套接字上进行读取或写入操作时，操作被暂时阻塞，需要再次尝试。EAGAIN实际上是一个宏定义，它在不同的操作系统中可能有不同的名称，比如在Linux中通常被定义为EWOULDBLOCK。

当使用非阻塞套接字进行读取或写入操作时，如果没有数据可读或者写缓冲区已满，操作将返回EAGAIN错误码。这个错误码告诉应用程序当前操作无法立即完成，但并不表示出现了错误。应用程序可以稍后再次尝试进行读取或写入操作。

使用非阻塞套接字和EAGAIN错误码可以实现异步的网络编程，提高程序的性能和响应能力。通过不断地轮询套接字状态，应用程序可以在数据可用时立即进行读取操作，而不需要等待。

相关问题

tcp 非阻塞 接收函数

非阻塞式接收函数是指在没有数据到达时，该函数不会一直等待数据到达，而是立即返回，以便程序能够执行其他任务。在TCP编程中，常用的非阻塞式接收函数是recv()函数。

使用非阻塞式接收函数需要先将socket设置为非阻塞模式，可以通过fcntl或者ioctl函数设置。然后，在调用recv()函数时，如果没有数据到达，该函数会立即返回，并且返回值为-1，同时设置errno为EAGAIN或EWOULDBLOCK。如果有数据到达，recv()函数会返回接收到的字节数。

下面是一个使用非阻塞式接收函数的示例代码：

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

int main() {
    int sockfd = socket(AF_INET, SOCK_STREAM, 0);
    
    // 将socket设置为非阻塞模式
    int flags = fcntl(sockfd, F_GETFL, 0);
    fcntl(sockfd, F_SETFL, flags | O_NONBLOCK);
    
    struct sockaddr_in servaddr;
    memset(&servaddr, 0, sizeof(servaddr));
    servaddr.sin_family = AF_INET;
    servaddr.sin_port = htons(8888);
    servaddr.sin_addr.s_addr = inet_addr("127.0.0.1");
    
    connect(sockfd, (struct sockaddr *)&servaddr, sizeof(servaddr));
    
    char buf[1024];
    int n = 0;
    while (1) {
        n = recv(sockfd, buf, sizeof(buf), 0);
        if (n == -1) {
            if (errno == EAGAIN || errno == EWOULDBLOCK) {
                // 没有数据到达，可以执行其他任务
                // ...
            } else {
                // 接收错误，关闭socket并退出循环
                close(sockfd);
                break;
            }
        } else if (n == 0) {
            // 对方关闭连接，关闭socket并退出循环
            close(sockfd);
            break;
        } else {
            // 接收到数据，处理数据
            // ...
        }
    }
    
    return 0;
}

C语言使用TCP协议向服务器发送心跳包

TCP协议发送心跳包的方式与UDP协议略有不同，需要在保持TCP连接的同时发送心跳包。

以下是一个使用TCP协议向服务器发送心跳包的示例代码：

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <errno.h>
#include <signal.h>

#define SERVER_IP "127.0.0.1"
#define SERVER_PORT 8888
#define HEARTBEAT_INTERVAL 10 // 心跳包发送间隔，单位为秒
#define MAX_RETRY_TIMES 3 // 最大重试次数

volatile sig_atomic_t can_exit = 0; // 是否可以退出程序的标志

void sigint_handler(int signum) {
    can_exit = 1;
}

int heartbeat(int sockfd) {
    int ret, retry_times;
    char buf[1024] = "heartbeat";

    while (!can_exit) {
        // 向服务器发送心跳包
        ret = send(sockfd, buf, strlen(buf), 0);
        if (ret <= 0) {
            perror("send");
            return -1;
        }
        printf("send heartbeat\n");
        sleep(HEARTBEAT_INTERVAL);

        // 接收服务器响应
        char recv_buf[1024];
        ret = recv(sockfd, recv_buf, sizeof(recv_buf), MSG_DONTWAIT);
        if (ret < 0) {
            if (errno == EAGAIN || errno == EWOULDBLOCK) {
                // 未收到响应，继续发送心跳包
                continue;
            } else {
                perror("recv");
                return -1;
            }
        } else if (ret == 0) {
            // 连接已断开，需要重新连接
            printf("connection closed\n");
            return -1;
        } else {
            // 收到服务器响应，重置重试次数
            retry_times = 0;
        }

        // 如果连续多次未收到服务器响应，则认为连接已断开
        retry_times++;
        if (retry_times > MAX_RETRY_TIMES) {
            printf("no response from server\n");
            return -1;
        }
    }
    return 0;
}

int main() {
    int sockfd;
    struct sockaddr_in server_addr;

    sockfd = socket(AF_INET, SOCK_STREAM, 0);
    if (sockfd < 0) {
        perror("socket");
        exit(-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);

    // 建立TCP连接
    int ret = connect(sockfd, (struct sockaddr *)&server_addr, sizeof(server_addr));
    if (ret < 0) {
        perror("connect");
        exit(-1);
    }

    // 注册SIGINT信号处理函数，以便在收到Ctrl+C信号时可以安全退出程序
    signal(SIGINT, sigint_handler);

    // 开始发送心跳包
    heartbeat(sockfd);

    close(sockfd);
    return 0;
}

该示例中，使用TCP协议向服务器发送心跳包。心跳包内容为字符串"heartbeat"，发送间隔为10秒。在程序开始时，先建立TCP连接。然后进入心跳包发送循环，不断发送心跳包，同时接收服务器的响应。如果连续多次未收到服务器响应，则认为连接已断开，需要重新连接。如果收到服务器的响应，则重置重试次数。在程序收到Ctrl+C信号时，设置can_exit标志，以便安全退出程序。