- Created by 郭强, last modified on Mar 16, 2023
微服务完整特性及相关组件从v2.4版本开始提供。
基本介绍
GoFrame框架支持微服务模式开发，提供了常用的微服务组件、开发工具、开发教程帮助团队快速微服务转型。
简单示例
GoFrame微服务组件的低藕及通用化设计的，组件化使用支持大部分的微服务通信协议。在官方文档中，我们以HTTP及GRPC协议为示例，介绍微服务的开发以及组件工具的使用。由于HTTP Web开发已经有比较丰富完善的独立章节介绍，因此微服务章节大部分介绍以GRPC为主。
HTTP微服务示例
https://github.com/gogf/gf/tree/master/example/registry/file
server.go
package main
import (
"github.com/gogf/gf/contrib/registry/file/v2"
"github.com/gogf/gf/v2/frame/g"
"github.com/gogf/gf/v2/net/ghttp"
"github.com/gogf/gf/v2/net/gsvc"
"github.com/gogf/gf/v2/os/gfile"
)
func main() {
gsvc.SetRegistry(file.New(gfile.Temp("gsvc")))
s := g.Server(`hello.svc`)
s.BindHandler("/", func(r *ghttp.Request) {
g.Log().Info(r.Context(), `request received`)
r.Response.Write(`Hello world`)
})
s.Run()
}
可以看到，一个HTTP的微服务端和一个普通的Web Server端没什么差异，但是顶部多了一行代码：
gsvc.SetRegistry(file.New(gfile.Temp("gsvc")))
这行代码用于启用并注册当前服务使用的注册发现组件，在该示例中使用的file.New(gfile.Temp("gsvc"))是基于本地系统文件的服务注册发现组件，其中的gfile.Temp("gsvc")指定的是存放服务文件的路径，例如在Linux/MacOS系统下，指向的是/tmp/gsvc目录。基于文件系统的注册发现仅用于本地微服务示例，不能用于跨节点通信。在生产环境时，我们往往会使用其他的服务注册发现组件，例如 etcd, polaris, zookeeper等，框架的社区组件中已经提供了常用的服务注册发现组件的实现。
其次，在该示例中，我们给Server设置了一个名字hello.svc，该名字表示该Server绑定的微服务的名称，服务名称作为微服务的唯一标识，用于服务间的识别通信。当服务注册组件注册启用时，HTTP Server在运行时将会把自己的访问地址注册到服务注册组件中，方便其他服务通过相同组件按照服务名称进行访问。
client.go
package main
import (
"time"
"github.com/gogf/gf/contrib/registry/file/v2"
"github.com/gogf/gf/v2/frame/g"
"github.com/gogf/gf/v2/net/gsvc"
"github.com/gogf/gf/v2/os/gctx"
"github.com/gogf/gf/v2/os/gfile"
)
func main() {
gsvc.SetRegistry(file.New(gfile.Temp("gsvc")))
client := g.Client()
for i := 0; i < 10; i++ {
ctx := gctx.New()
res, err := client.Get(ctx, `http://hello.svc/`)
if err != nil {
panic(err)
}
g.Log().Debug(ctx, res.ReadAllString())
res.Close()
time.Sleep(time.Second)
}
}
客户端通过g.Client()创建一个HTTP Client，并通过http://hello.svc/地址访问服务端，其中的hello.svc即先前的Server端绑定的微服务名称。当客户端通过微服务名称访问的时候，服务注册发现组件将会在底层进行检索，并找到对应的服务端地址进行通信。
执行结果
先执行server.go服务端运行一个简单的服务，随后再执行client.go通过服务名称请求服务。
执行后，客户端输出：
$ go run client.go
2023-03-14 20:22:10.006 [DEBU] {8054f3a48c484c1760fb416bb3df20a4} Hello world
2023-03-14 20:22:11.007 [DEBU] {6831cae08c484c1761fb416b9d4df851} Hello world
2023-03-14 20:22:12.008 [DEBU] {9035761c8d484c1762fb416b1e648b81} Hello world
2023-03-14 20:22:13.011 [DEBU] {a05a32588d484c1763fb416bc19ff667} Hello world
2023-03-14 20:22:14.012 [DEBU] {40fdea938d484c1764fb416b8459fc43} Hello world
2023-03-14 20:22:15.014 [DEBU] {686c9acf8d484c1765fb416b3697d369} Hello world
2023-03-14 20:22:16.015 [DEBU] {906a470b8e484c1766fb416b85b9867e} Hello world
2023-03-14 20:22:17.017 [DEBU] {28c7fd468e484c1767fb416b86e5557f} Hello world
2023-03-14 20:22:18.018 [DEBU] {90d2ad828e484c1768fb416bfcde738f} Hello world
2023-03-14 20:22:19.019 [DEBU] {d05559be8e484c1769fb416baad06f23} Hello world
服务端输出：
$ go run server.go
2023-03-14 20:20:06.364 [INFO] pid[96421]: http server started listening on [:61589]
2023-03-14 20:20:06.364 [INFO] openapi specification is disabled
2023-03-14 20:20:06.364 [DEBU] service register: &{Head: Deployment: Namespace: Name:hello.svc Version: Endpoints:10.35.12.81:61589 Metadata:map[insecure:true protocol:http]}
SERVER | DOMAIN | ADDRESS | METHOD | ROUTE | HANDLER | MIDDLEWARE
------------|---------|---------|--------|-------|-----------------------------------------------------------------|--------------------
hello.svc | default | :61589 | ALL | / | main.main.func1 |
------------|---------|---------|--------|-------|-----------------------------------------------------------------|--------------------
hello.svc | default | :61589 | ALL | /* | github.com/gogf/gf/v2/net/ghttp.internalMiddlewareServerTracing | GLOBAL MIDDLEWARE
------------|---------|---------|--------|-------|-----------------------------------------------------------------|--------------------
2023-03-14 20:22:10.006 [INFO] {8054f3a48c484c1760fb416bb3df20a4} request received
2023-03-14 20:22:11.007 [INFO] {6831cae08c484c1761fb416b9d4df851} request received
2023-03-14 20:22:12.008 [INFO] {9035761c8d484c1762fb416b1e648b81} request received
2023-03-14 20:22:13.010 [INFO] {a05a32588d484c1763fb416bc19ff667} request received
2023-03-14 20:22:14.012 [INFO] {40fdea938d484c1764fb416b8459fc43} request received
2023-03-14 20:22:15.013 [INFO] {686c9acf8d484c1765fb416b3697d369} request received
2023-03-14 20:22:16.015 [INFO] {906a470b8e484c1766fb416b85b9867e} request received
2023-03-14 20:22:17.016 [INFO] {28c7fd468e484c1767fb416b86e5557f} request received
2023-03-14 20:22:18.017 [INFO] {90d2ad828e484c1768fb416bfcde738f} request received
2023-03-14 20:22:19.019 [INFO] {d05559be8e484c1769fb416baad06f23} request received
GRPC微服务示例
https://github.com/gogf/gf/tree/master/example/rpc/grpcx/basic
helloworld.proto
grpc和http协议比较大的差异在于grpc需要通过protobuf来实现API接口以及数据结构的定义。
syntax = "proto3";
package protobuf;
option go_package = "github.com/gogf/gf/grpc/example/helloworld/protobuf";
// The greeting service definition.
service Greeter {
// Sends a greeting
rpc SayHello (HelloRequest) returns (HelloReply) {}
}
// The request message containing the user's name.
message HelloRequest {
string name = 1;
}
// The response message containing the greetings
message HelloReply {
string message = 1;
}
以上protobuf文件通过以下命令执行编译（请提前安装protoc工具）：
gf gen pb
将会生成对应的proto go数据结构文件以及grpc接口文件：
helloworld.pb.go helloworld_grpc.pb.go
controller.go
控制器用于实现proto中定义的接口方法（如果使用框架标准化工程目录结构，该控制器代码文件也是由框架的gf gen pb工具自动生成，开发者进需要填充对应方法的具体实现即可）：
type Controller struct {
protobuf.UnimplementedGreeterServer
}
func Register(s *grpcx.GrpcServer) {
protobuf.RegisterGreeterServer(s.Server, &Controller{})
}
// SayHello implements helloworld.GreeterServer
func (s *Controller) SayHello(ctx context.Context, in *protobuf.HelloRequest) (*protobuf.HelloReply, error) {
return &protobuf.HelloReply{Message: "Hello " + in.GetName()}, nil
}
config.yaml
服务端配置文件，在该配置文件中指定了该服务的名称为demo。微服务的名称用于服务间通信的唯一识别标识。在不显式配置服务端的监听端口时，服务端将会随机监听可用的本地端口。在微服务模式下，由于使用服务名称进行通信，服务端口往往不需要显式指定，随机监听即可。
grpc: name: "demo" logPath: "./log" logStdout: true errorLogEnabled: true accessLogEnabled: true errorStack: true
server.go
grpc服务端，在不显式指定服务端使用的服务注册发现组件时，服务端默认使用系统文件注册发现组件，该组件仅用于单机测试。其中的controller.Register即调用我们通过工具生成的控制器注册方法将具体的接口实现注册到服务端中。
package main
import (
"github.com/gogf/gf/contrib/rpc/grpcx/v2"
"github.com/gogf/gf/example/rpc/grpcx/basic/controller"
)
func main() {
s := grpcx.Server.New()
controller.Register(s)
s.Run()
}
client.go
grpc客户端，在创建连接时需要给定服务端服务的具体名称。这里的服务端服务名称为demo，指定的是上面提到的微服务名称。在不显式指定客户端使用的服务注册发现组件时，客户端默认使用系统文件注册发现组件，该组件仅用于单机测试。
package main
import (
"github.com/gogf/gf/contrib/rpc/grpcx/v2"
"github.com/gogf/gf/example/rpc/grpcx/basic/protobuf"
"github.com/gogf/gf/v2/frame/g"
"github.com/gogf/gf/v2/os/gctx"
)
func main() {
var (
ctx = gctx.New()
conn = grpcx.Client.MustNewGrpcClientConn("demo")
client = protobuf.NewGreeterClient(conn)
)
res, err := client.SayHello(ctx, &protobuf.HelloRequest{Name: "World"})
if err != nil {
g.Log().Error(ctx, err)
return
}
g.Log().Debug(ctx, "Response:", res.Message)
}
执行结果
服务端输出：可以看到，服务端输出了一下DEBU调试信息，用于显示一些服务注册的细节。同时，由于没有显式指定服务端的监听端口，这里随机监听了本地端口64517。
$ go run server.go
2023-03-14 20:50:58.465 [DEBU] set default registry using file registry as no custom registry set
2023-03-14 20:50:58.466 [DEBU] service register: &{Head: Deployment: Namespace: Name:demo Version: Endpoints:10.35.12.81:64517 Metadata:map[protocol:grpc]}
2023-03-14 20:50:58.466 [INFO] pid[98982]: grpc server started listening on [:64517]
2023-03-14 20:52:37.059 {9898c809364a4c17da79e47f3e6c3b8f} /protobuf.Greeter/SayHello, 0.003ms, name:"World", message:"Hello World"
客户端输出：客户端通过微服务名称访问，并接收到了服务端的返回。注意客户端的日志和服务端的日志中，链路跟踪的TraceID是相同的（9898c809364a4c17da79e47f3e6c3b8f），表示同一个请求产生的日志。GoFrame的微服务特性默认开启了链路跟踪能力。
$ go run client.go
2023-03-14 20:52:37.060 [DEBU] {9898c809364a4c17da79e47f3e6c3b8f} Response: Hello World
相关文档
- No labels
12 Comments
了人烟
强哥 少一个服务熔断限流的文档
朱华 Hunk
我也在找这个，现在这个功能有实现吗？
lowe
感觉上还是 goframe + dubbo-go 好用些
langbin
徐宪章
这部分完全看不懂，gf的实现与框架对Web服务、微服务的定义完全不一样。很那懂
徐宪章
不能说完全看不懂吧，是不知所谓。
郭强
这里只是写了简单的微服务注册和发现的实例，更详细的代码以及工程化管理请参考示例仓库 https://github.com/gogf/gf-demo-grpc
tobin
https://github.com/gogf/gf-demo-grpc/blob/main/api/pbentity/user.pb.go
func (x *User) GetId() uint32 {
if x != nil {
return x.Id
}
return 0
}
func (x *User) GetPassport() string {
if x != nil {
return x.Passport
}
return ""
}
这种又回到java那种啰嗦的大堆Get的视角
钟传华
如何使用gRPC-gateway来处理向后兼容的http请求？
agrozyme
之後有考慮整合 Buf 相關工具以及 Connect 嗎？
最近剛好有做一個三端串聯 (Client) ← http → (Proxy) ← gRPC → (Server) 的案子，目前 Client 跟 Proxy 之間的通訊搞定了，也寫了一些 Wrap Service Handler Function 給 GoFrame 的 Route 用～
不過因為 Buf 產出的 Code 有用到泛型，所以需要 Go 1.18+
下周會來搞 Proxy 跟 Server 間的通訊～
lin
这里我挺懵逼的，rpc client 居然不需要知道 rpc server 层的ip port，就可以请求成功了，有没有谁能告诉我，他们怎么进行服务发现的
tobin
示例用的是本地文件做注册中心
在该示例中使用的
file.New(gfile.Temp("gsvc"))是基于本地系统文件的服务注册发现组件，其中的gfile.Temp("gsvc")指定的是存放服务文件的路径，例如在Linux/MacOS系统下，指向的是/tmp/gsvc目录。基于文件系统的注册发现仅用于本地微服务示例，不能用于跨节点通信。在生产环境时，我们往往会使用其他的服务注册发现组件，例如etcd, polaris, zookeeper等，框架的社区组件中已经提供了常用的服务注册发现组件的实现