网络超时检测-alarm（）函数

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
= {};

//创建套接字
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);

//将新的属性
aa3c
写入信号
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;
}