rpc接口调用优化

rpc/client.go

@@ -23,6 +23,7 @@ type Client struct {
 
 func (slf *Client) NewClientAgent(conn *network.TCPConn) network.Agent {
 	slf.conn = conn
+	slf.pending = map[uint64]*Call{}
 	return slf
 }
 

rpc/rpchandler.go

@@ -258,6 +258,7 @@ func (slf *RpcHandler) goRpc(bCast bool,nodeId int,serviceMethod string,mutiCoro
 			if pCall.Err!=nil {
 				err = pCall.Err
 			}
+			continue
 		}
 
 		//跨node调用
@@ -265,6 +266,7 @@ func (slf *RpcHandler) goRpc(bCast bool,nodeId int,serviceMethod string,mutiCoro
 		if pCall.Err!=nil {
 			err = pCall.Err
 		}
+
 	}
 
 	return err