Thrift第四課 連接中斷異常處理

場景

????????Thrift框架采用了異常處理機制，當客戶端異常斷開連接，服務端這個時候嘗試發送數據給客戶端，Thrift庫會拋出異常，導致進程中斷。這種情況是非常正常的，服務器端應該捕獲異常的發生，但是不應該異常退出。

在用戶調用的線程進行異常捕獲，這樣子不需要修改代碼

catch (const TTransportException& ttx)

{

//Thrift框架拋出的所有異常都會直接返回

std::cout<<ttx.what()<<std::endl;

return;

}

catch (const TException& ttx)

{

//Thrift框架拋出的所有異常都會直接返回

std::cout<<ttx.what()<<std::endl;

return;

}

分析一下服務器發送數據的函數

void TSocket::write(const uint8_t* buf, uint32_t len) {

? uint32_t sent = 0;

? while (sent < len) {

?uint32_t b = write_partial(buf + sent, len - sent);

?if (b == 0) {

?// This should only happen if the timeout set with SO_SNDTIMEO expired.

?// Raise an exception.

?throw TTransportException(TTransportException::TIMED_OUT,

?"send timeout expired");

?}

?sent += b;

? }

}

但b==0拋出異常，代表當前發送超時。while循環是為了循環發送，因為一次不一定發送完用戶數據，畢竟MTU的限制。注意sent是一個無符號整型，當b返回-1的時候，sent==0-1意味著將達到32位整數最大值，大于len，從而直接退出循環。因為套接字已經中斷，所以發送失敗，在調用write_partial函數的時候，返回b ==-1,導致退出循環，從而避免了拋出異常，因此返回-1，是非常合理的值

問題
1）? 客戶端沒有調用close接口，關閉連接，服務器端只有唯一的一次closesocket代碼，輸出的字符串是\x1，目前暫時不知道在什么地方關閉套接字
2）? 線程在空閑的時候是如何進行等待事件請求的
3）? pendingTaskCountMax_ 參數的具體含義是什么
4）isOpen函數其實只是確保了連接是否成功，如果連接成功之后，如果服務器斷開或者客戶端斷開連接，這個時候判斷isOpen函數的返回值是沒有任何的效果的，這個時候只能夠通過thrift自身的斷開連接的檢測機制，目前尚不了解會在什么時機釋放連接

其他的處理細節

1）繼承TServerEventHandler類，獲取連接用戶的基本信息包括IP和端口，從而監控是否保存有沒有清除的連接
TServerEventHandler類提供了用戶連接和斷開的時候，針對套接字的處理方式,其中提供了兩個函數
createContext 當一個新的用戶連接的時候會被調用
deleteContext 當用戶結束請求處理的時候會被調用
?
詳細的流程可以查看TThreadPoolServer::Task，Task作為TThreadPoolServer的內部類，在Task::run函數內部，當有連接進來的時候，會獲取TServerEventHandler類的對象，判斷是否有實例化，對連接進行處理，詳細的代碼??
boost::shared_ptr<TServerEventHandler>eventHandler =
?server_.getEventHandler();
??
void* connectionContext = NULL;
if (eventHandler != NULL)
{????
?connectionContext =eventHandler->createContext(input_, output_);
}
?