GoZero微服务个人探索之路(三)Go-Zero官方rpc demo示例探究

这篇具有很好参考价值的文章主要介绍了GoZero微服务个人探索之路(三)Go-Zero官方rpc demo示例探究。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

官方网址:https://go-zero.dev/docs/tasks/cli/grpc-demo

项目结构

GoZero微服务个人探索之路(三)Go-Zero官方rpc demo示例探究,微服务,golang,rpc

demo包

两个文件均为protoc-gen-go-grpc自动生成
构成一个完整的 gRPC 服务的定义和实现

democlient包

demo.go goctl生成的客户端代码

GoZero微服务个人探索之路(三)Go-Zero官方rpc demo示例探究,微服务,golang,rpc

  • Request 和 Response 别名: 定义了 RequestResponse 两个别名,实际上是从 demo 包中导入的对应的消息类型。
  • Demo 接口: 定义了一个 Demo 接口,其中包含了调用 gRPC 服务中 Ping 方法的方法声明。
  • defaultDemo 结构体: 实现了 Demo 接口,包含一个 zrpc.Client 类型的字段,用于与 gRPC 服务建立连接。
  • NewDemo 函数: 用于创建并返回 Demo 接口的实例,需要传入一个 zrpc.Client 类型的参数,用于建立连接。
  • Ping 方法:Demo 接口中的实际方法,通过 defaultDemo 结构体的实例调用 gRPC 服务中的 Ping 方法。

etc包

demo.yaml

GoZero微服务个人探索之路(三)Go-Zero官方rpc demo示例探究,微服务,golang,rpc

  • Name:demo.rpc 服务名称
  • ListenOn:0.0.0.0:8080 指定服务监听的地址和端口
  • Mode:dev 服务运行在开发模式 (dev)

internal包

config/config.go

GoZero微服务个人探索之路(三)Go-Zero官方rpc demo示例探究,微服务,golang,rpc
zrpc结构体源码如下
GoZero微服务个人探索之路(三)Go-Zero官方rpc demo示例探究,微服务,golang,rpc

logic/pinglogic.go

GoZero微服务个人探索之路(三)Go-Zero官方rpc demo示例探究,微服务,golang,rpc

  • **PingLogic 结构体:**包含了处理 gRPC 请求的上下文、服务上下文以及日志记录器
  • NewPingLogic 函数: 创建并返回 PingLogic 结构体的实例,初始化了上下文和服务上下文,并通过 logx.WithContext 方法创建了与上下文关联的日志记录器
  • Ping 方法: 是处理 gRPC 请求的具体逻辑方法。接收一个 demo.Request 类型的参数 in,并返回一个 *demo.Response 类型和一个 error

server/demoserver.go 由goctl生成的grpc服务端代码

GoZero微服务个人探索之路(三)Go-Zero官方rpc demo示例探究,微服务,golang,rpc

  • 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

GoZero微服务个人探索之路(三)Go-Zero官方rpc demo示例探究,微服务,golang,rpc
创建返回svc结构体实例

demo.proto

GoZero微服务个人探索之路(三)Go-Zero官方rpc demo示例探究,微服务,golang,rpc
用于生成不同语言的gRPC代码

  • syntax = “proto3”;: 指定使用 protobuf 3 语法
  • package demo;: 指定生成的 Go 代码的包路径
  • option go_package=“./demo”;: 指定生成的 Go 代码的包路径
  • message Request: 定义了一个消息类型 Request,其中包含一个字符串字段 ping
  • message Response: 定义了一个消息类型 Response,其中包含一个字符串字段 pong
  • service Demo: 定义了一个服务接口 Demo,包含一个 Ping 方法,该方法接收 Request 消息作为参数,并返回 Response 消息

