Pyro4 介绍，利用其实现进程间类方法的互相调用

client code

#!/usr/bin/python
# -*- coding: utf-8 -*-

import Pyro4
uri=raw_input(" Pyro uri : ").strip() //输入server端uri
name=raw_input("Your name: ").strip()
greeting_maker=Pyro4.Proxy(uri)        
print greeting_maker.get_fortune(name)

server code

#!/usr/bin/python
# -*- coding: utf-8 -*-

import Pyro4
class GreetingMaker(object):
    def get_fortune(self, name):
        return "Hello, {0}. \n" .format(name)
greeting_maker=GreetingMaker()
daemon=Pyro4.Daemon()                
uri=daemon.register(greeting_maker)   
print "Ready. Object uri =", uri      //此处的uri需要告知client
daemon.requestLoop()

#!/usr/bin/python
# coding:utf-8
import Pyro4

@Pyro4.expose #将此类暴露给client
class GreetingMaker(object):
    def __init__(self,name):
        print ‘this is %s‘ % name
    def get_fortune(self, name):
        return "Hello, {0}. Here is your fortune message:\n"                "Tomorrow‘s lucky number is 12345678.".format(name)

daemon = Pyro4.Daemon()                # make a Pyro daemon
ns = Pyro4.locateNS()                  # find the name server
uri = daemon.register(GreetingMaker(‘lyh‘))   # register the greeting maker as a Pyro object
ns.register("example.greeting", uri)   # register the object with a name in the name server

print("Ready.")
daemon.requestLoop()                   # start the event loop of the server to wait for calls

#!/usr/bin/python
# coding:utf-8
import Pyro4

name = input("What is your name? ").strip()

greeting_maker = Pyro4.Proxy("PYRONAME:example.greeting")    # use name server object lookup uri shortcut
print(greeting_maker.get_fortune(name))

#!/usr/bin/python
# -*- coding: utf-8 -*-

import Pyro4
import psutil
import subprocess
import traceback
import time
import threading
import multiprocessing
import os
import common_func

from awlib import atc_net_serial_com
from slave_logger import Logger


logger = Logger("RmiServer")

MAINCOM = [‘COM11‘, ‘COM21‘]
UARTCOM = [‘COM29‘, ‘COM28‘, ‘COM27‘, ‘COM26‘, ‘COM25‘, ‘COM24‘, ‘COM23‘, ‘COM22‘,
           ‘COM19‘, ‘COM18‘, ‘COM17‘, ‘COM16‘, ‘COM15‘, ‘COM14‘, ‘COM13‘, ‘COM12‘]


class RmiServer(multiprocessing.Process):
    """Remote classmethod call server
    @register net uart COM11 COM21
    @brocast port 9091, listen port 9090

    """

    def start(self):
        # start rmi nameserver
        net_ip = common_func.get_netcard()[0][1]
        exists_python_pids_before = common_func.get_pids_by_name(‘python‘)
        # broadcast method, all local area network pc can connect to it
        # pyro4_cmd = ‘python -m Pyro4.naming -n %s‘ % net_ip
        # start pyro4 server on localhost
        pyro4_cmd = ‘python -m Pyro4.naming‘
        # set Pyro4 server threadpool size unlimit
        Pyro4.config.SERVERTYPE="multiplex"
        p_pyro4 = subprocess.Popen(pyro4_cmd, shell=True)
        time.sleep(1)
        exists_python_pids_after = common_func.get_pids_by_name(‘python‘)
        self.kill_pids = []
        for pid_after in exists_python_pids_after:
            if pid_after not in exists_python_pids_before:
                self.kill_pids.append(pid_after)

        # self.pyro4_daemon = Pyro4.Daemon(host=net_ip)   # make a Pyro daemon
        self.pyro4_daemon = Pyro4.Daemon()
        try:
            # find the broadcast name server use specify ip
            # self.ns = Pyro4.locateNS(host=net_ip)
            # find the name server
            self.ns = Pyro4.locateNS()
        except:
            traceback.print_exc()
        else:
            logger.info(‘connect to RmiNameServer successfully‘)
        # register classmethod
        self._register_net_uart()
        # run rmiserver thread
        t_run = threading.Thread(target=self._run)
        t_run.setDaemon(True)
        t_run.start()

    def stop(self):
        try:
            self.pyro4_daemon.shutdown()
            self.pyro4_daemon.close()
            for kill_pid in self.kill_pids:
                os.kill(kill_pid, 9)
        except:
            pass

        logger.info(‘stop RmiServer successfully‘)

    def _run(self):
        self.pyro4_daemon.requestLoop()  # start the event loop of the server to wait for calls

    def _register(self, cls_md, cls_md_str):
        uri = self.pyro4_daemon.register(cls_md)
        self.ns.register(cls_md_str, uri)

    def _register_net_uart(self, wait_connect_time=6):
        logger.warn(‘********************Init MainCOM and DUT uart will take more time, please wait***********************‘)
        for maincom in MAINCOM:
            self._register(atc_net_serial_com.MainComCaller(maincom), maincom)
        time.sleep(wait_connect_time)
        logger.info(‘****************************************Init MainCOM and DUT uart OK!!!******************************‘)
if __name__ == ‘__main__‘:
    rmi_server = RmiServer()
    rmi_server.start()

# broadcast method, all local area network pc can connect to it
# pyro4_cmd = ‘python -m Pyro4.naming -n %s‘ % net_ip
# self.pyro4_daemon = Pyro4.Daemon(host=net_ip)   # make a Pyro daemon
# find the broadcast name server use specify ip
# self.ns = Pyro4.locateNS(host=net_ip)