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