diff --git a/rpc/rpchandler.go b/rpc/rpchandler.go index cf80e84..03daf39 100644 --- a/rpc/rpchandler.go +++ b/rpc/rpchandler.go @@ -250,7 +250,7 @@ func (handler *RpcHandler) HandlerRpcRequest(request *RpcRequest) { log.Error(err) return } - v(request.inputArgs.GetRawData()) + v(request.RpcRequestData.GetInParam()) return } diff --git a/rpc/server.go b/rpc/server.go index 7213d7e..9513ce9 100644 --- a/rpc/server.go +++ b/rpc/server.go @@ -146,7 +146,7 @@ func (agent *RpcAgent) Run() { //交给程序处理 serviceMethod := strings.Split(req.RpcRequestData.GetServiceMethod(),".") - if len(serviceMethod)!=2 { + if len(serviceMethod) < 1 { rpcError := RpcError("rpc request req.ServiceMethod is error") agent.WriteResponse(processor,req.RpcRequestData.GetServiceMethod(),req.RpcRequestData.GetSeq(),nil,rpcError) ReleaseRpcRequest(req)