Объяснение

Я создаю сервер архитектуры-мультиклиентный с сокетами в python3.

Для этого я использую многопроцессорную библиотеку. Следующий код создает сервер, прослушивающий подключения клиентов:

 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) sock.bind(("",PORT)) sock.listen(CLIENTS) print(logFile().message(f"running ClassAdmin server, listen {CLIENTS} clients by port {PORT}...",True,"INFO")) sockSSL = context.wrap_socket(sock,server_side=True) while sockSSL:  connection, address = sockSSL.accept()  eventChildStop = multiprocessing.Event()  subprocess = multiprocessing.Process(target=ClientListener, name="client", args=(connection, address))  subprocess.start()  

В приведенном выше коде каждый клиент выполняется в дочернем процессе. С multiprocessing.Process()

Это запускает класс ClientListener .

 class ClientListener:  def __init__(self,conn,addr):  try:  self.conn, self.addr = conn, addr  self.nick = ""  self.__listenData()  except (KeyboardInterrupt,SystemExit) as err:  print(logFile().message(f"The host {self.nick} ({self.addr[0]}:{self.addr[1]}) left", True, "INFO"))  except BaseException as err:  type, object, traceback = sys.exc_info()  file = traceback.tb_frame.f_code.co_filename  line = traceback.tb_lineno  print(logFile().message(f"{err} in {file}:{line}", True, "ERROR"))  finally:  try:  ListClients().remove(self.conn)  self.conn.close()  except:  None  finally:  Client(self.conn,self.addr).registre(self.nick,"DISCONNECTED",False)  def __listenData(self):  while True:  data = self.conn.recv(1024)  text = data.decode('utf-8')  if text.startswith("sig."):  exec(f"raise {text.split('.')[1]}")  elif data:  if text.startswith("HelloServer: "):  self.nick = text.replace("HelloServer: ","")  client = Client(self.conn,self.addr).registre(self.nick, "CONNECTED", False)  if client==False:  self.conn.send(b"sig.SystemExit(-5000,'The nick exists and is connected',True)")  else:  print(logFile().message(f"The host {self.nick} ({self.addr[0]}:{self.addr[1]}) is connected", True, "INFO"))  ListClients().add(self.conn)  else:  print(data)  

При __init__() запуске метода __listenData() , этот метод отвечает за работу с данными, отправленными клиентом на сервер.

В разделе __init__() я работаю с исключениями для отображения информации при закрытии клиента.

 try:  #{...} finally:  try:  ListClients().remove(self.conn)  self.conn.close()  except:  None  finally:   Client(self.conn,self.addr).registre(self.nick,"DISCONNECTED",False)  #HERE, Can I close the current child process?  

In this try executes a finally , because always will delete the client of clients list, and if there is a connection will close it.

The problem

My problem is the follow:

1. I run the server….
2. In the client machine, I run the client….

   When I had connected the client at server, in the server process had created a child process.

3. Now the client closed, so in the server, if we show the child process his status changed to Z, is means, Zombie

My question, is…

How to close this child process? As the client is running in a child process started by multiprocessing.Process() . I must be close it with the method terminate() of multiprocessing … I think that is this the solution.

Solution possible?

I thought in…

1. Add other child process listening a multiprocessing.Event() in the root:

 while sockSSL:  connection, address = sockSSL.accept()  eventChildStop = multiprocessing.Event()  subprocess = multiprocessing.Process(target=ClientListener, name="client", args=(connection, address,eventChildStop))  subprocess.start()  multiprocessing.Process(target=ClientListener.exitSubprocess, name="exitChildProcess",args=(eventChildStop, subprocess)).start()  time.sleep(1)  

2. In the class listenerClients I add the argument event in __init__() :

 class ClientListener:  def __init__(self,conn,addr,event):  

3. I add the static method exitSubprocess() . This method in teory terminate the child process (this is not so):

 @staticmethod  def exitSubprocess(event,process):  while True:  if event.is_set():  print(process.id)  process.terminate()  break  time.sleep(.5)  

But, this is not so, the result is same. The childs process (one is the method static exitSubprocess . the first is the client process) are status Zombie . Why…?

Somebody understand what is happening?

I appreciate someone response. Thank you by your attention.

Решение

Привет!! Проблема была решена!!

Как мне это решить?

Я это сделал, после запуска дочернего процесса клиента запустите поток в родительском процессе, чтобы, когда дочерний процесс перейдет к выходу, перед выходом поток присоединится к дочернему процессу с родительским процессом, и поток завершится успешно. Наконец, дочерний процесс клиента завершается.

шаги, которые необходимо выполнить

во — первых, в корневой код сервера добавлен:

 # This thread is responsible of close the client's child process threading.Thread(target=ClientListener.exitSubprocess,name="closeChildProcess",args=(eventChildStop,subprocess,)).start()  

результат завершен:

 while sockSSL:  connection, address = sockSSL.accept()  eventChildStop = multiprocessing.Event()  subprocess = multiprocessing.Process(target=ClientListener, name="client", args=(connection, address,eventChildStop))   # This thread is responsible of close the client's child process  threading.Thread(target=ClientListener.exitSubprocess,name="closeChildProcess",args=(eventChildStop,subprocess,)).start()  subprocess.start()  time.sleep(1)  

После того, как в новом exitSubprocess методе я изменил:

 if event.is_set():  print(process.id)  process.terminate()  break  

Автор:

 if event.is_set():  process.join()  break  

результат завершен:

 # This method get as argument the process child. For join it at parent process @staticmethod def exitSubprocess(event,process):  while True:  if event.is_set():  process.join()  break  time.sleep(.5)  

Важно, что в дочернем процессе клиента в его последнем finally добавлении time.sleep(1) 1 секунда. Для предоставления времени в потоке для присоединения дочернего процесса клиента к родительскому процессу

 class ClientListener: def __init__(self,conn,addr,event):  try:  self.conn, self.addr = conn, addr  self.nick = ""  self.__listenData()  except (KeyboardInterrupt,SystemExit) as err:  print(logFile().message(f"The host {self.nick} ({self.addr[0]}:{self.addr[1]}) left", True, "INFO"))  except BaseException as err:  type, object, traceback = sys.exc_info()  file = traceback.tb_frame.f_code.co_filename  line = traceback.tb_lineno  print(logFile().message(f"{err} in {file}:{line}", True, "ERROR"))  finally:  try:  ListClients().remove(self.conn)  self.conn.close()  except:  None  finally:  Client(self.conn,self.addr).registre(self.nick,"DISCONNECTED",False)  event.set()  # This will delay 1 second to close the proccess, for this gives time at exitSubprocess method to join the client's child process with the parent process  time.sleep(1)  

Большое вам спасибо за ваше внимание и время.