— string pong = 1; 不代表值为1,代表他的编号为1(protobuf语法

demo.go

GoZero微服务个人探索之路(三)Go-Zero官方rpc demo示例探究,微服务,golang,rpc

  • 加载配置文件: 使用 flag 包解析命令行参数,获取配置文件路径,并通过 conf.MustLoad 加载配置信息到结构体 c
  • 创建服务上下文: 使用 svc.NewServiceContext 创建服务上下文,将配置信息传递给服务上下文
  • 创建 gRPC 服务: 使用 zrpc.MustNewServer 创建 gRPC 服务,同时注册了 Demo 服务。如果是开发或测试模式,还注册了 gRPC 服务反射服务,以方便 gRPC 工具的使用
  • 启动 gRPC 服务: 使用 s.Start() 启动 gRPC 服务,监听指定的地址

启动

GoZero微服务个人探索之路(三)Go-Zero官方rpc demo示例探究,微服务,golang,rpc
GoZero微服务个人探索之路(三)Go-Zero官方rpc demo示例探究,微服务,golang,rpc文章来源地址https://www.toymoban.com/news/detail-801990.html

到了这里,关于GoZero微服务个人探索之路(三)Go-Zero官方rpc demo示例探究的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • go-zero的服务发现源码阅读

    服务发现原理与grpc源码解析_wangxiaoangg的博客-CSDN博客   go-zero rpc demo官方文档:rpc编写与调用 | go-zero 目录 一 服务注册 1. 创建rpc服务 2. 启动rpc服务 3. registerEtcd做了什么 4. discov.NewPublisher 服务发布者 二 服务发现 1.定义注册resolver 2.解析etcd地址创建链接 3.update方法 在看rp

    2024年02月06日
    浏览(46)
  • go-zero微服务实战——服务构建

    接上一节go-zero微服务实战——基本环境搭建。搭建好了微服务的基本环境,开始构建整个微服务体系了,将其他服务也搭建起来。 order的目录结构,如下 根目录 api服务 rpc服务 自定义逻辑层logic 自定义参数层models 自定义工具层util api服务和rpc服务都是基于goctl一键生成的,当

    2024年02月14日
    浏览(32)
  • go-zero的rpc服务案例解析

    go-zero的远程调用服务是基于gRpc的gRPC教程与应用。 zero使用使用gRpc需要安装 protoc 插件,因为gRpc基于protoc插件使用protocol buffers文件生成rpc服务器和api的代码的。 gRPC 的代码生成还依赖 protoc-gen-go,protoc-gen-go-grpc 插件来配合生成 Go 语言的 gRPC 代码。 也可以使用go get命令安装

    2024年02月13日
    浏览(65)
  • go-zero学习 第三章 微服务

    1.1 API服务模块 goctl 使用 api 文件生成 api服务 命令: 1.2 RPC服务模块 goctl 使用 protoc 文件生成 rpc服务 命令: 注意: --go_out 、 --go-grpc_out 、 --zrpc_out 三者配置的路径需要完全一致,否则会报下列错误。 基础代码:已生成基本的API服务、RPC服务。 这里以API服务调用RPC服务的登

    2024年02月16日
    浏览(60)
  • 【go-zero】go-zero阿里云oss 前端上传文件到go-zero API服务 并在k8s pod中创建文件 并推送到阿里云oss 最佳实践

    问题:在本地通过上传文件,然后将文件推送到aliyun的oss中,是没问题的 但是部署到了k8s中,则出现了问题,一直报错没有创建的权限 思路:开始认为应该将该文件挂载到configmap中,然后通过这种方式修改了deployment和dockerfile。最终发现应该是go的创建文件路径方式搞错了,

    2024年02月13日
    浏览(38)
  • GoZero微服务个人探究之路(零)个人对微服务产生原因的思考,对前三篇的补充

    这里我觉得看GoZero作者写的博文就可以有很好的体会 具体的,他画了这一张图(以电商后台系统为例子) 所以,我个人产生了如下思考 1.业务逻辑越来越复杂,层层嵌套,分解成微服务有两个好处,分解一个庞大的服务成细小的微服务,更利于程序员各司其职,职能划分,

    2024年01月16日
    浏览(45)
  • Go-Zero微服务快速入门和最佳实践(一)

    并发编程和分布式微服务 是我们Gopher升职加薪的关键。 毕竟Go基础很容易搞定,不管你是否有编程经验,都可以比较快速的入门Go语言进行简单项目的开发。 虽说好上手,但是想和别人拉开差距,提高自己的竞争力, 搞懂分布式微服务和并发编程还是灰常重要的,这也是我

    2024年04月28日
    浏览(33)
  • 微服务框架 go-zero logx 日志组件剖析

    上一篇我们说到咱们还剩下 addTenant 功能还未实现,不知道有没有兄弟感兴趣去实验一波的,本篇文章进行简要补充 根据上一篇文章分析,其实我们只需要执行如下几步即可: 编写 tenant.api,提供外部 addTenant 的 http 接口 编写 tenant.api 提供一个 POST http 的接口 / api /tenant/addt

    2024年02月11日
    浏览(39)
  • GoZero微服务个人探究之路(七)添加中间件、自定义中间件

    官方已经自己实现了很多中间件,我们可以方便的直接使用,不用重复造轮子了 开启方式可以看官方文档 中间件 | go-zero Documentation 在业务逻辑中,我们需要实现自定义功能的中间件 ------这里我们以实现跨源访问的中间件(详情可见这篇文章flutter开发web应用网络请求后台失

    2024年01月21日
    浏览(42)
  • 微服务架构|go-zero 的自适应熔断器

    原文链接: go-zero 的自适应熔断器 上篇文章我们介绍了微服务的限流,详细分析了计数器限流和令牌桶限流算法,这篇文章来说说熔断。 熔断和限流还不太一样,限流是控制请求速率,只要还能承受,那么都会处理,但熔断不是。 在一条调用链上,如果发现某个服务异常,

    2024年02月10日
    浏览(41)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包