。

因此需要通过实现一个服务器定时器#xff0c;处理这种非活跃连接#xff0c;释放连接资源。

定时器处理流程

信号…如果客户端长时间没有动作会占用了许多连接资源严重影响服务器的性能。

因此需要通过实现一个服务器定时器处理这种非活跃连接释放连接资源。

定时器处理流程

信号该信号每5秒会触发一次。

发送消息当SIGALARM触发时会进入

sig_handler

中断服务函数中在该函数中会向管道写端发送数据Epoll轮询管道读端接收到消息后使用

epoll

函数中检查连接是否超时由于定时器的数据结构是一个链表所以这个过程实际上是链表的查询操作超时处理当链表查询到客户端超时连接时服务器会调用

cb_func

回调函数来断开这些连接。

在这个函数中服务器可能会执行一些必要的清理工作比如从

epoll

sockfd以及删除定时器。

重定时当查询到各个客户端都不超时或者执行完

cb_func

回调函数处理的客户数据由定时器的执行者传递给回调函数client_data*

prev;util_timer*

};定时器实际上是链表的一个节点里面存着任务超时时间这里是使用绝对时间以及任务的回调函数cb_func客户端数据使用的是一个额外的结构体里面有客户端的地址族、sockfd、以及下一个定时器的指针。

当然也可以用http_conn这个数据类但比较麻烦

定时器链表,

调整该定时器在链表中的位置此函数只考虑定时时间延长的情况即定时器往链表的后面移动void

timer);/*

SIGALARM每触发一次就在信号处理函数执行一次tick函数,

*/void

prev-next;while(tmp){if(timer-expire

timer;timer-next

user_data-sockfd);epoll_ctl(epollfd,

EPOLL_CTL_DEL,

0);assert(user_data);close(user_data-sockfd);

}初始化

-1);setnonblocking(pipefd[1]);addfd(epollfd,

pipefd[0],

timer_sig_handler);addsig(SIGTERM,

timer_sig_handler);

函数用于创建一个全双工的、相互连接的、无名的套接字对。

这两个套接字就像是同一个管道的两端但它们是网络通信的范畴而不是进程间管道通信的范畴。

简单来说就是模拟成管道通信在默认情况下当使用

write

函数向管道写入数据时如果管道的读端缓冲区已满写操作将被阻塞直到有空间可用。

因此我们需要将

pipefd[1]

//创建定时器设置回调函数和超时时间绑定用户数据将定时器添加到链表中

client_address;

timer_lst.add_timer(timer);读端有数据

else

Linux高并发服务器项目参考了TinyWebServer将在此基础上进行性能改进与功能增加。

为方便读者学习附带详细注释和博客

TinyWebserver的复现与改进1服务器环境的搭建与测试-CSDN博客

TinyWebserver的复现与改进2项目的整体框架-CSDN博客

TinyWebserver的复现与改进3线程同步机制类封装及线程池实现-CSDN博客

TinyWebserver的复现与改进4主线程的具体实现-CSDN博客

TinyWebserver的复现与改进5HTTP报文的解析与响应-CSDN博客

完整代码

user_data-sockfd);epoll_ctl(epollfd,

EPOLL_CTL_DEL,

0);assert(user_data);close(user_data-sockfd);

void

{timer_lst.tick();alarm(TIMESLOT);

类型说明符

指定sa内存区域的前n个字节都设置为某个特定的值(\0)用于对新分配的内存进行初始化memset(sa,

\0,

写入函数指针指向的函数就是信号捕捉到之后的处理函数sa.sa_handler

SA_RESTART;//

设置临时阻塞信号集sigfillset(sa.sa_mask);assert(sigaction(sig,

sa,

-1);setnonblocking(pipefd[1]);addfd(epollfd,

pipefd[0],

timer_sig_handler);addsig(SIGTERM,

timer_sig_handler);

如果向一个没有读端的管道写数据不用终止进程addsig(SIGPIPE,

SIG_IGN);

threadpoolhttp_conn;}catch(...){//

若异常则退出return

开辟一块连续的http_conn数组保存所有正在连接的客户端信息http_conn*

users

address;address.sin_addr.s_addr

htons(port);//

-1){perror(listen);exit(-1);}//

events[MAX_EVENT_NUMBER];epollfd

listenfd,

false;alarm(TIMESLOT);while(!stop_server){//

epoll轮询等待有数据发送int

MAX_EVENT_NUMBER,-1);if((number

(errno

errno);continue;}if(http_conn::m_user_count

MAX_FD){close(connfd);continue;}users[connfd].init(connfd,

client_address);//初始化client_data数据//创建定时器设置回调函数和超时时间绑定用户数据将定时器添加到链表中users_timer[connfd].address

client_address;users_timer[connfd].sockfd

connfd;util_timer

users_timer[connfd];timer-cb_func

cb_func;time_t

3*TIMESLOT;users_timer[connfd].timer

timer;timer_lst.add_timer(timer);}else

if((sockfd

EPOLLERR)){users[sockfd].close_conn();}//

if(events[i].events

有读事件发生if(users[sockfd].read()){//

读的到数据pool-append(userssockfd);//若有数据传输则将定时器往后延迟3个单位//并对新的定时器在链表上的位置进行调整if

(timer){time_t

TIMESLOT;timer_lst.adjust_timer(timer);}}else{printf(Read

Fail!\n);//

读不到数据timer-cb_func(users_timer[sockfd]);if

(timer){timer_lst.del_timer(timer);}//

users[sockfd].close_conn();}}//

if(events[i].events

users_timer[sockfd].timer;if(users[sockfd].write()){if

(timer){time_t

TIMESLOT;timer_lst.adjust_timer(timer);}}else{printf(Write

Fail!\n);timer-cb_func(users_timer[sockfd]);if

(timer){timer_lst.del_timer(timer);}//

users[sockfd].close_conn();}}}if

(timeout){timer_handler();timeout

false;}}close(epollfd);close(listenfd);close(pipefd[1]);close(pipefd[0]);delete

users;delete[]

回调函数处理的客户数据由定时器的执行者传递给回调函数client_data*

prev;util_timer*

调整该定时器在链表中的位置此函数只考虑定时时间延长的情况即定时器往链表的后面移动void

timer);/*

SIGALARM每触发一次就在信号处理函数执行一次tick函数,

*/void

prev-next;while(tmp){if(timer-expire

timer;timer-next

sort_timer_lst::sort_timer_lst():

head(NULL),

sort_timer_lst::~sort_timer_lst()

{util_timer*

sort_timer_lst::add_timer(util_timer*

timer)

{if(!timer){return;}if(!head){head

tail

如果目标定时器的超时时间小于当前链表中所有定时器的超时时间则把该定时器插入链表头部,作为链表新的头节点否则就需要调用重载函数

add_timer(),把它插入链表中合适的位置以保证链表的升序特性

*/if(timer-expire

sort_timer_lst::del_timer(util_timer*

timer)

调整该定时器在链表中的位置此函数只考虑定时时间延长的情况即定时器往链表的后面移动

void

sort_timer_lst::adjust_timer(util_timer*

timer)

{if(!timer){return;}util_timer*

tmp

目标定时器在链表的后面或者定时时长小于后面的则不动if(!tmp

(timer-expire

目标定时器在链表中间则重新插入到链表中else{timer-prev-next

timer-next);}

SIGALARM每触发一次就在信号处理函数执行一次tick函数,

void

从头节点依次处理每一个定时器直到遇到一个尚未定期的定时器while(tmp){//

调用定时器回调函数执行定时任务tmp-cb_func(tmp-user_data);head

NULL;}delete