Dubbo Golang快速开发Rpc服务
开发 RPC Server & RPC Client
基于 Dubbo 定义的 Triple 协议，你可以轻松编写浏览器、gRPC 兼容的 RPC 服务，并让这些服务同时运行在 HTTP/1 和 HTTP/2 上。Dubbo Go SDK 支持使用 IDL 或编程语言特有的方式定义服务，并提供一套轻量的 API 来发布或调用这些服务。
本示例演示了基于 Triple 协议的 RPC 通信模式，示例使用 Protocol Buffer 定义 RPC 服务，并演示了代码生成、服务发布和服务访问等过程。
前置条件
因为使用 Protocol Buffer 的原因，我们首先需要安装相关的代码生成工具，这包括 protoc、protoc-gen-go、protoc-gen-go-triple。
-
安装
protoc查看 Protocol Buffer Compiler 安装指南
-
安装
protoc插件接下来，我们安装插件
protoc-gen-go、protoc-gen-go-triple。go install google.golang.org/protobuf/cmd/protoc-gen-go@latest go install dubbo.apache.org/dubbo-go/v3/cmd/protoc-gen-go-triple@v3.0.1确保
protoc-gen-go、protoc-gen-go-triple在你的PATH中。这可以通过which protoc-gen-go验证，如果该命令不能正常工作的话，请执行以下命令：[ -n "$(go env GOBIN)" ] && export PATH="$(go env GOBIN):${PATH}" [ -n "$(go env GOPATH)" ] && export PATH="$(go env GOPATH)/bin:${PATH}"
快速运行示例
下载示例源码
我们在 apache/dubbo-go-samples 仓库维护了一系列 dubbo-go 使用示例，用来帮助用户快速学习 dubbo-go 使用方式。
你可以 下载示例zip包并解压，或者克隆仓库：
$ git clone --depth 1 https://github.com/apache/dubbo-go-samples
切换到快速开始示例目录：
$ cd dubbo-go-samples/helloworld
运行 server
在 go-server/cmd 目录：
运行以下命令，启动 server：
$ go run server.go
使用 cURL 验证 server 已经正常启动：
$ curl \
--header "Content-Type: application/json" \
--data '{"name": "Dubbo"}' \
http://localhost:20000/greet.GreetService/Greet
Greeting: Hello world
运行 client
打开一个新的 terminal，运行以下命令，在 go-client/cmd 目录运行以下命令，启动 client
$ go run client.go
Greeting: Hello world
以上就是一个完整的 dubbo-go RPC 通信服务开发过程。
源码讲解
接下来，我们将对 dubbo-go-samples/helloworld 示例进行源码层面的讲解。
定义服务
示例使用 Protocol Buffer (IDL) 来定义 Dubbo 服务。
syntax = "proto3";
package greet;
option go_package = "github.com/apache/dubbo-go-samples/helloworld/proto;greet";
message GreetRequest {
string name = 1;
}
message GreetResponse {
string greeting = 1;
}
service GreetService {
rpc Greet(GreetRequest) returns (GreetResponse) {}
}
这个文件声明了一个叫做 GreetService 的服务，为这个服务定义了 Greet 方法以及它的请求参数 GreetRequest 和返回值 GreetResponse。
生成代码
在运行 server 或者 client 之前，我们需要使用 protoc-gen-go、protoc-gen-go-triple 生成相关的代码
protoc --go_out=. --go_opt=paths=source_relative \
--go-triple_out=. --go-triple_opt=paths=source_relative \
./greet.proto
运行以上命令后，在目标目录中看到以下生成的文件：
proto
├── greet.pb.go
├── greet.proto
└── greet.triple.go
在 proto/greet/v1 包下有两部分内容：
greet.pb.go是由谷歌标准的protoc-gen-go生成，它包含GreetRequest、GreetResponse结构体和响应的编解码规则。greet.triple.go是由 Dubbo 自定义的插件protoc-gen-go-triple成，其中关键的信息包括生成的接口GreetService、构造器等。
实现服务
接下来我们就需要添加业务逻辑了，实现 greet.GreetService 接口即可。
type GreetTripleServer struct {
}
func (srv *GreetTripleServer) Greet(ctx context.Context, req *greet.GreetRequest) (*greet.GreetResponse, error) {
resp := &greet.GreetResponse{Greeting: req.Name}
return resp, nil
}
启动 Server
创建一个新的 Server，把我们上一步中实现的 GreeterServer注册给它，接下来就可以直接初始化和启动 Server 了，它将在指定的端口接收请求。
func main() {
srv, err := server.NewServer(
server.WithServerProtocol(
protocol.WithPort(20000),
protocol.WithTriple(),
),
)
if err != nil {
panic(err)
}
if err := greet.RegisterGreetServiceHandler(srv, &GreetTripleServer{}); err != nil {
panic(err)
}
if err := srv.Serve(); err != nil {
logger.Error(err)
}
}
访问服务
最简单方式是使用 HTTP/1.1 POST 请求访问服务，参数则作以标准 JSON 格式作为 HTTP 负载传递。如下是使用 cURL 命令的访问示例：
curl \
--header "Content-Type: application/json" \
--data '{"name": "Dubbo"}' \
http://localhost:20000/greet.GreetService/Greet
也可以使用 Dubbo client 请求服务，我们首先需要从生成代码即 greet 包中获取服务代理，为它指定 server 地址并初始化，之后就可以发起 RPC 调用了。
func main() {
cli, err := client.NewClient(
client.WithClientURL("127.0.0.1:20000"),
)
if err != nil {
panic(err)
}
svc, err := greet.NewGreetService(cli)
if err != nil {
panic(err)
}
resp, err := svc.Greet(context.Background(), &greet.GreetRequest{Name: "hello world"})
if err != nil {
logger.Error(err)
}
logger.Infof("Greet response: %s", resp.Greeting)
}
以上即是 dubbo-go rpc 的基本工作原理！