ファイアウォールスレッドのリスニングソケットを閉じる

Question

ネットワーク通信用のソケットについて学ぶときに問題があります。私は接続を聞き、クライアント接続のためのプロセスを作成する単純なスレッドを作ったが、私の問題はsocket.accept（）を取り消す方法を見つけられなかったのでスレッドを正しく結合できないことであるいつ私がプログラムを終了したい。

私のコードは次のようになります。

class ServerThread(threading.Thread): 

    def __init__(self, queue, host, port): 
     threading.Thread.__init__(self) 
     self.queue = queue 
     self.running = True 
     self.hostname = host 
     self.port = port 

    def run(self): 
     self.socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 
     self.socket.bind((self.hostname, self.port)) 
     self.socket.listen(1) 
     while self.running: 
      try: 
       conn, address = self.socket.accept() 
       process = Process(target=server_slave, args=(conn, address, self.queue)) 
       process.daemon = True 
       process.start() 
      except socket.timeout: 
       pass 

    def stop(self): 
     self.running = False 
     self.socket.close() 

私はself.setDaemon(True)を設定し、ちょうど偉大なガベージコレクタにすべてを手渡し、メインプログラムを終了することで閉じるようにプログラムを得るために管理している - それは悪い解決策のように思えます。私もソケットのタイムアウトを設定しようとしましたが、その結果は[Errno 35] Resource temporarily unavailableになります（実際のタイムアウトに関係なく、何年に設定しても...）。

私は間違っていますか？私はスレッドを愚かな方法で設計したのですか、接続を受け入れることについて何か忘れたことがありますか？

Answer 1

スレッドを閉じるための1つの方法は、ソケットへの接続を作成し、スレッドを完了させることです。

def stop(self): 
    self.running = False 
    socket.socket(socket.AF_INET, 
        socket.SOCK_STREAM).connect((self.hostname, self.port)) 
    self.socket.close() 

これは動作しますが、それは最適ではない可能性がありますように、それはまだ感じている...

Answer 2

ほとんどのケースでは、一度接続が受け入れられる新しいスレッドやプロセスを開きます。接続を閉じるには、whileループを解除します。ガベージコレクションはスレッドまたはプロセスを削除しますが、参加することで後で取り残されることはありません。

永続ソケットは、ユーザーが閉じたりタイムアウトすると閉じます。静的なWebページのような非永続的な情報は、情報を送信した後に終了します。

これは、Pythonの永続ソケットサーバの良い例です。マルチプロセッシングを使用しています。つまり、CPUに依存するタスクのために複数のコアで実行できます。より一般的にはマルチスレッドと呼ばれます。

import socket 
import multiprocessing 

def run(): 
    host = '000.000.000.000' 
    port = 1212 
    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 
    sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) 
    sock.bind(('', port)) 
    sock.listen(3) 
    while True: 
     p = multiprocessing.Process(target=worker, args=sock.accept()).start() 
def worker(conn, addr): 
    while True: 
     if data == '': 
      #remote connection closed 
      break 
     if len(dataList) > 2: 
      # do stuff 
      print 'This code is untested' 

run() 

Answer 3

部分的にテスト済みのソリューション

1. は右while
2. 前self.socket.settimeout(0.1)を入れて右accept