recall

Python High performance RPC framework based on protobuf

Example

Suppose you want to write an Hello RPC service by recall, then you will define the following protocol:

// hello.proto

option py_generic_services = true; // This is required
message HelloRequest {
  string data;
}

message HelloResponse {
  string data;
}

service HelloService {
  rpc HelloMethod (HelloRequest) returns (HelloResponse);
}

Then compile the proto file:

$ protoc --python_out=. hello.proto

Then you can write your Hello service server like the following:

import hello_pb2
from recall.server import RpcServer

class HelloServiceImpl(hello_pb2.HelloService):
    def HelloMethod(self, rpc_controller, request, done):
        print 'recv', request.data
        return hello_pb2.HelloResponse(data='world')

if __name__ == '__main__':
    addr = ('0.0.0.0', 12345)
    print 'server listen at %s' % str(addr)
    server = RpcServer(addr)
    server.register_service(HelloServiceImpl())
    server.run(print_stat_interval=60)

And to access Hello service, you can simply use RpcClient like the following:

import hello_pb2
from recall.controller import RpcController
import recall.client

if __name__ == '__main__':
    client = recall.client.RpcClient()
    channel = client.get_tcp_channel(('127.0.0.1', 12345))
    stub = hello_pb2.HelloService_Stub(channel)

    req = hello_pb2.HelloRequest(data='hello')
    controller = RpcController()
    rsp = stub.HelloMethod(controller, req, None)
    print 'recv', rsp.data

Installation

You can install recall by simply using pip:

$ pip install recall

Or you can install recall by github source code:

$ git clone https://github.com/airekans/recall.git
$ cd recall
$ sudo python setup.py install