vlambda博客
学习文章列表

       当服务端主动关闭客户端连接后，如果客户端的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)