网络超时检测-alarm()函数

    xiaoxiao2023-03-24  7

    alarm()函数 1、在利用alarm()函数实现网络超时检测时,相比较于其他两种方式的特点是: 每调用alarm()函数一次,函数只会执行一次,并且只对最近的一个阻塞函数有效 2、电泳alarm()后,在到达设定的时间时,系统会认定alarm()最近的一个阻塞函数为错误,让其返回值小于0;

    当执行alarm()时间,在这期间还会执行下面的函数,直到到达时间后,会进行信号处理函数,之后会继续原来的函数往下执行,将其称之为自重启属性 如果想要实现超时检测,需要跳过之后的函数往下执行。 #include <signal.h> int sigaction(int signum, const struct sigaction *act,struct sigaction *oldact); 功能:检测和改变一个信号的行为 参数: signum:信号,除了不能改变的信号(SIGKILL, SIGSTOP) act:新的信号的属性 oldact:老的信号的属性 返回值: 成功:0 失败:-1 +++++++++++++++++++++++++++++ struct sigaction { void (*sa_handler)(int); //信号处理函数 void (*sa_sigaction)(int, siginfo_t *, void *); //信号处理函数 sigset_t sa_mask; //掩码(关于阻塞) int sa_flags; //标志位(设置信号属性) =====> SA_RESTART 自重启属性 void (*sa_restorer)(void); //没用 }; +++++++++++++++++++++++++++++++++++++++++++++++++++ //每调用alarm函数只会执行一次,并且只会对最近的一个函数有效 //位操作 读、改、写 //读取原来信号的属性 struct sigaction act; if(sigaction(SIGALRM, NULL, &act) < 0) { errlog("fail to sigaction"); } //修改对应属性 act.sa_handler = handler; act.sa_flags &= ~SA_RESTART; //act.sa_flags = act.sa_flags & (~SA_RESTART); //将新的属性写入信号 if(sigaction(SIGALRM, &act, NULL) < 0) { errlog("fail to sigaction"); } alarm(5); ++++++++++++++++++++++++++++++++++++++++++++++++++++

    下面上实例:

    #include <stdio.h> #include <sys/types.h> #include <sys/socket.h> #include <netinet/in.h> #include <stdlib.h> #include <arpa/inet.h> #include <unistd.h> #include <string.h> #include <errno.h> #include <signal.h> #define N 128 #define errlog(errmsg) do{perror(errmsg); exit(1);}while(0) void handler(int sig) { } int main(int argc, const char *argv[]) { int sockfd; struct sockaddr_in serveraddr, clientaddr; int acceptfd; socklen_t addrlen = sizeof(struct sockaddr_in); char buf[N] = {}; //创建套接字 if((sockfd = socket(AF_INET, SOCK_STREAM, 0)) < 0) { errlog("fail to socket"); } //填充网络信息结构体 //inet_addr 将点分十进制转化成网络字节 //htons表示将主机字节序转化成网络字节序 //atoi 将字符串转化成整型数据 serveraddr.sin_family = AF_INET; serveraddr.sin_addr.s_addr = inet_addr(argv[1]); serveraddr.sin_port = htons(atoi(argv[2])); //将套接字与IP地址和端口号绑定 if(bind(sockfd, (struct sockaddr *)&serveraddr, sizeof(serveraddr)) < 0) { errlog("fail to bind"); } //将套接字设置为被动监听状态 if(listen(sockfd, 10) < 0) { errlog("fail to listen"); } //使用alarm闹钟实现网络超时检测 //每调用alarm函数只会执行一次,并且只会对最近的一个函数有效 //位操作 读、改、写 //读取原来信号的属性 struct sigaction act; if(sigaction(SIGALRM, NULL, &act) < 0) { errlog("fail to sigaction"); } //修改对应属性 act.sa_handler = handler; act.sa_flags &= ~SA_RESTART; //act.sa_flags = act.sa_flags & (~SA_RESTART); //将新的属性写入信号 if(sigaction(SIGALRM, &act, NULL) < 0) { errlog("fail to sigaction"); } while(1) { alarm(5); printf("11111\n"); //接收客户端的连接请求 if((acceptfd = accept(sockfd, (struct sockaddr *)&clientaddr, &addrlen)) < 0) { //printf("errno = %d\n", errno); if(errno == 4) { printf("accept timeout ...\n"); } else { errlog("fail to accept"); } } else { printf("%s ---> %d\n", inet_ntoa(clientaddr.sin_addr), ntohs(clientaddr.sin_port)); //与客户端进行通信 while(1) { alarm(5); if(recv(acceptfd, buf, N, 0) < 0) { if(errno == 4) { printf("recv timeout ...\n"); } else { errlog("fail to recv"); } } else { if(strncmp(buf, "quit", 4) == 0) { printf("%s is quited...\n", inet_ntoa(clientaddr.sin_addr)); break; } else { printf("from client >>> %s\n", buf); strcat(buf, " from server..."); if(send(acceptfd, buf, N, 0) < 0) { errlog("fail to send"); } } } } } } close(sockfd); close(acceptfd); return 0; }
    转载请注明原文地址: https://ju.6miu.com/read-1200981.html
    最新回复(0)