采用多路复用模式，出现了数据乱码的情况

zzqCh commented 1 year ago

Describe the bug 采用多路复用模式，出现了数据乱码的情况：

To Reproduce 请求链路： client---->mosn----->netpoll，其中mosn方显示发出的数据是对的，但是接收到的是乱码，mosn也开启了多路复用。 netpoll的示例代码：


func (s *muxServer) handler(ctx context.Context, conn netpoll.Connection) (err error) {
    mc := ctx.Value(ctxkey).(*muxConn)
    reader := conn.Reader()
    var p1 []byte
    var p netpoll.Reader
    p1, err = reader.Peek(6)
    if err != nil {
        return err
    }
    length := int(binary.BigEndian.Uint32(p1[2:6])) + 6
    p, err = reader.Slice(length)
    if err != nil {
        return err
    }
    // handler must use another goroutine
    go func() {
        defer func() {
            if err2 := recover(); err2 != nil {
                err = fmt.Errorf("Recover from panic!,data is %v\n", err)
            }
        }()
        req := &runner.Message{}
        err = codec.Decode(p, req)
        if err != nil {
            panic(fmt.Errorf("netpoll decode failed: %s", err.Error()))
        }
        // handler
        resp := runner.ProcessRequest(reporter, req)
        // encode
        writer := netpoll.NewLinkBuffer()
        err = codec.Encode(writer, resp)
        if err != nil {
            panic(fmt.Errorf("netpoll encode failed: %s", err.Error()))
        }
        mc.Put(func() (buf netpoll.Writer, isNil bool) {
            return writer, false
        })
    }()
    return nil
}

func ProcessRequest(report *perf.Recorder, req *Message) (resp *Message) {
    decoder := req.DecoderData
    if decoder.DataLen == 0 || decoder.SerialNo == codec.HB {
        return &Message{DecoderData: &codec.CustomDecoder{Version: decoder.Version, SerialNo: decoder.SerialNo}}
    }
    //marshal, err := json.Marshal(req)
    logInfo("reqInfo serialNo:%s,data is:%#v", blueString("["+req.DecoderData.SerialNo+"]"), *decoder)
    // copy a map
    fruitRankCopy := make(map[string]string)
    for k, v := range decoder.Params {
        fruitRankCopy[k] = v
    }
    fruitRankCopy["Error1123"] = "999"
    resp = &Message{
        DecoderData: &codec.CustomDecoder{
            Version: decoder.Version, Params: fruitRankCopy},
    }
    //marshal1, err1 := json.Marshal(resp)
    logInfo("respInfo serialNo:%s,data is:%+v", blueString("["+resp.DecoderData.SerialNo+"]"), *resp.DecoderData)
    if len(decoder.Params) > 0 {
        sleepMs, ok := decoder.Params["sleep"]
        if ok {
            sl, err := strconv.ParseInt(sleepMs, 10, 0)
            if err == nil && sl > 0 {
                time.Sleep(time.Millisecond * time.Duration(sl))
            }
        }
    }
    //marshal1, err1 := json.Marshal(resp)
    logInfo("respInfo---->222 serialNo:%s,data is:%+v", blueString("["+resp.DecoderData.SerialNo+"]"), *resp.DecoderData)
    return resp
}

Expected behavior 两个loginfo打印的内容一致。

Screenshots