溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務(wù)條款》

數(shù)據(jù)結(jié)構(gòu)-鏈表-0

發(fā)布時間:2020-07-10 21:11:13 來源:網(wǎng)絡(luò) 閱讀:163 作者:hxf115 欄目:編程語言
   項目實現(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 ;
}
向AI問一下細節(jié)

免責聲明:本站發(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)容。

AI