Python non-blocking XML-RPC

b_xmlrpc_server.py

#!/usr/bin/env python
#coding=utf8
"""
====================================
:mod: 테스트용 blocking XML-RPC 서버
====================================
.. moduleauthor:: 채문창 <mcchae@gmail.com>
.. note:: GNU

설명
=====

테스트용 blocking XML-RPC 서버
"""

##########################################################################################
import time
from SimpleXMLRPCServer import SimpleXMLRPCServer, SimpleXMLRPCRequestHandler

##########################################################################################
class TestSvc(object):
	def ping(self, pid, _sleep=0):
		for i in xrange(_sleep):
			print "[%d] %d" % (pid, i)
			time.sleep(1)
		return True

##########################################################################################
def doSvc():
	mgr = TestSvc()
	class RequestHandler(SimpleXMLRPCRequestHandler):
		rpc_paths = ('/TestSvc')
	server = SimpleXMLRPCServer(('0.0.0.0', 9000),
	                            requestHandler=RequestHandler,
	                            logRequests=False,
	                            allow_none=True,
	)
	server.register_introspection_functions()
	server.register_instance(mgr)
	server.serve_forever()

##########################################################################################
if __name__=='__main__':
	doSvc()

n_xmlrpc_server.py

#!/usr/bin/env python
#coding=utf8
"""
====================================
:mod: 테스트용 non-blocking XML-RPC 서버
====================================
.. moduleauthor:: 채문창 <mcchae@gmail.com>
.. note:: GNU

설명
=====

테스트용 non-blocking XML-RPC 서버
"""

##########################################################################################
import time
from SimpleXMLRPCServer import SimpleXMLRPCServer, SimpleXMLRPCRequestHandler

##########################################################################################
class TestSvc(object):
	def ping(self, pid, _sleep=0):
		for i in xrange(_sleep):
			print "[%d] %d" % (pid, i)
			time.sleep(1)
		return True

##########################################################################################
def doSvc():

	mgr = TestSvc()
	from SocketServer import ThreadingMixIn
	class SimpleThreadXMLRPCServer(ThreadingMixIn, SimpleXMLRPCServer):
		pass
	class RequestHandler(SimpleXMLRPCRequestHandler):
		rpc_paths = ('/TestSvc')
	server = SimpleThreadXMLRPCServer(('0.0.0.0', 9000),
			                            requestHandler=RequestHandler,
			                            logRequests=False,
			                            allow_none=True,
	)
	server.register_introspection_functions()
	server.register_instance(mgr)
	server.serve_forever()

##########################################################################################
if __name__=='__main__':
	doSvc()

xmlrpc_client.py

#!/usr/bin/env python
#coding=utf8
import os
import xmlrpclib
proxy = xmlrpclib.ServerProxy("http://localhost:9000/TestSvc")
print "[%d] TestSvc.ping(5)=%s" % (os.getpid(), proxy.ping(os.getpid(), 5))

xmlrpc_client.sh

#!/bin/bash

python xmlrpc_client.py &
python xmlrpc_client.py &
python xmlrpc_client.py &
python xmlrpc_client.py &
python xmlrpc_client.py &

FAIL=0
sleep 2
for job in `jobs -p`; do
	wait $job || let "FAIL+=1"
done

if [ "$FAIL" == "0" ]; then
	echo "Done!"
else
	echo "FAIL! ($FAIL)"
fi

I don't know why or how but it works like a charm!