SocketServer ThreadingTCPServer＆Asyncore Dispatcher

Question

我想爲使用SocketServer模塊的服務器的請求處理程序中的單個連接添加超時。

讓我先說這是我第一次嘗試使用Python進行網絡編程。我已經對SocketServer.BaseRequestHandler和SocketServer.ThreadingTCPServer分別進行了分類，並且設法使用一些基本的線程化TCP功能創建兩個類。

但是，我想我的傳入連接超時。嘗試覆蓋任何內置的SocketServer超時值和方法不起作用，因爲文檔說這隻適用於分叉服務器。我設法創建了一個在X秒後觸發的計時器線程，但由於處理程序線程中的阻塞recv調用的性質，這是沒有用的，因爲我將被迫殺死它，這是我真正的東西想避免。

因此，我的理解是，我需要一個asyncore實現，在那裏獲得通知並讀取一定數量的數據。如果在5秒內沒有發送任何數據，可以說，我想關閉該連接（我知道如何幹淨地做到這一點）。 我發現了一些使用socket的asyncore的例子，但是沒有一個使用SocketServer。那麼，我怎樣才能實現asyncore & threadingTCPserver？ 這可能嗎？ 有沒有人做過？

Answer 1

您還可以設置一個超時的recv調用，就像這樣：

sock.settimeout(1.0) 

由於您使用SocketServer，你必須找到在某處SocketServer底層socket。請注意，SocketServer將爲您創建套接字，因此您無需自行完成該套接字。

您可能已將RequestHandler定義爲與SocketServer一起使用。它應該是這個樣子：

class RequestHandler(SocketServer.BaseRequestHandler): 
    def setup(self): 
     # the socket is called request in the request handler 
     self.request.settimeout(1.0) 

    def handle(self): 
     while True: 
      try: 
       data = self.request.recv(1024) 
       if not data: 
         break # connection is closed 
       else: 
         pass # do your thing 
      except socket.timeout: 
       pass # handle timeout