您好,登錄后才能下訂單哦!
項目實現中,需要實現tcp服務,多鏈接處理數據,自定義傳輸協議,每個鏈接處理的
數據完全不一樣,每個鏈接處理完之后,鏈接可能繼續存在,可能立刻就關閉了。
在設計中,使用了select模型進行處理鏈接,但是有些異常情況會導致一些異常信息存
儲在給定的數據集合中,數據存儲是有上限的,作為服務,要一直運行,不能定時的對服
務進行重啟,數據存儲集合的設計就存在了一定的問題。
當前解決辦法:
1、買個鏈接處理完數據后,直接斷開鏈接,釋放資源。
2、每個鏈接標記存儲到自定義隊列中,設置超時時間,如果超過時間,就斷開鏈接,
釋放資源。
當前采用了第一種方式在運行驗證。
準備實現第二種方式,將兩種方式進行比較
tcp服務數據接收代碼部分,此部分采用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{
//接收數據
char buf[1024] ;
recv(rfd.fd_array[i],buf,1024,0) ;
}
}
}
}
}
closesocket(m_sockTcp) ;
return AR_OK ;
}
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。