Python 다중 프로세스 통신 모듈

다중 프로세스 통신 방법에는 여러 가지가 있습니다. 방금 Python으로 패키지된 다중 프로세스 통신 모듈 multiprocessing.connection을 사용해 보았습니다.

간단한 테스트 결과 효율성은 괜찮습니다. 소켓 캡슐화여야 합니다. 효율성은 4krps에 도달할 수 있으며 이는 많은 요구 사항을 충족할 수 있습니다.

첨부된 코드는 다음과 같습니다.

클라이언트

#!/usr/bin/python
# -*- coding: utf-8 -*-
""" download - slave
"""
__author__ = 'Zagfai'
__license__ = 'MIT@2014-02'
  
import webtul
from multiprocessing.connection import Client
  
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()
except:
    pass
print a

서버

#!/usr/bin/python
# -*- coding: utf-8 -*-
""" downloader - master server
"""
__author__ = 'Zagfai'
__license__ = 'MIT@2014-02'
  
import webtul
from multiprocessing.connection import Listener
from threading import Thread
  
def listener():
    address = ('10.33.41.112', 6666)
    listener = Listener(address, backlog=100, authkey='hellokey')
    while True:
        conn = listener.accept()
        #print 'connection accepted from', listener.last_accepted
        try:
            conn.send({'1':2, '2':'abc'})
        except Exception, 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)