rpc内存池优化

rpc/rpc.go

@@ -144,7 +144,7 @@ func (call *Call) Done() *Call{
 }
 
 func MakeRpcRequest(rpcProcessor IRpcProcessor,seq uint64,rpcMethodId uint32,serviceMethod string,noReply bool,inParam []byte) *RpcRequest{
-	rpcRequest := rpcRequestPool.Get().(*RpcRequest).Clear()
+	rpcRequest := rpcRequestPool.Get().(*RpcRequest)
 	rpcRequest.rpcProcessor = rpcProcessor
 	rpcRequest.RpcRequestData = rpcRequest.rpcProcessor.MakeRpcRequest(seq,rpcMethodId,serviceMethod,noReply,inParam)
 

rpc/rpchandler.go

@@ -243,12 +243,12 @@ func (handler *RpcHandler) HandlerRpcRequest(request *RpcRequest) {
 					request.requestHandle(nil,rpcErr)
 				}
 		}
-
-		if request.requestHandle == nil {
-			ReleaseRpcRequest(request)
-		}
 	}()
 
+	if request.requestHandle == nil {
+		defer ReleaseRpcRequest(request)
+	}
+
 	//如果是原始RPC请求
 	rawRpcId := request.RpcRequestData.GetRpcMethodId()
 	if rawRpcId>0 {