响应式网站开发支持ie6解决,做网站感想,苗圃网站模版,网站建设流量什么意思官方网址#xff1a;https://go-zero.dev/docs/tasks/cli/grpc-demo
项目结构 demo包
两个文件均为protoc-gen-go-grpc自动生成构成一个完整的 gRPC 服务的定义和实现
democlient包
demo.go goctl生成的客户端代码 Request 和 Response 别名#xff1a; 定义了 Request 和…官方网址https://go-zero.dev/docs/tasks/cli/grpc-demo
项目结构 demo包
两个文件均为protoc-gen-go-grpc自动生成构成一个完整的 gRPC 服务的定义和实现
democlient包
demo.go goctl生成的客户端代码 Request 和 Response 别名 定义了 Request 和 Response 两个别名实际上是从 demo 包中导入的对应的消息类型。Demo 接口 定义了一个 Demo 接口其中包含了调用 gRPC 服务中 Ping 方法的方法声明。defaultDemo 结构体 实现了 Demo 接口包含一个 zrpc.Client 类型的字段用于与 gRPC 服务建立连接。NewDemo 函数 用于创建并返回 Demo 接口的实例需要传入一个 zrpc.Client 类型的参数用于建立连接。Ping 方法 是 Demo 接口中的实际方法通过 defaultDemo 结构体的实例调用 gRPC 服务中的 Ping 方法。
etc包
demo.yaml Name:demo.rpc 服务名称ListenOn:0.0.0.0:8080 指定服务监听的地址和端口Mode:dev 服务运行在开发模式 (dev)
internal包
config/config.go
zrpc结构体源码如下
logic/pinglogic.go **PingLogic 结构体**包含了处理 gRPC 请求的上下文、服务上下文以及日志记录器NewPingLogic 函数 创建并返回 PingLogic 结构体的实例初始化了上下文和服务上下文并通过 logx.WithContext 方法创建了与上下文关联的日志记录器Ping 方法 是处理 gRPC 请求的具体逻辑方法。接收一个 demo.Request 类型的参数 in并返回一个 *demo.Response 类型和一个 error
server/demoserver.go 由goctl生成的grpc服务端代码 DemoServer 结构体 实现 demo.UnimplementedDemoServer 接口表示该结构体用于处理 gRPC 请求包含了一个 svcCtx 字段–指向 svc.ServiceContext 结构体的指针NewDemoServer 函数 用于创建并返回 DemoServer 结构体的实例Ping 方法 是 DemoServer 处理 gRPC 请求的具体方法。它接收一个上下文 ctx 和一个 demo.Request 类型的参数 in并返回一个 *demo.Response 类型和一个 error。在这个方法中它创建了一个 logic.NewPingLogic 实例然后调用了 l.Ping(in) 方法将请求交由具体的业务逻辑处理。
svc/servicecontext.go
创建返回svc结构体实例
demo.proto
用于生成不同语言的gRPC代码
syntax “proto3”; 指定使用 protobuf 3 语法package demo; 指定生成的 Go 代码的包路径option go_package“./demo”; 指定生成的 Go 代码的包路径message Request 定义了一个消息类型 Request其中包含一个字符串字段 pingmessage Response 定义了一个消息类型 Response其中包含一个字符串字段 pongservice Demo 定义了一个服务接口 Demo包含一个 Ping 方法该方法接收 Request 消息作为参数并返回 Response 消息
— string pong 1; 不代表值为1代表他的编号为1protobuf语法
demo.go 加载配置文件 使用 flag 包解析命令行参数获取配置文件路径并通过 conf.MustLoad 加载配置信息到结构体 c 中创建服务上下文 使用 svc.NewServiceContext 创建服务上下文将配置信息传递给服务上下文创建 gRPC 服务 使用 zrpc.MustNewServer 创建 gRPC 服务同时注册了 Demo 服务。如果是开发或测试模式还注册了 gRPC 服务反射服务以方便 gRPC 工具的使用启动 gRPC 服务 使用 s.Start() 启动 gRPC 服务监听指定的地址
启动
