您好,登錄后才能下訂單哦!
項目實現(xiàn)中,需要實現(xiàn)tcp服務(wù),多鏈接處理數(shù)據(jù),自定義傳輸協(xié)議,每個鏈接處理的
數(shù)據(jù)完全不一樣,每個鏈接處理完之后,鏈接可能繼續(xù)存在,可能立刻就關(guān)閉了。
在設(shè)計中,使用了select模型進行處理鏈接,但是有些異常情況會導(dǎo)致一些異常信息存
儲在給定的數(shù)據(jù)集合中,數(shù)據(jù)存儲是有上限的,作為服務(wù),要一直運行,不能定時的對服
務(wù)進行重啟,數(shù)據(jù)存儲集合的設(shè)計就存在了一定的問題。
當前解決辦法:
1、買個鏈接處理完數(shù)據(jù)后,直接斷開鏈接,釋放資源。
2、每個鏈接標記存儲到自定義隊列中,設(shè)置超時時間,如果超過時間,就斷開鏈接,
釋放資源。
當前采用了第一種方式在運行驗證。
準備實現(xiàn)第二種方式,將兩種方式進行比較
tcp服務(wù)數(shù)據(jù)接收代碼部分,此部分采用select模式:
int recvTcp() {
fd_set rfd ;
timeval timeout ;
int nRet ;
timeout.tv_sec = 10 ;
timeout.tv_usec = 0 ;
FD_ZERO(&rfd) ;
FD_SET(m_sockTcp,&rfd) ;
while(TRUE){
fd_set fdread = rfd ;
nRet = select(0,&fdread,NULL,NULL,&timeout) ;
if(nRet>0){
for(UINT i=0 ; i<rfd.fd_count ;i++){
if(FD_ISSET(rfd.fd_array[i],&fdread)){
if(rfd.fd_array[i] == m_sockTcp){
if(rfd.fd_count<FD_SETSIZE){
sockaddr_in addrremote={0} ;
int nlen = sizeof(addrremote) ;
SOCKET sNew = accept(m_sockTcp,(sockaddr*)&addrremote,&nlen) ;
FD_SET(sNew,&rfd) ;
}else{
cout<<"max connection"<<endl ;
continue ;
}
}else{
//接收數(shù)據(jù)
char buf[1024] ;
recv(rfd.fd_array[i],buf,1024,0) ;
}
}
}
}
}
closesocket(m_sockTcp) ;
return AR_OK ;
}
免責聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進行舉報,并提供相關(guān)證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權(quán)內(nèi)容。