在網(wǎng)絡(luò)通訊中,socket處于阻塞模式運行時,其存在著超時處理。以下總結(jié)下在那些阻塞函數(shù)的處理方法。
這里摘抄一段描述阻塞函數(shù)的描述,非常到位。
所謂阻塞函數(shù),是指其完成指定的任務(wù)之前不允許程序調(diào)用另一個函數(shù),在Windows下還會阻塞本線程消息的發(fā)送。 所謂非阻塞函數(shù),是指操作啟動之后,如果可以立即得到結(jié)果就返回結(jié)果,否則返回表示結(jié)果需要等待的錯誤信息,不等待任務(wù)完成函數(shù)就返回。 首先,異步函數(shù)是非阻塞函數(shù); 其次,獲取遠地信息的數(shù)據(jù)庫函數(shù)是阻塞函數(shù)(因此,WinSock提供了其異步版本); 在Berkeley socket函數(shù)部分中,不涉及網(wǎng)絡(luò)I/O、本地端工作的函數(shù)是非阻塞函數(shù); 在Berkeley socket函數(shù)部分中,網(wǎng)絡(luò)I/O的函數(shù)是可阻塞函數(shù),也就是它們可以阻塞執(zhí)行,也可以不阻塞執(zhí)行。這些函數(shù)都使用了一個socket,如果它們使用的socket是阻塞的,則這些函數(shù)是阻塞函數(shù);如果它們使用的socket是非阻塞的,則這些函數(shù)是非阻塞函數(shù) |
其實說明阻塞還是非阻塞也是我們可以設(shè)置相關(guān)。這里主要講解下處于阻塞模式下的超時處理。
1.在我們直接調(diào)用socket創(chuàng)建時,如果不進行特意聲明的話,創(chuàng)建的socket都是阻塞的。這樣當我們調(diào)用accept,recv時,將有可能“block”,如果想設(shè)置為非阻塞,則方法有調(diào)用fcntl,select,WSAAsynSelect 來改變socket的阻塞
hsocket = socket(AF_INET, SOCK_STREAM, 0)
fcntl(hsocket, F_SETFL, 0_NONBLOCK);
注意:
其中fcntl是Unix系統(tǒng)環(huán)境中使用的,使用ioctl()函數(shù)和fcntl()函數(shù)實現(xiàn)對套接字的控制,而在Windows系統(tǒng)中則應(yīng)使用ioctlsocket()函數(shù)。
Ioctl和fcntl的區(qū)別是:
ioctl - control device
ioctl() performs a variety of control functions on devices
and STREAMS. For non-STREAMS files, the functions performed
by this call are device-specific control functions. request
and an optional third argument with varying type are passed
to the file designated by fildes and are interpreted by the
device driver.
The fcntl() function provides control of open file descriptors. It is similar to ioctl().
( 這些帶著unix的體味的函數(shù),看著就頭大。這個我是摘自某個文檔,設(shè)置超時應(yīng)該采用ioctlsocket。)
1.調(diào)用MFC的CAsyncSocket和CSocket類
MFC提供了兩個類CAsyncSocket和CSocket來封裝WinSock API,
CAsyncSocket在較低層次上封裝了WinSock API,缺省情況下,使用該類創(chuàng)建的socket是非阻塞的socket,所有操作都會立即返回,如果沒有得到結(jié)果,返回WSAEWOULDBLOCK,表示是一個阻塞操作。
CSocket建立在CAsyncSocket的基礎(chǔ)上,是CAsyncSocket的派生類。也就是缺省情況下使用該類創(chuàng)建的socket是非阻塞的socket,但是CSocket的網(wǎng)絡(luò)I/O是阻塞的,它在完成任務(wù)之后才返回。CSocket的阻塞不是建立在“阻塞”socket的基礎(chǔ)上,而是在“非阻塞”socket上實現(xiàn)的阻塞操作,在阻塞期間,CSocket實現(xiàn)了本線程的消息循環(huán),因此,雖然是阻塞操作,但是并不影響消息循環(huán),即用戶仍然可以和程序交互。(即程序不會freeze)。
其中設(shè)置超時函數(shù)如下:
CAsyncSocket::SetSockOpt( int nOptionName, const void* lpOptionValue, int nOptionLen, int nLevel = SOL_SOCKET );
nOptionName用SO_SNDTIMEO or SO_RCVTIMEO。
2.采用select處理超時
int select(int nfds, fd_set FAR* readfds, fd_set FAR* writefds,fd_set FAR*exceptfds, const struct timeval FAR* timeout)
其中在windows中,其nfds可以可以設(shè)置為0,沒有實際意義。
fd_set fdR;
struct timeval timeout = ..; //設(shè)置超時時間
...
for(;;) {
FD_ZERO(&fdR);
FD_SET(sockfd, &fdR);
switch (select(sockfd + 1, &fdR, NULL, &timeout)) {
case -1:
//錯誤,需要關(guān)閉端口。。。
case 0:
// timeout 處理
default:
if (FD_ISSET(sockfd)) {
//或讀寫操作或Accept()操作,按你設(shè)置處理。
}
}
}
注意的是:
由于Windows Sockets 某些函數(shù)在接口上雖然與Unix Sockets一致,但是它們的內(nèi)部實現(xiàn)卻不一樣,例如,在函數(shù)select()的參數(shù)中,Unix Sockets實現(xiàn)套接字集合使用的是位掩碼,但在Windows Sockets中卻是使用一個SOCKET的數(shù)組。雖然套接字的集合仍由fd_set類型表示,但在Unix Sockets 源文件中直接修改fd_set結(jié)構(gòu)的代碼在Windows Sockets環(huán)境下將不能正常工作。故fd_set在微軟中則采用FD_XXX宏處理。
3.采用WSAsyncSelect()
這個是消息事件模式來處理的,通過其中參數(shù)句柄返回一個消息,在自定義消息中處理。
4.采用setsockopt設(shè)置超時
int PASCAL FAR setsockopt( SOCKET s, int level, int optname, const char FAR* optval, int optlen); s:標識一個套接口的描述字。 level:選項定義的層次;目前僅支持SOL_SOCKET和IPPROTO_TCP層次。 optname:需設(shè)置的選項。 optval:指針,指向存放選項值的緩沖區(qū)。 optlen:optval緩沖區(qū)的長度。 |
setsockopt()函數(shù)用于任意類型、任意狀態(tài)套接口的設(shè)置選項值。盡管在不同協(xié)議層上存在選項,但本函數(shù)僅定義了最高的“套接口”層次上的選項。選項影響套接口的操作,諸如加急數(shù)據(jù)是否在普通數(shù)據(jù)流中接收,廣播數(shù)據(jù)是否可以從套接口發(fā)送等等。
有兩種套接口的選項:
一種是布爾型選項,允許或禁止一種特性;
一種是整形或結(jié)構(gòu)選項。允許一個布爾型選項,則將optval指向非零整形數(shù);禁止一個選項optval指向一個等于零的整形數(shù)。
對于布爾型選項,optlen應(yīng)等于sizeof(int);對其他選項,optval指向包含所需選項的整形數(shù)或結(jié)構(gòu),而optlen則為整形數(shù)或結(jié)構(gòu)的長度。
SO_LINGER選項用于控制下述情況的行動:套接口上有排隊的待發(fā)送數(shù)據(jù),且closesocket()調(diào)用已執(zhí)行。參見closesocket()函數(shù)中關(guān)于SO_LINGER選項對closesocket()語義的影響。應(yīng)用程序通過創(chuàng)建一個linger結(jié)構(gòu)來設(shè)置相應(yīng)的操作特性。
這個setsockopt的水也太深了,對于一般運用大致運用就行,主要是其中參數(shù)太多,只需要了解幾個就可以了,至于想了解更多,則讀msdn吧,以及相關(guān)的文檔吧,不過感覺這些東西純粹就是個技術(shù)指標細節(jié),不需要動腦筋卻需要了解的一個方面,說白了是這些都是技術(shù)活而不是腦力活。
常見的命令:
//確定套接字自動讀入的數(shù)據(jù)量
#define FIONREAD _IOR(''''f'''', 127, u_long) /* get # bytes to read */
//允許或禁止套接字的非阻塞模式,允許為非0,禁止為0
#define FIONBIO _IOW(''''f'''', 126, u_long) /* set/clear non-blocking i/o */
//確定是否所有帶外數(shù)據(jù)都已被讀入
#define SIOCATMARK _IOR(''''s'''', 7, u_long) /* at oob mark? */
設(shè)置接受超時