ezrpc 0.1.0

步骤1

创建服务器

# server.py
from ezrpc import Server

# By default, the server binds to all available interfaces
s = Server(server_port=5000, client_port=5001)
s.start()

运行以下命令

python server.py

步骤2

创建工作进程

# worker.py
from ezrpc import Registry, ServerWorker
registry = Registry()

@registry.method
def add(a, b):
        return a + b

@registry.method
def multiply(a, b):
        return a * b

# Point the worker to the Server's IP
w = ServerWorker(sys.argv[1], registry, "tcp://127.0.0.1:5000")
w.run()

根据服务器处理能力运行尽可能多的工作进程

python worker.py worker1
python worker.py worker2
python worker.py worker3

工作进程是弹性的，即您可以随意启动和停止它们，客户端将继续提供服务。

步骤3

创建客户端

# client.py
from ezrpc import Client

# Point the client to the Server's IP
# timeout (millis) is optional, default is 5 seconds
c = Client('tcp://127.0.0.1:5001', timeout=1000)

for i in range(1,11):
        res = c.ask('add', i, 1)
        print 'Response: %s' % res

c._disconnect()

运行客户端

python client.py