這是一個(gè)場(chǎng)景：您正在 golang 中實(shí)現(xiàn)一個(gè)通用組件，它可以與任何類型的原型消息（二進(jìn)制序列化）一起使用，并且需要在編譯時(shí)不知道其類型的情況下反序列化二進(jìn)制原型數(shù)據(jù)。例如，我在編寫通用的 kafka json 歸檔程序時(shí)遇到了這個(gè)問題，該組件將：從配置中接收消息類型（字符串）和 kafka 主題的名稱需要在運(yùn)行時(shí)創(chuàng)建二進(jìn)制 -> 內(nèi)存解串器和內(nèi)存 -> json 序列化器。你如何從消息名稱中獲得二進(jìn)制字節(jié)的反序列化器？
1 回答
料青山看我應(yīng)如是
TA貢獻(xiàn)1772條經(jīng)驗(yàn) 獲得超8個(gè)贊
golang 原型庫(kù)有一個(gè)用于此目的的輔助實(shí)用程序：
// MessageType returns the message type (pointer to struct) for a named message.
// The type is not guaranteed to implement proto.Message if the name refers to a
// map entry.
func MessageType(name string) reflect.Type {
? ?// ....
}
要使用它，您可以使用類似于此的方法：
func getProto(messageType string, messageBytes []byte) proto.Message {
? ? pbtype := proto.MessageType(messageType)
? ? msg := reflect.New(pbtype.Elem()).Interface().(proto.Message)
? ? proto.Unmarshal(messageBytes, msg)
? ? return msg
}
- 1 回答
- 0 關(guān)注
- 177 瀏覽
添加回答
舉報(bào)
0/150
提交
取消