select机制
?
背景知識分析:
?1. fd_set 結構體
? fd_set是文件句柄的集合。???
????
?? FD_ZERO??? 清空這個集合;???
?? FD_SET 往這個集合里面加入一個文件句柄;???
?? FD_ISSET????? 查看某一個文件句柄是否被設置了;
?? 'fd_set') 是一組文件描述符(fd)的集合。由于fd_set類型的長度在不同平臺上不同,因此應該用一組標準的宏定義來處理此類變量:??
?? fd_set set;??????
?? FD_ZERO(&set);??????? /* 將set清零 */????
?? FD_SET(fd, &set);???? /* 將fd加入set */???
?? FD_CLR(fd, &set);???? /* 將fd從set中清除 */????
?? FD_ISSET(fd, &set);?? /* 判斷fd是否處于可用狀態 是為true */??
2使用介紹:
[cpp]?view plaincopy
注意select函數的第一個參數,是所有加入集合的句柄值的最大那個值還要加1。比如我們創建了3個句柄:
[cpp]?view plaincopy
在使用select函數之前,一定要找到3個句柄中的最大值是哪個,我們一般定義一個變量來保存最大值,取得最大socket值如下:
[cpp]?view plaincopy
然后調用select函數:
[cpp]?view plaincopy
?
3 關于 Select 的 FD_SETSIZE
?
nt select(int n, fd_set *rd_fds, fd_set *wr_fds, fd_set *ex_fds, struct timeval *timeout);
Select 用到了fd_set結構,從man page里可以知道fd_set能容納的句柄和FD_SETSIZE相關。實際上fd_set在*nix下是一個bit標志數組,每個bit表示對應下標 的fd是不是在fd_set中。fd_set只能容納編號小于 FD_SETSIZE的那些句柄。
FD_SETSIZE默認是1024,如果向 fd_set里放入過大的句柄,數組越界以后程序就會垮掉。系統默認限制了一個進程最大的句柄號不超過1024,但是可以通過ulimit -n命令/setrlimit函數來擴大這一限制。如果不幸一個程序在FD_SETSIZE=1024的環境下編譯,運行時又遇到ulimit n > 1024的,那就只有祈求上帝保佑不會垮掉了。
通過上述說明,可以看到如果連接很多的話,建議還是使用epoll來解決這個問題。
4 select 機制的優勢
為什么會出現select模型?
先看一下下面的這句代碼:
int iResult = recv(s, buffer,1024);
這是用來接收數據的,在默認的阻塞模式下的套接字里,recv會阻塞在那里,直到套接字連接上有數據可讀,把數據讀到buffer里后recv函數才會返 回,不然就會一直阻塞在那里。在單線程的程序里出現這種情況會導致主線程(單線程程序里只有一個默認的主線程)被阻塞,這樣整個程序被鎖死在這里,如果永 遠沒數據發送過來,那么程序就會被永遠鎖死。這個問題可以用多線程解決,但是在有多個套接字連接的情況下,這不是一個好的選擇,擴展性很差。
再看代碼:
int iResult = ioctlsocket(s, FIOBIO, (unsigned long *)&ul);
iResult = recv(s, buffer,1024);
這一次recv的調用不管套接字連接上有沒有數據可以接收都會馬上返回。原因就在于我們用ioctlsocket把套接字設置為非阻塞模式了。不過 你跟蹤 一下就會發現,在沒有數據的情況下,recv確實是馬上返回了,但是也返回了一個錯誤:WSAEWOULDBLOCK,意思就是請求的操作沒有成功完成。 看到這里很多人可能會說,那么就重復調用recv并檢查返回值,直到成功為止,但是這樣做效率很成問題,開銷太大。
select模型的出現就是為了解決上述問題。
select模型的關鍵是使用一種有序的方式,對多個套接字進行統一管理與調度?。
看核心代碼:(這里只給出服務端的)
while ( 1 )
{
// 初始化fdset
FD_ZERO( &fdsRead );
// 將server套接字添加到可讀集合中
FD_SET( sockServer, &fdsRead );
// 調用select
select( 0, &fdsRead, NULL, NULL, &tv );
// 判斷server套接字的狀態,如果套接字還在可讀集合中,
// 說明有數據可以讀入,則建立套接字可以成功
if ( FD_ISSET( sockServer, &fdsRead ) )
{
sockAccept = accept( sockServer, (sockaddr*)&addr, &nLen );
// 有數據可讀,進行相關處理
}
?
?
總結
- 上一篇: epoll机制
- 下一篇: epoll与select区别