Fix: readHeader error

protocol/dubbo/codec.go

@@ -79,6 +79,10 @@ func (p *DubboPackage) Unmarshal(buf *bytes.Buffer, opts ...interface{}) error {
 	// read header
 	err := codec.ReadHeader(&p.Header)
 	if err != nil {
+		if p.Header.Type&hessian.PackageError != hessian.PackageType(hessian.Zero) {
+			p.Body = &hessian.Response{Exception: err}
+			return nil
+		}
 		return perrors.WithStack(err)
 	}
 

protocol/dubbo/readwriter.go

@@ -19,7 +19,6 @@ package dubbo
 
 import (
 	"bytes"
-	"fmt"
 	"reflect"
 )
 
@@ -165,6 +164,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()))
 }