SimpleXMLRPC_Python聊天室II（SimpleXMLRPCServer模块实现）

并不是上一个用SocketServer的聊天室的延续。用远程调用完成的聊天室。

正好有Java的RMI聊天室的作业&＃xff0c;就先用Python写了一个简单的类似远程调用的东西&＃xff0c;逻辑完成之后&＃xff0c;在Java上写一遍也是水到渠成的事。

Python没有RMI&＃xff0c;但拥有一个SimpleXMLRPCServer模块。

原理和RMI类似&＃xff0c;不过省去了定义接口和生成stub的过程&＃xff0c;而且不仅支持调用远程对象&＃xff0c;更支持调用远程函数。

下面的代码都只调用了远程函数。这点和RMI必须通过远程对象调用方法不同。

说起啦&＃xff0c;Python算是个OO语言&＃xff0c;但不像Java那样完全的OO&＃xff0c;可以完全不用OO的方式来编写程序。

基本上下面的程序就是如此&＃xff0c;而且相对简洁&＃xff0c;同样的RMI下次贴上来&＃xff0c;代码量就多了很多&＃xff0c;而且注册&＃xff0c;接口等一系列事情&＃xff0c;很烦。

当然这个SimpleXMLRPCServer模块有个问题&＃xff1a;敢不敢快一点&＃xff01;&＃xff01;&＃xff01;&＃xff01;&＃xff01;基本上读端有大概1秒的延迟&＃xff0c;这个略显坑爹了。。

from SimpleXMLRPCServer import SimpleXMLRPCServer

# list to store the total message

ms&＃61;[]

# remote function

# each write client invoke this function to say something, and the message will be store in the ms list

def say(s):

ms.append(s)

# each read client invoke this function to get the latest message.

# args: message_no the total message number which this client has received.

def showMessage(message_no):

if message_no>&＃61;0:

mst&＃61;ms[message_no:] # always to get the latest message which client haven&＃39;t received.

return mst

# create the XMLRPCServer

svr&＃61;SimpleXMLRPCServer(("", 8080), allow_none&＃61;True)

# regisrer functions

svr.register_function(say)

svr.register_function(showMessage)

# run server

svr.serve_forever()

from xmlrpclib import ServerProxy

svr&＃61;ServerProxy("http://localhost:8080") #connect to server

while True: #loop to get input

s&＃61;raw_input("Zhu Di:")

svr.say(s) #Remote invoking the server&＃39;s function

from xmlrpclib import ServerProxy

# connect to server

svr&＃61;ServerProxy("http://localhost:8080")

# the message number which this client has recveied.

message_no&＃61;0

# remote invoking the function to show the latest message

while True:

ms&＃61;svr.showMessage(message_no)

if len(ms)>0:

for i in range(len(ms)):

print ms[i]

message_no&＃43;&＃61;len(ms)