基于微服務(wù)框架go-micro開發(fā)gRPC應(yīng)用程序
go-micro是golang的一個(gè)微服務(wù)框架。這篇文章將介紹使用go-micro最新版本v4開發(fā)gRPC服務(wù)的方式。
1、安裝protoc
這個(gè)工具也稱為proto編譯器,可以用來生成各種開發(fā)語言使用proto協(xié)議的代碼。
下載地址:https://github.com/protocolbuffers/protobuf/releases
一般下載最新版本就行,注意要符合自己當(dāng)前的操作系統(tǒng)。

解壓后里邊有個(gè) protoc.exe ,拷貝到 GOPATH 的 bin 目錄下,我這里就是 C:/Users/PC-001/go/bin ,PC-001 是登錄當(dāng)前操作系統(tǒng)的用戶名,需要換成你自己的。GOPATH 可以通過執(zhí)行 go env 查看到。

一般都是把 GOPATH 的 bin 目錄添加到環(huán)境變量的 PATH 變量中,如果沒有,請(qǐng)自行添加上。
2、安裝protoc的go-micro插件
需要安裝兩個(gè)插件,它們用來生成 Golang 版本的 proto 協(xié)議代碼和 go-micro 的 gRPC 代理代碼。
執(zhí)行如下命令,會(huì)在 GOPATH 的 bin 目錄下生成兩個(gè)可執(zhí)行文件:protoc-gen-go.exe 和 protoc-gen-micro.exe。
go install google.golang.org/protobuf/cmd/protoc-gen-go go install go-micro.dev/v4/cmd/protoc-gen-micro@v4
3、編寫proto文件
proto文件是符合Protocol Buffers語言規(guī)范的數(shù)據(jù)交換協(xié)議文件,就像以前WebService定義服務(wù)時(shí)使用的XML文件?,F(xiàn)在一般都是用proto3了,這里創(chuàng)建一個(gè)名為 hello.proto 的文件,放到項(xiàng)目的proto目錄下:
syntax = "proto3";
option go_package="/proto";
package Business;
service Hello {
rpc Say (SayRequest) returns (SayResponse);
}
message SayResponse {
string Message = 1;
}
message SayRequest {
string Name = 1;
}這個(gè)協(xié)議很簡(jiǎn)單,有個(gè)名字為Hello的服務(wù),提供一個(gè)名字為Say的rpc方法,這個(gè)方法有輸入輸出,輸入信息中有一個(gè)名為Name的參數(shù),輸出信息中有一個(gè)名為Message的返回值。
4、生成gRPC代理代碼
在項(xiàng)目根目錄中執(zhí)行如下命令,會(huì)在proto目錄下生成兩個(gè)文件:hello.pb.go 和 hello.pb.micro.go。
protoc --go_out=. --go_opt=paths=source_relative --micro_out=. --micro_opt=paths=source_relative proto/hello.proto
hello.pb.go 中是輸入輸出數(shù)據(jù)類型的Golang定義,hello.pb.micro.go 中是go-micro客戶端和服務(wù)端的gRPC代理程序。
也可以將文件生成到別的目錄中,比如修改 proto 文件中 go_package 的配置為:
option go_package="/business";
然后執(zhí)行下面的命令,會(huì)生成到項(xiàng)目下的business目錄中:
protoc --go_out=. --micro_out=. proto/hello.proto
具體這個(gè)命令還有哪些參數(shù),可以執(zhí)行 protoc -help 去探索下,這里就不羅嗦了。
5、編寫gRPC服務(wù)端程序
這里先上代碼:
package main
import (
"context"
"fmt"
"grpchello/proto"
"log"
"time"
"github.com/asim/go-micro/plugins/server/grpc/v4"
"go-micro.dev/v4"
"go-micro.dev/v4/server"
)
type Hello struct{}
func (s *Hello) Say(ctx context.Context, req *proto.SayRequest, rsp *proto.SayResponse) error {
fmt.Println("request:", req.Name)
rsp.Message = "Hello " + req.Name
return nil
}
func main() {
grpcServer := grpc.NewServer()
service := micro.NewService(
micro.Server(grpcServer),
micro.Name("grpchello.service"),
micro.Address("0.0.0.0:8001"),
micro.RegisterTTL(time.Second*30),
micro.RegisterInterval(time.Second*10),
)
// optionally setup command line usage
service.Init()
// Register Handlers
proto.RegisterHelloHandler(service.Server(), &Hello{})
// Run server
if err := service.Run(); err != nil {
log.Fatal(err)
}
}
整個(gè)過程如下:
先定義一個(gè)名為 Hello 的類型,它去實(shí)現(xiàn)hello.pb.micro.go中生成的HelloHandler接口,也就是編寫具體的業(yè)務(wù)實(shí)現(xiàn)。
然后通過grpc.NewServer創(chuàng)建一個(gè)gRPC服務(wù)器,這里決定go-micro底層通信使用gPRC;
然后通過micro.NewService創(chuàng)建一個(gè)micro服務(wù),這里需要傳入上面創(chuàng)建的grpc server,還要設(shè)置服務(wù)的名稱、監(jiān)聽端口,以及保持服務(wù)健康用的TTL和上報(bào)周期。go-mico當(dāng)前默認(rèn)的服務(wù)發(fā)現(xiàn)機(jī)制是mdns,不用額外部署服務(wù)發(fā)現(xiàn)工具,不過一般只建議在開發(fā)環(huán)境使用,生產(chǎn)環(huán)境建議使用etcd;
通過上面的步驟對(duì)服務(wù)進(jìn)行一些初始化之后,再將Hello類型的實(shí)例注冊(cè)到grpc server;
最后啟動(dòng)服務(wù),就可以開始接客了。
如果直接粘貼這段代碼的話,會(huì)有很多包沒有引用進(jìn)來,可以通過 go get 獲取這些包,也可以執(zhí)行命令:go mod tidy 來引入需要的包。
這里邊還import了一個(gè) grpchello/proto ,這個(gè)是我這邊項(xiàng)目的mod是 grpchello,gRPC代理程序的package是proto,如果你的不一樣,需要修改下。
6、編寫gRPC客戶端程序
訪問gRPC服務(wù)也是通過 hello.pb.micro.go 中生成的方法,直接上代碼:
package main
import (
"bufio"
"context"
"fmt"
"grpchello/proto"
"os"
"github.com/asim/go-micro/plugins/client/grpc/v4"
"go-micro.dev/v4"
)
func main() {
service := micro.NewService(
micro.Client(grpc.NewClient()),
)
service.Init()
client := proto.NewHelloService("grpchello.service", service.Client())
rsp, err := client.Say(context.TODO(), &proto.SayRequest{Name: "BOSSMA"})
if err != nil {
fmt.Println(err)
}
fmt.Println(rsp)
fmt.Println("按回車鍵退出程序...")
in := bufio.NewReader(os.Stdin)
_, _, _ = in.ReadLine()
}
上面的程序使用了 grpc.NewClient , 這決定了底層通信采用gRPC;然后再使用生成的代碼 proto.NewHelloService 創(chuàng)建客戶端代理,這里指定的服務(wù)名字必須是服務(wù)端注冊(cè)的名字;最后使用這個(gè)客戶端代理調(diào)用相應(yīng)的方法。
7、運(yùn)行程序
可以使用 go run xxx.go 來編譯并運(yùn)行程序。這里為了方便測(cè)試,先使用 go build 將它們編譯為exe,然后再雙擊運(yùn)行。實(shí)際運(yùn)行效果如下:

