многопроцессорное отключение слушателя Python - PullRequest
Новая
       18

многопроцессорное отключение слушателя Python

0 голосов
/ 26 октября 2018

Я пытаюсь создать прослушиватель, подключить клиентов и через некоторое время принудительно закрыть сокет и разорвать соединение.Я не могу закрыть соединение, даже пытаясь закрыть саму розетку.Я не уверен, что я делаю неправильно.Мой код имеет код на стороне сервера и код на стороне клиента (2 разных терминала)

сервер 

from multiprocessing.connection import Listener
import threading, socket


def start_thread(name,  target,  args=(),  kwargs={},  daemon=True):
    thread = threading.Thread(name=name,  target=target, args=args,  kwargs=kwargs)
    thread.daemon = daemon
    thread.start()
    return thread


# client
received = []
def child(conn):
    while True:
        msg = conn.recv()
        received.append(msg)
        # this just echos the value back, replace with your custom logic
        #import time
        #time.sleep(5)
        conn.send(msg)

# server
serv = Listener(('', 5000), authkey='mypassword')
def mother(serv):
    while True:
        client = serv.accept()
        print(client, type(client))
        t = start_thread('child', child, kwargs={'conn':client})
        print(t)

start_thread('mother',mother, (serv,))

Клиент 

from multiprocessing.connection import Client

c = Client(('localhost', 5000), authkey='mypassword')

c.send('hello');print( c.recv())

c.send({'a': 123}); print('i am back', c.recv())

Теперь на стороне серверабез закрытия терминала или выхода из python, я хотел бы остановить слушателя и закрыть сокет.при попытке выполнить все следующие действия (отдельно в разных средах выполнения) ничего не получилось, и соединение все еще было открыто 

1 - serv.close()
2 - serv._listener.close()
3 - serv._listener._socket.close()

# Shutdown the socket always returns an error
4 - socket.socket.shutdown(serv._listener._socket, 2)
Traceback (most recent call last):
  File "<stdin>", line 1, in <module>
  File "/usr/local/Cellar/python/2.7.12_2/Frameworks/Python.framework/Versions/2.7/lib/python2.7/socket.py", line 228, in meth
    return getattr(self._sock,name)(*args)
  File "/usr/local/Cellar/python/2.7.12_2/Frameworks/Python.framework/Versions/2.7/lib/python2.7/socket.py", line 174, in _dummy
    raise error(EBADF, 'Bad file descriptor')
socket.error: [Errno 9] Bad file descriptor


5 - serv._listener._socket.shutdown(2)
Traceback (most recent call last):
  File "<stdin>", line 1, in <module>
  File "/usr/local/Cellar/python/2.7.12_2/Frameworks/Python.framework/Versions/2.7/lib/python2.7/socket.py", line 228, in meth
    return getattr(self._sock,name)(*args)
  File "/usr/local/Cellar/python/2.7.12_2/Frameworks/Python.framework/Versions/2.7/lib/python2.7/socket.py", line 174, in _dummy
    raise error(EBADF, 'Bad file descriptor')
socket.error: [Errno 9] Bad file descriptor

1 Ответ

0 голосов
/ 27 октября 2018

Это socket относительная проблема.

Короче говоря, вы не можете shutdown после close, потому что close уничтожит сокет (дескриптор файла).

Подробности в этом и этом .

...