Agileutil v0.0.15 发布，支持异步的 RPC 框架！
本次更新的版本是v0.0.15。在原有基础上，开发者可通过async关键字，轻松实现异步，但异步不作为强制要求。使用async标记的方法中可配合await实现异步调用，未使用async标记的方法是同步调用，开发者自行选择。 同时优化了TCP服务端的性能，借助于asyncio, 由多线程修改为单线程异步服务器。
TCP RPC 服务端
下面是一个TCP协议的服务端例子。
- 创建一个TcpRpcServer对象, 指定服务端监听地址和端口
- 通过@rpc装饰器注册需要被客户端请求的方法
- 调用serve()方法，开始处理客户端请求
from agileutil.rpc.server import TcpRpcServer, rpc
import asyncio
@rpc
class TestService:
def hello(self, name):
return "Hello, {}!".format(name)
async def add(self, a, b, c):
asyncio.sleep(1)
return a + b + c
@rpc
def hello(name):
return "Hello, {}!".format(name)
server = TcpRpcServer('0.0.0.0', 9988)
server.serve()
TCP RPC 客户端
- 创建TcpRpcClient对象，指定RPC服务端地址
- 通过call()方法，指定服务端方法名称和参数（注意：如果方法名不存在，或者服务端未调用@rpc装饰器注册，那么call()方法将抛出异常）
- call() 方法的返回值和在本地调用一样，原来是什么返回类型，就还是什么（例如返回字典、列表、对象甚至内置类型，经过序列化后，不会发生改变）
from agileutil.rpc.client import TcpRpcClient cli = TcpRpcClient('127.0.0.1', 9988, timeout = 2) resp = cli.call('TestService.hello', args=('xiaoming',)) resp = cli.call('TestService.add', args=(1, 2, 3)) resp = cli.call('hello', args=('xiaoming',))
