Come creare un semplice server socket multithread in Python che ricordi i client

Question

Come posso creare un semplice server echo Python che ricordi i client e non crei un nuovo socket per ogni richiesta? Deve essere in grado di supportare l'accesso simultaneo. Voglio essere in grado di connettermi una volta e inviare e ricevere continuamente dati utilizzando questo client o simili:

import socket 

sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 
host = raw_input("Server hostname or ip? ") 
port = input("Server port? ") 
sock.connect((host,port)) 
while True: 
    data = raw_input("message: ") 
    sock.send(data) 
    print "response: ", sock.recv(1024) 

I.e. con il server in esecuzione sulla porta 50000, utilizzando il client di cui sopra che voglio essere in grado di fare questo:

me@mine:~$ client.py 
Server hostname or ip? localhost 
Server Port? 50000 
message: testa 
response: testa 
message: testb 
response: testb 
message: testc 
response: testc 

Answer 1

È possibile utilizzare un thread per ogni cliente di evitare il blocco client.recv() quindi utilizzare il thread principale solo per l'ascolto per il nuovo clienti. Quando ci si connette, il thread principale crea un nuovo thread che ascolta solo il nuovo client e termina quando non parla per 60 secondi.

import socket 
import threading 

class ThreadedServer(object): 
    def __init__(self, host, port): 
     self.host = host 
     self.port = port 
     self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 
     self.sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) 
     self.sock.bind((self.host, self.port)) 

    def listen(self): 
     self.sock.listen(5) 
     while True: 
      client, address = self.sock.accept() 
      client.settimeout(60) 
      threading.Thread(target = self.listenToClient,args = (client,address)).start() 

    def listenToClient(self, client, address): 
     size = 1024 
     while True: 
      try: 
       data = client.recv(size) 
       if data: 
        # Set the response to echo back the recieved data 
        response = data 
        client.send(response) 
       else: 
        raise error('Client disconnected') 
      except: 
       client.close() 
       return False 

if __name__ == "__main__": 
    while True: 
     port_num = input("Port? ") 
     try: 
      port_num = int(port_num) 
      break 
     except ValueError: 
      pass 

    ThreadedServer('',port_num).listen() 

I client scadono dopo 60 secondi di inattività e devono riconnettersi. Vedere la riga client.settimeout(60) nella funzione ThreadedServer.listen()