在網絡通訊中,socket處于阻塞模式運行時,其存在著超時處理。以下總結下在那些阻塞函數的處理方法。
這里摘抄一段描述阻塞函數的描述,非常到位。
所謂阻塞函數,是指其完成指定的任務之前不允許程序調用另一個函數,在Windows下還會阻塞本線程消息的發送。 所謂非阻塞函數,是指操作啟動之后,如果可以立即得到結果就返回結果,否則返回表示結果需要等待的錯誤信息,不等待任務完成函數就返回。 首先,異步函數是非阻塞函數; 其次,獲取遠地信息的數據庫函數是阻塞函數(因此,WinSock提供了其異步版本); 在Berkeley socket函數部分中,不涉及網絡I/O、本地端工作的函數是非阻塞函數; 在Berkeley socket函數部分中,網絡I/O的函數是可阻塞函數,也就是它們可以阻塞執行,也可以不阻塞執行。這些函數都使用了一個socket,如果它們使用的socket是阻塞的,則這些函數是阻塞函數;如果它們使用的socket是非阻塞的,則這些函數是非阻塞函數 |
其實說明阻塞還是非阻塞也是我們可以設置相關。這里主要講解下處于阻塞模式下的超時處理。
1.在我們直接調用socket創建時,如果不進行特意聲明的話,創建的socket都是阻塞的。這樣當我們調用accept,recv時,將有可能“block”,如果想設置為非阻塞,則方法有調用fcntl,select,WSAAsynSelect 來改變socket的阻塞
hsocket = socket(AF_INET, SOCK_STREAM, 0)
fcntl(hsocket, F_SETFL, 0_NONBLOCK);
注意:
其中fcntl是Unix系統環境中使用的,使用ioctl()函數和fcntl()函數實現對套接字的控制,而在Windows系統中則應使用ioctlsocket()函數。
Ioctl和fcntl的區別是:
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的體味的函數,看著就頭大。這個我是摘自某個文檔,設置超時應該采用ioctlsocket。)
1.調用MFC的CAsyncSocket和CSocket類
MFC提供了兩個類CAsyncSocket和CSocket來封裝WinSock API,
CAsyncSocket在較低層次上封裝了WinSock API,缺省情況下,使用該類創建的socket是非阻塞的socket,所有操作都會立即返回,如果沒有得到結果,返回WSAEWOULDBLOCK,表示是一個阻塞操作。
CSocket建立在CAsyncSocket的基礎上,是CAsyncSocket的派生類。也就是缺省情況下使用該類創建的socket是非阻塞的socket,但是CSocket的網絡I/O是阻塞的,它在完成任務之后才返回。CSocket的阻塞不是建立在“阻塞”socket的基礎上,而是在“非阻塞”socket上實現的阻塞操作,在阻塞期間,CSocket實現了本線程的消息循環,因此,雖然是阻塞操作,但是并不影響消息循環,即用戶仍然可以和程序交互。(即程序不會freeze)。
其中設置超時函數如下:
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可以可以設置為0,沒有實際意義。
fd_set fdR;
struct timeval timeout = ..; //設置超時時間
...
for(;;) {
FD_ZERO(&fdR);
FD_SET(sockfd, &fdR);
switch (select(sockfd + 1, &fdR, NULL, &timeout)) {
case -1:
//錯誤,需要關閉端口。。。
case 0:
// timeout 處理
default:
if (FD_ISSET(sockfd)) {
//或讀寫操作或Accept()操作,按你設置處理。
}
}
}
注意的是:
由于Windows Sockets 某些函數在接口上雖然與Unix Sockets一致,但是它們的內部實現卻不一樣,例如,在函數select()的參數中,Unix Sockets實現套接字集合使用的是位掩碼,但在Windows Sockets中卻是使用一個SOCKET的數組。雖然套接字的集合仍由fd_set類型表示,但在Unix Sockets 源文件中直接修改fd_set結構的代碼在Windows Sockets環境下將不能正常工作。故fd_set在微軟中則采用FD_XXX宏處理。
3.采用WSAsyncSelect()
這個是消息事件模式來處理的,通過其中參數句柄返回一個消息,在自定義消息中處理。
4.采用setsockopt設置超時
int PASCAL FAR setsockopt( SOCKET s, int level, int optname, const char FAR* optval, int optlen); s:標識一個套接口的描述字。 level:選項定義的層次;目前僅支持SOL_SOCKET和IPPROTO_TCP層次。 optname:需設置的選項。 optval:指針,指向存放選項值的緩沖區。 optlen:optval緩沖區的長度。 |
setsockopt()函數用于任意類型、任意狀態套接口的設置選項值。盡管在不同協議層上存在選項,但本函數僅定義了最高的“套接口”層次上的選項。選項影響套接口的操作,諸如加急數據是否在普通數據流中接收,廣播數據是否可以從套接口發送等等。
有兩種套接口的選項:
一種是布爾型選項,允許或禁止一種特性;
一種是整形或結構選項。允許一個布爾型選項,則將optval指向非零整形數;禁止一個選項optval指向一個等于零的整形數。
對于布爾型選項,optlen應等于sizeof(int);對其他選項,optval指向包含所需選項的整形數或結構,而optlen則為整形數或結構的長度。
SO_LINGER選項用于控制下述情況的行動:套接口上有排隊的待發送數據,且closesocket()調用已執行。參見closesocket()函數中關于SO_LINGER選項對closesocket()語義的影響。應用程序通過創建一個linger結構來設置相應的操作特性。
這個setsockopt的水也太深了,對于一般運用大致運用就行,主要是其中參數太多,只需要了解幾個就可以了,至于想了解更多,則讀msdn吧,以及相關的文檔吧,不過感覺這些東西純粹就是個技術指標細節,不需要動腦筋卻需要了解的一個方面,說白了是這些都是技術活而不是腦力活。
常見的命令:
//確定套接字自動讀入的數據量
#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 */
//確定是否所有帶外數據都已被讀入
#define SIOCATMARK _IOR(''''s'''', 7, u_long) /* at oob mark? */
設置接受超時