再帰的接続スレッドの作成

Question

クライアントとの接続が確立されるたびに新しい接続スレッドを作成します。しかし、2回目にクライアントスクリプトを実行すると、エラーが発生します。どのように来るのですか？

クライアント

from multiprocessing.connection import Client 
conn = Client(('localhost', 5555), authkey='secret_password') 
conn.send('Hello World!') 
conn.close() 

import time 
from multiprocessing.connection import Listener 
from threading import Thread 

_threads = [] 
_listener = Listener(('localhost', 5555), authkey='secret_password') 

def start_server_thread(): 
    global _threads 
    _threads.append(Thread(target=threaded_server)) 
    _threads[-1].daemon = True 
    _threads[-1].start() 

def threaded_server(): 
    conn = _listener.accept() 
    print str(conn.recv()) 
    conn.close() 
    _listener.close() 

if __name__ == "__main__": 
    start_server_thread() 
    while True: 
     time.sleep(1) 

エラー

Traceback (most recent call last): 
    File "C:\dev\spyker\t2.py", line 3, in <module> 
    conn = Client(('localhost', 5555), authkey='secret_password') 
    File "C:\Python26\lib\multiprocessing\connection.py", line 143, in Client 
    c = SocketClient(address) 
    File "C:\Python26\lib\multiprocessing\connection.py", line 263, in SocketClient 
    s.connect(address) 
    File "<string>", line 1, in connect 
socket.error: [Errno 10061] No connection could be made because the target machine actively refused it 

Answer 1

は、このサーバーのコードでいくつかの問題を抱えています。あなたはより多くの接続

import time 
from multiprocessing.connection import Listener 
from threading import Thread 

_threads = [] 

def start_server_thread(): 
    global _threads 
    _threads.append(Thread(target=threaded_server)) 
    _threads[-1].daemon = True 
    _threads[-1].start() 

def threaded_server(): 
    while True: 
     conn = _listener.accept() 
     print str(conn.recv()) 
     conn.close() 


if __name__ == "__main__": 
    _listener = Listener(('localhost', 5555), authkey='secret_password') 

    start_server_thread() 
    while True: 
     time.sleep(1) 

    _listener.close() 

免責のためにループアレント最初の接続

後にリスナーを閉じている

：私は、サーバーを書くための厄介な方法の一種であると思います。私はあなたの現在のコードの修正を投稿しているだけです:-)

ここでは、あなたの同じコードのややきれいなバージョンです。それでも100％理想的ではないが、私はクリーナーだと思う？

import time 
from multiprocessing.connection import Listener 
from threading import Thread 

class Server(Listener): 

    def __init__(self, *args, **kwargs): 
     super(Server, self).__init__(*args, **kwargs) 
     self._thread = None 
     self._stopping = False 


    def serve(self): 
     self._stopping = False 
     self._thread = Thread(target=self._serve) 
     self._thread.daemon = True 
     self._thread.start() 

    def _serve(self): 
     threads = [] 
     while not self._stopping: 
      conn = self.accept() 
      t = Thread(target=self.handleConnection, args=(conn,)) 
      t.start() 
      threads.append(t) 


    def stop(self): 
     if not self._stopping: 
      print "Stopping." 
      self._stopping = True 
      self._thread.join(3) 
      self.close() 

    def handleConnection(self, conn): 
     print str(conn.recv()) 
     conn.close()   


if __name__ == "__main__": 
    listener = Server(('localhost', 5555), authkey='secret_password') 
    listener.serve() 

    try: 
     while True: 
      time.sleep(1) 
    except KeyboardInterrupt, e: 
     listener.stop() 

Answer 2

いくつかのエラーが発見サーバー：

• threaded_serverに無限ループがあり、複数の接続を受け入れることをお勧めします。今は最初のものだけを受け入れています。
• 処理が終了した後にリスナーを終了しています。これはおそらくあなたが望むものではありません。同じリスナーを使用してさらに多くの接続を受け入れることができます。

正しいthreaded_server（）：

def threaded_server(): 
    while True: 
     conn = _listener.accept() 
     print str(conn.recv()) 
     conn.close() 

Answer 3

他の回答のアドバイスを使用して修正されたコード。修正された行には、

import time 
from multiprocessing.connection import Listener 
from threading import Thread 

_threads = [] 
_listener = Listener(('localhost', 5555), authkey='secret_password') 

def start_server_thread(): 
    global _threads 
    _threads.append(Thread(target=threaded_server)) 
    _threads[-1].daemon = True 
    _threads[-1].start() 

def threaded_server(): 
    conn = _listener.accept() 
    start_server_thread()   # <== each connection creates the next one 
    print str(conn.recv()) 
    conn.close() 
            # <== removed _listener.close() 
if __name__ == "__main__": 
    start_server_thread() 
    try:       # <== 
     while True: 
      time.sleep(1) 
    except KeyboardInterrupt, e: # <== catch ^c 
     _listener.close()   # <==