我在這里想做的是:我有一個來自Kafka流的轉(zhuǎn)儲,其中以二進制格式存儲了未知數(shù)量的photobuff記錄。我想解碼它們并以JSON格式逐個打印到控制臺。我已經(jīng)瀏覽了整個互聯(lián)網(wǎng),但似乎沒有明確的答案,從原始二進制文件中讀取數(shù)據(jù),其中包含未知數(shù)量的photobuff記錄。我發(fā)現(xiàn)了這個:如何解碼二進制/原始谷歌protobuf數(shù)據(jù),但它與使用protoc對一個已知記錄的簡單解碼有關我已經(jīng)嘗試了以下內(nèi)容,但我似乎并不完全了解如何使用proto.buffer.go結構,因為我只能看到所有26 kb數(shù)據(jù)中的第一個值。package mainimport ( "encoding/json" "fmt" "github.com/golang/protobuf/proto" "io/ioutil" "parseRawDHCP/pb")func main() { file, err := ioutil.ReadFile("file") if err != nil { fmt.Printf("unable to read file %v", err) } msg := pb.Msg{} buffer := proto.NewBuffer(file) for { err := buffer.DecodeMessage(&msg) if err != nil { panic("unable to decode message") } marshalledStruct, err := json.Marshal(msg) if err != nil { panic("can't marshalledStruct the data from message") } if err == nil { fmt.Printf("message is: %v", marshalledStruct) continue } }}如果有人能為我指出如何正確地將原始二進制解碼為原型,我將不勝感激。
從文件中讀取原始字節(jié)數(shù)據(jù)并將其解碼為原型字節(jié)結構
寶慕林4294392
2022-10-04 16:49:26