gRPC in ASP.NET Core 3.x -- Protocol Buffer, Go语言的例子(上)
前兩篇文章半年前寫的:
gRPC in ASP.NET Core 3.0 -- Protocol Buffer(1),
gRPC in ASP.NET Core 3.0 -- Protocol Buffer(2)
之前把protocol buffer的基礎知識講了一遍,今天使用Go語言做一些例子。
最終目的是要做一個ASP.NET Core 和 Go Web之間的gRPC通信實例。
建立Go項目
在GOPATH的src下面建立一個文件夾 protobuf-go,然后在里面執行命令
go mod init github.com/solenovex/protobuf-go
這個命令是用來初始化go module的。
命令執行后在該目錄生成go.mod文件,其內容如下:
其實直接執行go mod init 也行,默認會取當前文件夾的名字作為項目名。
?
如果你使用的是Goland,那么需要啟用Go modules集成:
?
然后我們需要安裝Protocol buffer的 Go 支持庫:
go get -u github.com/golang/protobuf/protoc-gen-go
安裝好之后:
下面會出現require github.com/…. 后邊顯示indirect,說明我們的代碼還沒有對其進行直接引用
?
建立main.go,代碼如下:
?
然后執行命令 go run main.go 如果輸出 "hello world!" 就說明一切正常。
?
建立proto
在項目下建立src/first文件夾,在里面建立person.proto文件:
?
下面需要通過這個proto文件,生成go的代碼,命令行執行:
protoc --proto_path src/ --go_out=src/ src/first/person.proto
?
執行完之后,在src/first文件夾下會生成一個文件person.pb.go:
?
我們看一下這個文件里的PersonMessage 這個struct:
這里面前4個屬性就是proto文件里面定義的那4個屬性,每個屬性后邊都跟著一個字符串tags,它里面提供了一些反射需要的信息。
例如id屬性后邊這個:
它表示:
針對protocol buffer轉換,它的類型是varint,tag為1,opt應該是proto2里面遺留下來的東西不用去管,名子為id,協議是proto3.
針對json序列化,它的名為id,omitempty大概可以理解為如果值為該類型的默認值,那么id這個key就會被忽略掉。
??
該文件里面的其余內容我就不介紹了,但是注意,這個文件不可以修改!
?
使用proto生成的代碼
在main.go里面建立一個新的函數NewPersonMessage,然后main函數調用它:
在NewPersonMessage函數里面,我們New了一個生成文件里面的PersonMessage這個struct,并把4個屬性賦了值,最后把它賦給變量pm。
可以通過pm.xx屬性來修改它的值,也可以通過pm.GetXx()來獲取其屬性的值。
?
執行go run main.go之后結果如下:
?
修改package名
proto生成的go文件的package名并不是很符合約定,有一種約定是proto生成的go文件的package名應該以詩上層目錄名+pb:
?
所以我可以修改proto文件,添加一個option:
option go_package 的值就是 生成go文件的package名。
?
再次執行:
protoc --proto_path src/ --go_out=src/ src/first/person.proto
?
這次生成的go文件的package就是:
?
把數據寫入到文件
下面把NewPersonMessage添加一個返回類型:
返回PersonMessage的指針。
?
然后在main函數里通過NewPersonMessage函數獲取一個PersonMessage,然后再建立一個writeToFile函數,把數據寫入到文件里:
這里面writeToFile函數的第一個參數是文件名,第二個參數是proto.Message類型,它是一個接口,其代碼如下:
?
而person.proto生成的PersonMessage struct正好擁有這些方法,所以它就是實現了該接口,所以在main在調用writeToFile函數的時候,可以將PersonMessage傳遞進去。
writeToFile里面的代碼很簡單,就是把數據寫入到制定的文件里,文件權限模式為0644。
然后執行 go run main.go 會生成person.bin文件:
它是個二進制文件,編輯器無法打開查看內容。
?
從文件讀取數據
添加一個readFromFile函數,用來從文件讀取數據:
?
然后在main函數里面new一個PersonMessage的指針,它的各屬性值都沒填,把這個指針傳入到readFromFile函數里面,在里面使用proto.Unmarshal方法把數據寫入到該指針指向的struct里面。
最后在main函數里進行打印,其結果如下:
?
?
總結
以上是生活随笔為你收集整理的gRPC in ASP.NET Core 3.x -- Protocol Buffer, Go语言的例子(上)的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 中小企业团队敏捷产品开发流程最佳实践
- 下一篇: 温故知新 .Net重定向深度分析