Python 2.7 multiprocessing-не может передать объект сокета через словарь диспетчера
У меня есть простая программа, которая ищет открытые порты в локальной сети и сохраняет подключенные сокеты в словаре вместе с их локальным адресом. Теперь я использую общий словарь менеджера для хранения этих записей, но он принимает только простые объекты, а не экземпляры сокетов. Вот код:
from multiprocessing import Process, Manager
import socket
manager = Manager()
# Store connected sockets
sockets = manager.dict()
def ping_addr(addr=None, port=None, timeout=None):
"""
Create a socket and try to establish a connection to a specific address. If a connection is established, append
the socket to the sockets dictionary.
:param addr: The address.
:param port: The port number.
:param timeout: How many seconds to wait until its decided that the connection has been refused.
:return: None
"""
global sockets
# Setup the client socket
csocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
csocket.settimeout(timeout)
# Try to connect
try:
csocket.connect((addr, port))
print 'connected to {}:{}'.format(addr, port)
# This works
sockets.update({addr: 0})
# This doesnt work
sockets.update({addr: csocket})
except socket.error:
pass
for i in range(256):
proc = Process(target=ping_addr, kwargs={'addr': '192.168.1.{}'.format(i), 'port': 14540, 'timeout': 0.5})
proc.start()
Ошибка, которую я получаю:
Process Process-4:
Traceback (most recent call last):
File "/usr/lib/python2.7/multiprocessing/process.py", line 258, in _bootstrap
self.run()
File "/usr/lib/python2.7/multiprocessing/process.py", line 114, in run
self._target(*self._args, **self._kwargs)
File "/home/alex/PycharmProjects/proj/test.py", line 29, in ping_addr
sockets.update({addr: csocket})
File "<string>", line 2, in update
File "/usr/lib/python2.7/multiprocessing/managers.py", line 758, in _callmethod
conn.send((self._id, methodname, args, kwds))
TypeError: expected string or Unicode object, NoneType found
Я провел небольшое исследование о прокси, но не смог найти способ реализовать их в своем коде, поэтому я прошу помощи. Как я могу сделать экземпляры сокетов, совместимые со словарем диспетчера?
2 ответов:
Передача сокета от родительского к дочернему процессу является очень распространенной практикой. начиная с python3. 4, Вы можете поделиться объектом сокета напрямую через
multiprocessing.Manager, но в python2. 7, Вы должны подключить его самостоятельно(Смотрите полную суть здесь):import socket import copy_reg from multiprocessing.reduction import rebuild_socket, reduce_socket copy_reg.pickle(socket.socket, reduce_socket, rebuild_socket)
Сокеты
Не могут быть переданы другому процессу через Диспетчер.словарь. Каждый сокет python имеет сокет на уровне операционной системы. ОС знает привязку между сокетом и процессом и поддерживает владение сокетом. Сокет можно использовать только в процессе, который его создал. Или он может быть использован в дочернем процессе в unix-подобной системе.
Смотрите также передача объекта Python другому процессу Python
Comments