Skip to content
This repository has been archived by the owner on Sep 24, 2020. It is now read-only.
/ torpc Public archive

A tiny async tcp and duplex rpc implementation using Tornado IOLoop.

License

Notifications You must be signed in to change notification settings

yoki123/torpc

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

50 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

ToRPC

ToRPC(Tornado + RPC) 是一个的基于Tornado IOLoop的异步TCP和双向通信的RPC的Python实现。ToRPC非常轻量级,性能优秀(尤其是在PyPy环境下)。

torpc-gevent是另一个用Gevent实现的版本:https://github.com/yoki123/torpc-gevent

提醒:目前为止,ToRPC只在CPython 2.7+PyPy 2.5+上测试过,不要在产品中使用,现在还不稳定。

示例

RPC 服务器

from tornado import ioloop
from torpc import RPCServer
server = RPCServer(('127.0.0.1', 5000))

@server.service.register()
def echo(x):
    return x

server.start()
ioloop.IOLoop.instance().start()

RPC 客户端

from tornado import ioloop, gen
from torpc import RPCClient

def result_callback(f):
    print(f.result())

@gen.coroutine
def using_gen_style():
    want_to_say = 'way to explore'
    ret = yield rc.call('echo', want_to_say)
    assert ret == want_to_say
    print('gen_style complete')

rc = RPCClient(('127.0.0.1', 5000))
rc.call('echo', 'hello world', callback=result_callback)
future = rc.call('echo', 'code for fun')
future.add_done_callback(result_callback)
using_gen_style()
ioloop.IOLoop.instance().start()

更多请浏览examples

Performance

系统: CentOS 6.6 x64
处理器: Intel i5-3470 3.20GHz
内存: 8 GB 1600 MHz DDR3
Python: 2.7.10
PyPy: 4.0.0
Clients CPython(QPS) PyPy(QPS)
1 9031 32482
2 16386 64467
3 20377 80604

这个基准测试中,Python循环10w次,PyPy循环50w次,然后运行3次, 结果在 gist:benchmark_result.txt,另一个基于Python的测试在 BENCHMARK.rst

Links

About

A tiny async tcp and duplex rpc implementation using Tornado IOLoop.

Resources

License

Stars

Watchers

Forks

Packages

No packages published

Languages