Gniazdo nasłuchiwania w wątku python

Question

Mam problem podczas próby poznania gniazd dla komunikacji sieciowej. Zrobiłem prosty wątek, który nasłuchuje połączeń i tworzy procesy do łączenia klientów. Mój problem polega jednak na tym, że nie mogę uzyskać prawidłowego przyłączenia się wątku, ponieważ nie znalazłem sposobu na anulowanie połączenia socket.accept() - wywołanie kiedy chcę opuścić program.

Mój kod wygląda następująco;

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() 

udało mi się dostać do zamknięcia programu przez ustawienie self.setDaemon(True) i po prostu wyjście z programu głównego, podając wszystko do wielkiej śmieciarza - ale to wydaje się być złym rozwiązaniem. Próbowałem również ustawić limit czasu dla gniazda, ale to powoduje uzyskanie [Errno 35] Resource temporarily unavailable (niezależnie od faktycznego limitu czasu, nawet gdy ustawiłem go na lata ...).

Co robię źle? Czy zaprojektowałem wątek głupio, czy też przeoczyłem coś o akceptowaniu połączeń?

Answer 1

Jednym ze sposobów na zamknięcie wątku wydaje się być nawiązanie połączenia z gniazdem, a tym samym kontynuowanie wątku do zakończenia.

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

To działa, ale nadal czuje się jak może nie być optymalna ...

Answer 2

W większości przypadków będzie otworzyć nowy wątek lub proces gdy połączenie jest akceptowana. Aby zamknąć połączenie, przerwij pętlę while. Wyrzucanie śmieci usunie wątek lub proces, ale dołączenie zapewni, że żaden nie zostanie pozostawiony.

Trwałe gniazda zamykają się, gdy użytkownik je zamknie lub upłynął limit czasu. Nietrwałe, podobnie jak statyczne strony internetowe, zostaną zamknięte po wysłaniu informacji.

Oto dobry przykład trwałego serwera gniazd w języku Python. Wykorzystuje proces wieloprocesowy, co oznacza, że ​​może działać w wielu rdzeniach dla zadań związanych z procesorem. Bardziej znany jako wielowątkowość.

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

Częściowo przetestowane rozwiązanie

1. Put self.socket.settimeout(0.1) tuż przed while
2. Put conn.settimeout(None) zaraz po accept