Rft: DubboHeader的一些问题 about dubbo-go-hessian2 HOT 3 CLOSED

// hessian2/dubbo_test.go
package hessian

import (
	"bytes"
	"encoding/binary"
	"fmt"
	"log"
	"os/exec"
	"testing"
)

// 2 + 1 + 1 + 8 + 4 = 16
type DubboHeader2 struct {
	MagicNumber uint16
	Flat        uint8
	Status      uint8
	InvokeId    uint64
	BodyLength  uint32
}

func getReply1() []byte {
	// make sure jar is generate in hessian2/test_dubbo
	cmd := exec.Command("java", "-jar", "test_dubbo/target/test_dubbo-1.0.0.jar", "replyRequest")
	out, err := cmd.Output()
	if err != nil {
		log.Fatal(err)
	}
	return out
}

func TestDubboHeader2(t *testing.T) {
	resp := getReply1()
	reader := bytes.NewReader(resp)

	// read header
	header := DubboHeader2{}
	binary.Read(reader, binary.BigEndian, &header)
	fmt.Printf("%x %x %x %x %d\n", header.MagicNumber, header.Flat, header.Status, header.InvokeId, header.BodyLength)

	// read body
	d := NewDecoder(resp[16:]) // 16 is header size
	for i := 0; i < 7; i++ {
		r, err := d.Decode()
		if err != nil {
			log.Fatal(r)
		}
		fmt.Printf("%v\n", r)
	}
}