openstack：RPC消息通信示例

包括服务端和客户端：

1. RPC服务端：

Server.py：

#server.py server point

from oslo.config import cfg
from oslo import messaging

class ServerControlEndpoint(object):
	target = messaging.Target(namespace="control", version="2.0")
	
	def __init__(self, server):
		self.server = server
		
	def stop(self, ctx):
		if self.server:
			print("### I AM HERE @stop a")
			self.server.stop()
		print("### I AM HERE @ stop b")
		

class TestEndpoint(object):
	def test(self, ctx, arg):
		print("### I AM HERE @ test，arg:%s" %arg)
		return arg


transport = messaging.get_transport(cfg.CONF)
target = messaging.Target(topic="test", server="server1")
endpoints = [
	ServerControlEndpoint(None),
	TestEndpoint(),
]

server = messaging.get_rpc_server(transport, target, endpoints, executor="blocking")

server.start()
server.wait()#server.py serve