Ma/origin
1
0
Fork 0
mirror of https://github.com/duanhf2012/origin.git synced 2026-02-03 22:45:13 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

优化rpc

Browse Source
This commit is contained in:
orgin
2022-11-26 14:36:03 +08:00
parent 8c6ee24b16
commit 11b78f84c4
2 changed files with 18 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
rpc/rpchandler.go
View File

@@ -273,25 +273,7 @@ func (handler *RpcHandler) HandlerRpcRequest(request *RpcRequest) {
}
}
//复制输入参数
iParamValue := reflect.New(v.inParamValue.Type().Elem())
iParam := iParamValue.Interface()
_, processor := GetProcessorType(request.inParam)
bytes,err := processor.Marshal(request.inParam)
if err == nil {
err = processor.Unmarshal(bytes,iParam)
}
if err != nil {
errM := "RpcHandler " + handler.rpcHandler.GetName() + "."+ request.RpcRequestData.GetServiceMethod()+" deep copy inParam is error:" + err.Error()
log.SError(errM)
if request.requestHandle != nil {
request.requestHandle(nil, RpcError(errM))
}
return
}
paramList = append(paramList, iParamValue)
paramList = append(paramList, reflect.ValueOf(request.inParam))
var oParam reflect.Value
if v.outParamValue.IsValid() {
if request.localReply != nil {
@@ -306,7 +288,6 @@ func (handler *RpcHandler) HandlerRpcRequest(request *RpcRequest) {
request.requestHandle(nil, RpcError(rErr))
return
}
returnValues := v.method.Func.Call(paramList)
errInter := returnValues[0].Interface()
if errInter != nil {

19
rpc/server.go
View File

@@ -335,8 +335,23 @@ func (server *Server) selfNodeRpcHandlerAsyncGo(client *Client, callerRpcHandler
}
_, processor := GetProcessorType(args)
inParamValue := reflect.New(reflect.ValueOf(args).Type().Elem())
//args
//复制输入参数
iParam := inParamValue.Interface()
bytes,err := processor.Marshal(args)
if err == nil {
err = processor.Unmarshal(bytes,iParam)
}
if err != nil {
errM := errors.New("RpcHandler " + handlerName + "."+serviceMethod+" deep copy inParam is error:" + err.Error())
log.SError(errM.Error())
return errM
}
req := MakeRpcRequest(processor, 0, 0, serviceMethod, noReply, nil)
req.inParam = args
req.inParam = iParam
req.localReply = reply
if noReply == false {
@@ -370,7 +385,7 @@ func (server *Server) selfNodeRpcHandlerAsyncGo(client *Client, callerRpcHandler
}
}
err := rpcHandler.PushRpcRequest(req)
err = rpcHandler.PushRpcRequest(req)
if err != nil {
ReleaseRpcRequest(req)
return err