我试图解码服务器的gzip响应,msgpack数组或msgpack数组最终被gzip压缩。
为了说明这一点,我的回答看起来像:
gzip(msgpack([msgpack([]), msgpack([]), msgpack([]) ....]))
这是我到目前为止所做的,但我收到了msgpack错误
msgpack: invalid code=3f decoding array length
,因此我得到的只是空片。
这个getBytes函数我从这个SO answer
func getBytes(key interface{}) ([]byte, error) {
var buf bytes.Buffer
enc := gob.NewEncoder(&buf)
err := enc.Encode(key)
if err != nil {
return nil, err
}
return buf.Bytes(), nil
}
var unZipped io.Reader
unZipped, err = gzip.NewReader(resp.Body)
var dataBytes bytes.Buffer
_, err = dataBytes.ReadFrom(unZipped)
if err != nil {
logger.Println("error un gzipping", err)
}
var packedSlices []interface{}
bytesSlice := dataBytes.Bytes()
err = msgpack.Unmarshal(bytesSlice, &packedSlices)
for _, c := range packedSlices {
var packedSlice []interface{}
byts, _ := getBytes(c)
err = msgpack.Unmarshal(byts, &packedSlice)
logger.Println(err, packedSlice)
}
当我在python 3.7中做同样的事情时它工作正常:
resp = requests.post(url, headers=headers, json=payload, stream=True)
datas = msgpack.loads(gzip.decompress(resp.raw.data))
datas = [msgpack.loads(k) for k in datas]
这里有什么我想念的吗?
而不是使用[]interface{}
类型作为解包类型使用[][]byte
。将根msg解组为[][]byte
然后迭代切片的字节切片并解组每个子字节切片。你不需要getBytes
功能。
这里有一些例子:
var root [][]byte
if err := msgpack.Unmarshal(bytesSlice, &root); err != nil {
panic(err)
}
for _, childBytes := range root {
var child []interface{}
if err := msgpack.Unmarshal(childBytes, &child); err != nil {
panic(err)
}
_ = child
}