linux服務(wù)器端發(fā)數(shù)據(jù)時(shí)對端一直不收怎么解決

對于這種情況，我們一般建議從以下幾個(gè)方面來增加一些防御措施：

1. 設(shè)置每路發(fā)送連接的發(fā)送緩沖區(qū)大小上限（如 2 M，或者小于這個(gè)值），當(dāng)某路連接上的數(shù)據(jù)發(fā)送不出去的時(shí)候，即將數(shù)據(jù)存入發(fā)送緩沖區(qū)時(shí)，先判斷一下緩沖區(qū)最大剩余空間，如果剩余空間已經(jīng)小于我們要放入的數(shù)據(jù)大小，也就是說緩沖區(qū)中數(shù)據(jù)大小會(huì)超過了我們規(guī)定的上限，則認(rèn)為該連接出現(xiàn)了問題，關(guān)閉該路連接并回收相應(yīng)的資源（如清空緩沖區(qū)、回收套接字資源等）。示例代碼如下：

   //outputBuffer_為發(fā)送緩沖區(qū)對象
   size_t remainingLen = outputBuffer_.remainingBytes();
   //如果加入到緩沖區(qū)中的數(shù)據(jù)長度超出了發(fā)送緩沖區(qū)最大剩余量
   if (remainingLen < dataToAppend.length())
   {
   		forceClose()
   		return
   }
   
   outputBuffer_.append(static_cast<const char*>(dataToAppend.c_str()), dataToAppend.length());
   

2. 還有另外一種場景，當(dāng)有一部分?jǐn)?shù)據(jù)已經(jīng)積壓在發(fā)送緩沖區(qū)了，此后服務(wù)器端未產(chǎn)生新的待發(fā)送的數(shù)據(jù)，此時(shí)如果不做任何處理，發(fā)送緩沖區(qū)的數(shù)據(jù)會(huì)一直積壓，但是發(fā)送緩沖區(qū)的數(shù)據(jù)容量也不會(huì)超過上限。如果不做任何處理的話，該數(shù)據(jù)會(huì)一直在緩沖區(qū)中積壓，白白浪費(fèi)系統(tǒng)資源。對于這種情況一般我們會(huì)設(shè)置一個(gè)定時(shí)器，每隔一段時(shí)間（如 3 秒）去檢查一下各路連接的發(fā)送緩沖區(qū)中是否還有數(shù)據(jù)未發(fā)送出去，也就是說如果一個(gè)連接超過一定時(shí)間內(nèi)還存在未發(fā)送出去的數(shù)據(jù)，我們也認(rèn)為該連接出現(xiàn)了問題，我們可以關(guān)閉該路連接并回收相應(yīng)的資源（如清空緩沖區(qū)、回收套接字資源等）。示例代碼如下：

   //每3秒檢測一次
   const int SESSION_CHECK_INTERVAL = 3000;
   
   SetTimer(SESSION_CHECK_TIMER_ID, SESSION_CHECK_INTERVAL);
   
   void CSessionManager::OnTimer()
   {
       for (auto iter = m_mapSession.begin(); iter != m_mapSession.end(); ++iter)
       {
           if (!CheckSession(iter->value))
           {
               //關(guān)閉session，回收相關(guān)的資源
               iter->value->ForceClose();
   
               iter = m_mapSession.erase(iter);
           }
       }
   }
   
   void CSessionManager::CheckSession(CSession* pSession)
   {
       if (!pSession->GetConnection().OutputBuffer.IsEmpty())
           return false;
   
       return true;
   }