zishuo/apinto
1
0
Fork 0
mirror of https://github.com/eolinker/apinto synced 2025-12-24 13:28:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

优化文件传输占用内存问题

Browse Source
This commit is contained in:
Liujian
2025-10-29 16:50:56 +08:00
parent 33d4a5a6dd
commit 1423c1707d
4 changed files with 130 additions and 117 deletions
Download Patch File Download Diff File Expand all files Collapse all files

40
node/dubbo2-context/context.go
View File

@@ -25,13 +25,9 @@ import (
"github.com/google/uuid"
)
func NewDubboParamBody(typesList []string, valuesList []hessian.Object) *dubbo2_context.Dubbo2ParamBody {
func NewDubboParamBody(typesList []string, valuesList []interface{}) *dubbo2_context.Dubbo2ParamBody {
valList := make([]interface{}, 0, len(valuesList))
for _, v := range valuesList {
valList = append(valList, v)
}
return &dubbo2_context.Dubbo2ParamBody{TypesList: typesList, ValuesList: valList}
return &dubbo2_context.Dubbo2ParamBody{TypesList: typesList, ValuesList: valuesList}
}
var _ dubbo2_context.IDubbo2Context = (*DubboContext)(nil)
@@ -67,13 +63,17 @@ func NewContext(req *invocation.RPCInvocation, port int) dubbo2_context.IDubbo2C
t := time.Now()
method, typesList, valuesList := argumentsUnmarshal(req.Arguments())
if method == "" || len(typesList) == 0 || len(valuesList) == 0 {
log.Errorf("dubbo2 NewContext method=%s typesList=%v valuesList=%v req=%v", method, typesList, valuesList, req)
}
//method, typesList, valuesList := argumentsUnmarshal(req.Arguments())
//if method == "" || len(typesList) == 0 || len(valuesList) == 0 {
// log.Errorf("dubbo2 NewContext method=%s typesList=%v valuesList=%v req=%v", method, typesList, valuesList, req)
//}
method := req.MethodName()
path := req.GetAttachmentWithDefaultValue(constant.PathKey, "")
serviceName := req.GetAttachmentWithDefaultValue(constant.InterfaceKey, "")
serviceName := req.GetAttachmentWithDefaultValue(constant.ServiceKey, "")
if serviceName == "" {
serviceName = path
}
group := req.GetAttachmentWithDefaultValue(constant.GroupKey, "")
version := req.GetAttachmentWithDefaultValue(constant.VersionKey, "")
@@ -81,7 +81,10 @@ func NewContext(req *invocation.RPCInvocation, port int) dubbo2_context.IDubbo2C
serviceWriter := NewRequestServiceWrite(path, serviceName, group, version, method)
paramBody := NewDubboParamBody(typesList, valuesList)
paramBody := &dubbo2_context.Dubbo2ParamBody{
TypesList: req.ParameterTypeNames(),
ValuesList: req.Arguments(),
}
proxy := NewProxy(serviceWriter, paramBody, req.Attachments())
copyMaps := utils.CopyMaps(req.Attachments())
@@ -94,21 +97,20 @@ func NewContext(req *invocation.RPCInvocation, port int) dubbo2_context.IDubbo2C
requestReader := NewRequestReader(serviceReader, localAddr, remoteIp, copyMaps)
addr, _ := netip.ParseAddrPort(localAddr)
addrPort := net.TCPAddrFromAddrPort(addr)
dubboContext := &DubboContext{
netIP: addrPort.IP,
localAddr: addrPort,
ctx: context.Background(),
response: &Response{},
requestReader: requestReader,
proxy: proxy,
labels: make(map[string]string),
port: port,
requestID: uuid.New().String(),
proxy: proxy,
requestReader: requestReader,
netIP: addrPort.IP,
localAddr: addrPort,
acceptTime: t,
response: &Response{},
}
dubboContext.ctx = context.Background()
dubboContext.WithValue("request_time", t)
return dubboContext