高效能伺服器程式設計之統一事件源

在伺服器程式設計框架中，都伴隨著配置初始化，日誌列印、訊號處理、連線處理，資料處理等步驟。訊號常常可以用來進行父子程序，執行緒的管控，但訊號與連線到來/資料到來走的是不同的執行路線，並且訊號處理函式要盡可能快地執行完，因為在訊號函式處理期間，該訊號不會被再次觸發。為了能統一管理這些事件，一種典型的統一事件源的方法是，把訊號的主要處理邏輯放到主迴圈中來做，當訊號處理函式被觸發時，它只是簡單地執行目標訊號對應的邏輯**，訊號處理函式通常使用管道來將訊號傳遞給主迴圈，主迴圈通過i/o復用系統呼叫來監聽管道的讀端檔案描述符上的可讀事件。這樣訊號事件就跟其他i/o事件一樣被處理。而不會在處理函式中處理導致該訊號被遮蔽很久。

**如下：

#inlude 
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#include
#define max_event_number 1024
static
int pipefd[2]
;int
setnonblocking
(int fd)
void
addfd
(int epollfd,
int fd)
//訊號處理函式，負責將訊號寫入管道
void
sig_handler
(int sig)
/*設定訊號處理函式*/
void
add_sig
(int sig)
intmain
(int argc,
char
*ar**)
const
char
*ip = ar**[1]
;int port =
atoi
(ar**[2]
);int ret =0;
struct sockaddr_in address;
bzero
(&address,
sizeof
(address));
address.sin_family = af_inet;
inet_pton
(af_inet, ip,
&address.sin_addr)
;	address.sin_port =
htons
(port)
;int listenfd =
socket
(pf_inet, sock_stream,0)
;assert
(listenfd >=0)
;	ret =
bind
(listenfd,
(struct sockaddr *
)&address,
sizeof
(address));
if(ret ==-1
)	ret =
listen
(listenfd,5)
;assert
(ret !=-1
);epoll_event events[max_event_number]
;int epollfd =
epoll_create(5
);assert
(epollfd !=-1
);addfd
(epollfd, listenfd)
;/*使用sockpair建立管道，把pipefd[0]上的可讀事件註冊到epollfd中*/
ret =
socketpair
(pf_unix, sock_stream,
0, pipefd)
;assert
(ret !=1)
;//寫埠，訊號函式呼叫，不要阻塞
setnonblocking
(pipefd[1]
);//讀埠，主迴圈呼叫
addfd
(epollfd, pipefd[0]
);/*設定一些訊號的處理函式*/
addsig
(sighup)
;addsig
(sigchld)
;addsig
(sifterm)
;addsig
(sigint)
;	bool stop_server = false;
while
(!stop_server)
for(
int i =
0; i < number; i++
)/*如果是訊號管道*/
elseif(
(sockfd == pipefd[0]
)&&(events[i]
.events & epollin)
)case sigint:
case sigterm:}}
}else}}
}printf
("close fds\n");
close
(listenfd)
;close
(pipefd[1]
);close
(pipefd[0]
);return0;
}

高效能伺服器程式設計之統一事件源

高效能伺服器程式設計之epoll

linux網路程式設計十八統一事件源

Linux高效能伺服器程式設計（一）

高效能伺服器程式設計之統一事件源

高效能伺服器程式設計之epoll

linux網路程式設計十八 統一事件源

Linux高效能伺服器程式設計（一）

相關推薦

linux網路程式設計十八統一事件源