Mod:big pkg ut

protocol/dubbo/listener.go

@@ -88,7 +88,7 @@ func (h *RpcClientHandler) OnMessage(session getty.Session, pkg interface{}) {
 		logger.Debugf("get rpc heartbeat response{header: %#v, body: %#v}", p.Header, p.Body)
 		return
 	}
-	logger.Debugf("get rpc response{header: %#v, body: %#v}", p.Header, p.Body)
+	//logger.Debugf("get rpc response{header: %#v, body: %#v}", p.Header, p.Body)
 
 	h.conn.updateSession(session)
 

protocol/dubbo/readwriter.go

@@ -19,6 +19,7 @@ package dubbo
 
 import (
 	"bytes"
+	"fmt"
 	"reflect"
 )
 
@@ -164,6 +165,6 @@ func (p *RpcServerPackageHandler) Write(ss getty.Session, pkg interface{}) error
 		logger.Warnf("binary.Write(res{%#v}) = err{%#v}", res, perrors.WithStack(err))
 		return perrors.WithStack(err)
 	}
-
+	fmt.Println("eofefe", buf.Len())
 	return perrors.WithStack(ss.WriteBytes(buf.Bytes()))
 }