diff --git a/rpc/client.go b/rpc/client.go index 7dc884c..46f00f3 100644 --- a/rpc/client.go +++ b/rpc/client.go @@ -36,10 +36,10 @@ func (slf *Client) NewClientAgent(conn *network.TCPConn) network.Agent { func (slf *Client) Connect(addr string) error { slf.Addr = addr slf.maxCheckCallRpcCount = 100 - slf.callRpcTimerout = 10*time.Second + slf.callRpcTimerout = 15*time.Second slf.ConnNum = 1 slf.ConnectInterval = time.Second*2 - slf.PendingWriteNum = 10000 + slf.PendingWriteNum = 2000000 slf.AutoReconnect = true slf.LenMsgLen = 2 slf.MinMsgLen = 2 diff --git a/rpc/rpchandler.go b/rpc/rpchandler.go index 554a3eb..f8f8e8b 100644 --- a/rpc/rpchandler.go +++ b/rpc/rpchandler.go @@ -80,8 +80,8 @@ func (slf *RpcHandler) GetRpcHandler() IRpcHandler{ } func (slf *RpcHandler) InitRpcHandler(rpcHandler IRpcHandler,getClientFun FuncRpcClient,getServerFun FuncRpcServer) { - slf.callRequest = make(chan *RpcRequest,100000) - slf.callResponeCallBack = make(chan *Call,100000) + slf.callRequest = make(chan *RpcRequest,1000000) + slf.callResponeCallBack = make(chan *Call,1000000) slf.rpcHandler = rpcHandler slf.mapfunctons = map[string]RpcMethodInfo{} diff --git a/rpc/server.go b/rpc/server.go index 1352672..9ab575a 100644 --- a/rpc/server.go +++ b/rpc/server.go @@ -40,7 +40,7 @@ func (slf *Server) Start(listenAddr string) { slf.rpcserver.MinMsgLen = 2 slf.rpcserver.MaxMsgLen = math.MaxUint16 slf.rpcserver.MaxConnNum = 10000 - slf.rpcserver.PendingWriteNum = 10000 + slf.rpcserver.PendingWriteNum = 2000000 slf.rpcserver.NewAgent =slf.NewAgent slf.rpcserver.LittleEndian = LittleEndian slf.rpcserver.Start()