快速,非阻塞RPC系统。
项目描述
Speedy - 一个适用于Python的快速RPC系统
=====================================
一个快速的Python非阻塞RPC库。
安装
------------
pip install [--user] speedy
或
easy_install speedy
用法
-----
##### 导入
import speedy
from speedy import zeromq
##### 服务器
class MyServer(speedy.Server)
def foo(self, handle, request)
handle.done(do_something(request.foo, request.bar))
server = MyServer(zeromq.server_socket(('127.0.0.1', port)))
# 或使用-1让服务器获取一个开放的端口
# server = MyServer(zeromq.server_socket(('127.0.0.1', -1)))
server.serve() # 等待服务器退出
##### 客户端
client = speedy.Client(zeromq.client_socket(('127.0.0.1', server_port)))
# 请求是任意的Python对象
request = { 'foo' : 123, 'bar' : 456 }
future = client.foo(request)
# 等待结果。如果服务器遇到错误,
# 将抛出一个speedy.RemoteException异常。
result = future.wait()
反馈
--------
问题、评论:<power@cs.nyu.edu>
=====================================
一个快速的Python非阻塞RPC库。
安装
------------
pip install [--user] speedy
或
easy_install speedy
用法
-----
##### 导入
import speedy
from speedy import zeromq
##### 服务器
class MyServer(speedy.Server)
def foo(self, handle, request)
handle.done(do_something(request.foo, request.bar))
server = MyServer(zeromq.server_socket(('127.0.0.1', port)))
# 或使用-1让服务器获取一个开放的端口
# server = MyServer(zeromq.server_socket(('127.0.0.1', -1)))
server.serve() # 等待服务器退出
##### 客户端
client = speedy.Client(zeromq.client_socket(('127.0.0.1', server_port)))
# 请求是任意的Python对象
request = { 'foo' : 123, 'bar' : 456 }
future = client.foo(request)
# 等待结果。如果服务器遇到错误,
# 将抛出一个speedy.RemoteException异常。
result = future.wait()
反馈
--------
问题、评论:<power@cs.nyu.edu>
项目详情
关闭
speedy-0.23.tar.gz的哈希值
算法 | 哈希摘要 | |
---|---|---|
SHA256 | af0405c552f104ad21b183350a50d8bdf6bdd69a3fef328098dc503afc0afddb |
|
MD5 | 6ef04ff8cd928113315e36097f36da8d |
|
BLAKE2b-256 | 339aa3018fca2f4ca8709b6e1cfed227307fd8c902bc09f593a3c4ae954a7967 |