php小编新一为您介绍如何将任何类型的数据值传递到Golang中的GRPC Protobuf结构中。GRPC Protobuf是一种高效的数据传输协议,但是默认情况下只支持有限的数据类型。然而,通过使用自定义的字段类型和值转换方法,我们可以轻松地将任何类型的数据值传递到Protobuf结构中。在本文中,我们将提供一些实用的技巧和示例代码,帮助您在Golang中处理各种数据类型的传递。无论是字符串、数字、布尔值还是自定义的复杂对象,都可以通过这些方法成功传递到GRPC Protobuf结构中。让我们一起来看看吧!
我正在尝试通过 tonutils-go 解析 adnl 库中的数据并通过 grpc 传递数据。
我需要的数据结构为
// struct from tonutils-go type transaction struct { _ magic `tlb:"$0111"` accountaddr []byte `tlb:"bits 256"` lt uint64 `tlb:"## 64"` prevtxhash []byte `tlb:"bits 256"` prevtxlt uint64 `tlb:"## 64"` now uint32 `tlb:"## 32"` outmsgcount uint16 `tlb:"## 15"` origstatus accountstatus `tlb:"."` endstatus accountstatus `tlb:"."` io struct { in *message `tlb:"maybe ^"` out *messageslist `tlb:"maybe ^"` } `tlb:"^"` totalfees currencycollection `tlb:"."` stateupdate hashupdate `tlb:"^"` // of account description transactiondescription `tlb:"^"` // not in scheme, but will be filled based on request data for flexibility hash []byte `tlb:"-"` } type transactiondescription struct { description any `tlb:"."` } type transactiondescriptionordinary struct { _ magic `tlb:"$0000"` creditfirst bool `tlb:"bool"` storagephase *storagephase `tlb:"maybe ."` creditphase *creditphase `tlb:"maybe ."` computephase computephase `tlb:"."` actionphase *actionphase `tlb:"maybe ^"` aborted bool `tlb:"bool"` bouncephase *bouncephase `tlb:"maybe ."` destroyed bool `tlb:"bool"` } type computephase struct { phase any `tlb:"."` } type computephasevm struct { _ magic `tlb:"$1"` success bool `tlb:"bool"` msgstateused bool `tlb:"bool"` accountactivated bool `tlb:"bool"` gasfees coins `tlb:"."` details struct { gasused *big.int `tlb:"var uint 7"` gaslimit *big.int `tlb:"var uint 7"` gascredit *big.int `tlb:"maybe var uint 3"` mode int8 `tlb:"## 8"` exitcode int32 `tlb:"## 32"` exitarg *int32 `tlb:"maybe ## 32"` vmsteps uint32 `tlb:"## 32"` vminitstatehash []byte `tlb:"bits 256"` vmfinalstatehash []byte `tlb:"bits 256"` } `tlb:"^"` }
txtest的protobuf:
message txtest { int32 exitcode = 1; }
我要解析的数据是exitcode,代码如下:
list, err := api.listtransactions(context.background(), addr, 1, uint64(txinfo.txlt), data) if err != nil { log.printf("send err: %s", err.error()) return nil, err } for _, t := range list { a := t.description.description var result tlb.transactiondescriptionordinary b, err := json.marshalindent(a, "", " ") if err != nil { fmt.println("error:", err) } json.unmarshal([]byte(string(b)), &result) var computephase tlb.computephasevm c, err := json.marshalindent(result.computephase.phase, "", " ") if err != nil { fmt.println("error:", err) } json.unmarshal([]byte(string(c)), &computephase) detail := &pb.txtest{ exitcode: computephase.details.exitcode, } detail2 := struct { exitcode int32 `json:"exit_code"` }{ exitcode: computephase.details.exitcode, } fmt.printf("detail: %+v\n", detail) fmt.printf("detail2: %+v\n", detail2) }
一笔交易的数据结构为:
{ "accountaddr": "hymm1/kk6gb2dlv3zvkiryepkohrtf/jg8k7ttg91sq=", "lt": 11898016000001, "prevtxhash": "ikgjsxdt0gzijxgnilvxy0+a1ggeqded4f7zaj9dlmc=", "prevtxlt": 11897712000001, "now": 1685602760, "outmsgcount": 1, "origstatus": "active", "endstatus": "active", "io": { "in": { "msgtype": "external_in", "msg": { "srcaddr": "none", "dstaddr": "eqadiyzx-qroyhymtxfnwqhhiskqgdfmx-mbwru1mb3wxn5d", "importfee": "0", "stateinit": null, "body": {} } }, "out": { "list": {} } }, "totalfees": { "coins": "22324812", "extracurrencies": {} }, "stateupdate": { "oldhash": "wukexyos8hswyqyrlhpmjhpfmusid8odtaq6fy20pyq=", "newhash": "e8tn4cp4lakfwvdcgc/vqbz7lzeb4mhjmbrfe8rpsqa=" }, "description": { "description": { "creditfirst": true, "storagephase": { "storagefeescollected": "484", "storagefeesdue": null, "statuschange": { "type": "unchanged" } }, "creditphase": null, "computephase": { "phase": { "success": true, "msgstateused": false, "accountactivated": false, "gasfees": "19862000", "details": { "gasused": 19862, "gaslimit": 0, "gascredit": 10000, "mode": 0, "exitcode": 0, "exitarg": null, "vmsteps": 404, "vminitstatehash": "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa=", "vmfinalstatehash": "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa=" } } }, "actionphase": { "success": true, "valid": true, "nofunds": false, "statuschange": { "type": "unchanged" }, "totalfwdfees": "1000000", "totalactionfees": "333328", "resultcode": 0, "resultarg": null, "totalactions": 1, "specactions": 0, "skippedactions": 0, "messagescreated": 1, "actionlisthash": "fkoo2xx9ju4yxtgjlrujvayrrwtryhebkuywuyg9av4=", "totalmsgsize": { "cells": 1, "bits": 697 } }, "aborted": false, "bouncephase": null, "destroyed": false } }, "hash": "vmxfrkfietmaihm3brtvhskaide1ckgrw8rqbvarjtq=" }
detail
和 detail2
的输出为:
detail: detail2: {ExitCode:0}
我的问题是为什么 protoc
生成的结构无法从 transaction
解析 exitcode
但我定义的结构可以正常工作?
如何将数据注入到protoc
生成的struct txtest
中,让我通过grpc
传输数据?
使用 0 以外的退出代码值尝试此操作,我猜您会得到不同的结果。
看看您生成的代码。我相信发生的事情是 fmt.Printf
正在为您的原型结构调用生成的 String()
方法,它使用 prototext
包来打印消息的内容,而不是默认的 Go 结构打印机。
这是 proto3
的预期行为; int32
值 0
和空字段之间没有区别。
以上がGolang の GRPC Protobuf 構造に任意のタイプのデータ値を渡すにはどうすればよいですか?の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。