Python的XMLRPC机制：实现跨进程间、client/server端通信

#-*- coding: UTF-8 -*-import wx
import threading
import sys
from SimpleXMLRPCServer import SimpleXMLRPCServerclass XMLRPCServerThread(threading.Thread):def __init__(self, remoteServiceInstance, host&＃61;&＃39;127.0.0.1&＃39;, port&＃61;1234):self._RemoteServiceInstance &＃61; remoteServiceInstanceself._Host &＃61; hostself._Port &＃61; portthreading.Thread.__init__(self)def stop(self):self._Server.shutdown() def run(self):self._Server &＃61; SimpleXMLRPCServer( (self._Host, self._Port), logRequests&＃61;False, allow_none &＃61; True )self._Server.register_instance( self._RemoteServiceInstance )self._Server.serve_forever()class MyRemoteService(object):def __init__(self, obj):self.obj &＃61; objdef Add(self, a, b):return a &＃43; bdef NoReturn(self):print &＃39;xxxx&＃39;def Empty(self):return u&＃39;中国 .&＃39;class MyFrame(wx.Frame):def __init__(self, parent):wx.Frame.__init__(self, parent, -1, "Server service")mainPanel &＃61; wx.Panel(self, size &＃61; (300, 400))mainPanel.SetBackgroundColour(wx.Colour(0,122,200))sizer &＃61; wx.BoxSizer(wx.VERTICAL)sizer.Add(mainPanel, 1, wx.EXPAND)self.SetSizerAndFit(sizer)## &＃64;detail ShellApp主应用程序的核
class ShellApp(wx.App):def OnInit(self):mainFrame &＃61; MyFrame(None)self.Bind(wx.EVT_END_PROCESS, self.OnProcessEnded)self.__ServerThread &＃61; self.__GetRPCThread()self.__ChildProcess &＃61; wx.Process(self)pid &＃61; wx.Execute(&＃39;python remoteClient.py&＃39;, wx.EXEC_NOHIDE|wx.EXEC_ASYNC, self.__ChildProcess) mainFrame.Show(True) return Truedef __GetRPCThread(self, host&＃61;&＃39;localhost&＃39;, port&＃61;1234):remoteObj &＃61; MyRemoteService(self)rpcThread &＃61; XMLRPCServerThread(remoteObj, host, port)rpcThread.start()return rpcThreaddef OnProcessEnded(self, evt):print &＃39;Child process exist&＃39;self.__ChildProcess.Destroy()self.__ServerThread.stop()self.Exit()# &＃64;detail main程序的主入口程序
if __name__ &＃61;&＃61; &＃39;__main__&＃39;: app &＃61; ShellApp()#重新定向wxpython的输出输入和错误输出到系统标准输入输出sys.stdin &＃61; sys.__stdin__sys.stdout &＃61; sys.__stdout__sys.stderr &＃61; sys.__stderr__app.MainLoop()

#-*- coding: UTF-8 -*-
import wx
import sys
import xmlrpclib #客户端from SimpleXMLRPCServer import SimpleXMLRPCServerclass MyFrame(wx.Frame):def __init__(self, parent):wx.Frame.__init__(self, parent, -1, "Client app")mainPanel &＃61; wx.Panel(self, size &＃61; (300, 200))addButton &＃61; wx.Button(mainPanel, -1, &＃39;Add&＃39;)addButton.Bind(wx.EVT_BUTTON, self.__OnAddClicked)self._AText &＃61; wx.TextCtrl(mainPanel, -1, &＃39;10&＃39;)self._AddText &＃61; wx.StaticText(mainPanel, -1, &＃39; &＃43; &＃39;)self._BText &＃61; wx.TextCtrl(mainPanel, -1, &＃39;23&＃39;)self._Label &＃61; wx.StaticText(self, -1, &＃39; &＃61; &＃39;)self._SumText &＃61; wx.TextCtrl(mainPanel)panelSizer &＃61; wx.BoxSizer(wx.HORIZONTAL)panelSizer.Add(addButton, 0, wx.ALL, 6) panelSizer.Add(self._AText, 0, wx.ALL, 6)panelSizer.Add(self._AddText, 0, wx.ALL, 6)panelSizer.Add(self._BText, 0, wx.ALL, 6)panelSizer.Add(self._Label, 0, wx.ALL, 6)panelSizer.Add(self._SumText, 0, wx.ALL, 6)mainPanel.SetSizer(panelSizer)mainPanel.SetBackgroundColour(wx.Colour(122,12,20))sizer &＃61; wx.BoxSizer(wx.VERTICAL)sizer.Add(mainPanel, 1, wx.EXPAND)self.SetSizerAndFit(sizer)self._Proxy &＃61; xmlrpclib.ServerProxy(&＃39;http://127.0.0.1:1234&＃39;) def __OnAddClicked(self, evt):a &＃61; int(self._AText.GetLabel())b &＃61; int(self._BText.GetLabel())sum &＃61; self._Proxy.Add(a, b)self._SumText.SetLabel(&＃39;%s&＃39;%sum)self._Proxy.NoReturn()## &＃64;detail ShellApp主应用程序的核
class ShellApp(wx.App): def OnInit(self):mainFrame &＃61; MyFrame(None)mainFrame.Show(True) return True# &＃64;detail main程序的主入口程序
if __name__ &＃61;&＃61; &＃39;__main__&＃39;: app &＃61; ShellApp()#重新定向wxpython的输出输入和错误输出到系统标准输入输出sys.stdin &＃61; sys.__stdin__sys.stdout &＃61; sys.__stdout__sys.stderr &＃61; sys.__stderr__app.MainLoop()