以上就是本文的主要內(nèi)容了,完整代碼示例已經(jīng)上傳到 Github:https://github.com/bosima/go-demo/tree/main/go-micro-grpc-hello
到此這篇關(guān)于go-micro開發(fā)gRPC程序的文章就介紹到這了。希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
Golang跨平臺(tái)GUI框架Fyne的使用教程詳解
Go 官方?jīng)]有提供標(biāo)準(zhǔn)的 GUI 框架,在 Go 實(shí)現(xiàn)的幾個(gè) GUI 庫中,Fyne 算是最出色的,它有著簡(jiǎn)潔的API、支持跨平臺(tái)能力,且高度可擴(kuò)展,下面我們就來看看它的具體使用吧2024-03-03
Golang基于Vault實(shí)現(xiàn)敏感數(shù)據(jù)加解密
數(shù)據(jù)加密是主要的數(shù)據(jù)安全防護(hù)技術(shù)之一,敏感數(shù)據(jù)應(yīng)該加密存儲(chǔ)在數(shù)據(jù)庫中,降低泄露風(fēng)險(xiǎn),本文將介紹一下利用Vault實(shí)現(xiàn)敏感數(shù)據(jù)加解密的方法,需要的可以參考一下2023-07-07
golang接收post和get請(qǐng)求參數(shù)處理
本文主要介紹了golang接收post和get請(qǐng)求參數(shù)處理,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2023-03-03
Go|使用Options模式和建造者模式創(chuàng)建對(duì)象實(shí)戰(zhàn)
這篇文章主要介紹了Go使用Options模式和建造者模式創(chuàng)建對(duì)象實(shí)戰(zhàn)詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-04-04
Go語言對(duì)字符串進(jìn)行SHA1哈希運(yùn)算的方法
這篇文章主要介紹了Go語言對(duì)字符串進(jìn)行SHA1哈希運(yùn)算的方法,實(shí)例分析了Go語言針對(duì)字符串操作的技巧,具有一定參考借鑒價(jià)值,需要的朋友可以參考下2015-03-03
十個(gè)Golang開發(fā)中應(yīng)該避免的錯(cuò)誤總結(jié)
Go是一種靜態(tài)類型的、并發(fā)的、垃圾收集的編程語言,由谷歌開發(fā)。開發(fā)人員在編寫Go代碼時(shí)總會(huì)有一些常見的錯(cuò)誤,下面是Go語言中需要避免的十大壞錯(cuò)誤,希望對(duì)大家有所幫助2023-03-03
Go語言標(biāo)準(zhǔn)庫中math模塊詳細(xì)功能介紹與示例代碼
Go語言的標(biāo)準(zhǔn)庫math提供了一系列基礎(chǔ)數(shù)學(xué)函數(shù)和常量,用于進(jìn)行科學(xué)計(jì)算、幾何計(jì)算和其他數(shù)學(xué)相關(guān)的操作,這篇文章主要介紹了Go語言標(biāo)準(zhǔn)庫中math模塊詳細(xì)功能介紹與示例代碼,需要的朋友可以參考下2025-03-03

