test36.py

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

'处理分布式进程发送的数据'

__author__ = 'sergiojune'
from multiprocessing.managers import BaseManager
import time, queue


class QueueManager(BaseManager):
 pass


# 注册到网络上
QueueManager.register('post_task_queue') # 由于只是从网络上获取queue，所以不需要写callable方法
QueueManager.register('result_task_queue')
# 连接到网络
address = '127.0.0.1' # 这个是网络地址
manager = QueueManager(address=(address, 500), authkey=b'abc') # 这些必须与发送的一致，要不会连不上
# 连接
manager.connect()
# 获取queue
post = manager.post_task_queue()
result = manager.result_task_queue()

# 处理数据
print('tyr get value')
for x in range(10):
 try:
 v = post.get(timeout=10)
 print('get value %d' % v)
 r = v*v
 print('put value %d to result' % r)
 time.sleep(1)
 result.put(r)
 except queue.Empty as e:
 print('Queue is empty')
print('work exit')