Agileutil v0.0.7 发布,Python RPC 框架

来源: 投稿
作者: tankli
2021-03-27

        本次更新的版本是v0.0.7, 在v0.0.6的基础上,添加了TCP服务端的keepalive timeout设置。如果客户端长时间没有活动,达到超时时间后,服务端会主动关闭客户端连接,减少性能开销,节省系统资源,防止内存泄漏。

       当服务端主动关闭客户端连接后,如果客户端的client对象,后面继续调用call()方法请求,此时由于连接已被服务端关闭,已不可用,客户端会自动判断进行重连,对用户是透明的,因此用户可以无需关心连接被关闭的问题。

       默认的keepalive timeout时间设置为和Nginx相同的75s 。也支持自定义keepalive timeout时间,用户可以通调用setKeepaliveTime() 方法,参考下面的例子:

from agileutil.rpc.server import TcpRpcServer

def sayHello(name):
    return 'hello ' + name

s = TcpRpcServer('0.0.0.0', 9988)
s.setKeepaliveTimeout(10) #那么客户端连接如果10秒内没有活动,将会被服务端主动关闭
s.regist(sayHello)
s.serve()

客户端

from agileutil.rpc.client import TcpRpcClient
import time

cli = TcpRpcClient('127.0.0.1', 9988, timeout = 2)
resp = cli.call(func = 'sayHello', args=('zhangsan'))
print('resp', resp)
time.sleep(15)
resp = cli.call(func = 'sayHello', args=('zhangsan'))  #此时客户端会自动进行重连
print('resp', resp)

 

详情访问

github: https://github.com/lycclsltt/agileutil

gitee:   https://gitee.com/lycclsltt/agileutil

展开阅读全文
3 收藏
分享
加载中
最新评论 (1)
mark
2021-03-28 19:20
0
回复
举报
更多评论
1 评论
3 收藏
分享
返回顶部
顶部