Pythonマルチプロセス通信モジュールの簡単な実装

ほんの数例を挙げると、マルチプロセス通信には多くの方法があります。 Pythonでパッケージ化されたマルチプロセス通信モジュールmultiprocessing.connectionを試してみました。

簡単なテストを行ったところ、ソケットのカプセル化には問題がなく、多くのニーズを満たすことができます。

添付されたコードは次のとおりです:

クライアント

コードをコピー コードは次のとおりです:

#!/usr/bin/python
# -*-コーディング: utf -8 -*-
""" ダウンロード - スレーブ
"""
__author__ = 'Zagfai'
__license__ = 'MIT@2014-02'

multiprocessing.connection インポート クライアントからの webtul のインポート

a = 0
try:
while True:
a += 1
address = ('10.33.41.112', 6666)
conn = Client(address, authkey=' HelloKey ')
#print conn.Recv ()
D = conn.recv ()
conn.close ()
例外:
PASS

印刷

サーバー

コードをコピー コードは次のとおりです:

#!/usr/bin/python
# -* - コーディング: utf-8 -*-
""" ダウンローダー - マスターサーバー
"""
__author__ = 'Zagfai'
__license__ = 'MIT@2014-02'

import webtul
from multiprocessing.connection import Listener
from threading import Thread

deflistener():
address = ('10.33.41.112', 6666)
listener = Listener(address, backlog=100, authkey='hellokey')
True の場合:
conn =listener.accept()
#print '接続を受け入れました',listener.last_accepted
try:
conn.send({'1':2, '2':'abc' })
例外を除き、e:
print e
finally:
conn.close()
listener.close()

listener_th = Thread(target=listener)
listener_th.daemon = True
listener_th.start()
listener_th.join(timeout=20)