按照@三尺蛮腰 的改了，可是master和worker的链接出现问题，我两个都是在本机上跑的

Discuss / Python / 按照@三尺蛮腰的改了，可是master和worker的链接出现问题，我两个都是在本机上跑的

Back

按照@三尺蛮腰的改了，可是master和worker的链接出现问题，我两个都是在本机上跑的

Topic source

木可堂主爱早起

#1 Created at ... [Delete] [Delete and Lock User]

#!/usr/bin/env python3
# -*- coding: utf-8 -*-

# task_master.py

import random, time, queue
from multiprocessing.managers import BaseManager
from multiprocessing import freeze_support

# 发送任务的队列:
task_queue = queue.Queue
# 接收结果的队列:
result_queue = queue.Queue

# 从BaseManager继承的QueueManager:
class QueueManager(BaseManager):
    pass
def test():
    # 把两个Queue都注册到网络上, callable参数关联了Queue对象:
    QueueManager.register('get_task_queue', callable=task_queue)
    QueueManager.register('get_result_queue', callable=result_queue)
    # 绑定端口5000, 设置验证码'abc':
    manager = QueueManager(address=('172.24.28.56', 5000), authkey=b'abc')
    # 启动Queue:
    manager.start()
    # 获得通过网络访问的Queue对象:
    task = manager.get_task_queue()
    result = manager.get_result_queue()
    # 放几个任务进去:
    for i in range(10):
        n = random.randint(0, 10000)
        print('Put task %d...' % n)
        task.put(n)
    # 从result队列读取结果:
    print('Try get results...')
    for i in range(10):
        r = result.get(timeout=10)
        print('Result: %s' % r)
    # 关闭:
    manager.shutdown()
    print('master exit.')

if __name__ == '__main__':
    freeze_support()
    test()

worker没改动，结果是这样

master界面：

D:\programlearnning\Python\code>python task_master.py
Put task 4175...
Put task 651...
Put task 65...
Put task 2521...
Put task 151...
Put task 4023...
Put task 6037...
Put task 1923...
Put task 89...
Put task 3667...
Try get results...
Traceback (most recent call last):
  File "task_master.py", line 45, in <module>
    test()
  File "task_master.py", line 37, in test
    r = result.get(timeout=10)
  File "<string>", line 2, in get
  File "C:\Python34\lib\multiprocessing\managers.py", line 747, in _callmethod
    raise convert_to_error(kind, result)
queue.Empty

worker界面：

D:\programlearnning\Python\code>python task_worker.py
Connect to server 172.24.28.56...
task queue is empty.
task queue is empty.
task queue is empty.
task queue is empty.
task queue is empty.
task queue is empty.
Traceback (most recent call last):
  File "task_worker.py", line 30, in <module>
    n = task.get(timeout=1)
  File "<string>", line 2, in get
  File "C:\Python34\lib\multiprocessing\managers.py", line 732, in _callmethod
    kind, result = conn.recv()
  File "C:\Python34\lib\multiprocessing\connection.py", line 250, in recv
    buf = self._recv_bytes()
  File "C:\Python34\lib\multiprocessing\connection.py", line 416, in _recv_bytes
    buf = self._recv(4)
  File "C:\Python34\lib\multiprocessing\connection.py", line 383, in _recv
    chunk = read(handle, remaining)
ConnectionResetError: [WinError 10054] 远程主机强迫关闭了一个现有的连接。