Go单体服务开发最佳实践总结

目录
  • 单体最佳实践的由来
  • 单体示例
  • 单体实现
    • API 定义
    • Download 服务定义
    • Upload 服务定义
    • 问题来了
    • 定义单体服务接口
    • 生成单体服务
    • 实现业务逻辑
  • 单体开发的总结
  • 项目地址

单体最佳实践的由来

  • 对于很多初创公司来说,业务的早期我们更应该关注于业务价值的交付,并且此时用户体量也很小,QPS 也非常低,我们应该使用更简单的技术架构来加速业务价值的交付,此时单体的优势就体现出来了。
  • 正如我直播分享时经常提到,我们在使用单体快速交付业务价值的同时,也需要为业务的发展预留可能性,我们可以在单体里面清晰的拆分业务模块。
  • go-zero 社区里也有很多小伙伴在问,咱们单体开发的最佳实践应该是怎样的。

而 go-zero 作为一个被广泛使用的渐进式微服务框架来说,也是我在多个大型项目完整发展过程中沉淀出来的,自然我们也充分考虑了单体服务开发的场景。

如图所示的使用 go-zero 的单体架构,也可以支撑很大体量的业务规模,其中 Service 是单体服务的多个 Pod

我就通过本文详细跟大家分享一下如何使用 go-zero 快速开发一个有多个模块的单体服务。

单体示例

我们用一个上传下载的单体服务来讲解 go-zero 单体服务开发的最佳实践,为啥用这么个示例呢?

  • go-zero 社区里经常有同学会问上传文件怎么定义 API 文件,然后用 goctl 自动生成。初见此类问题会觉得比较奇怪,为啥不用 OSS 之类的服务呢?发现很多场景是用户需要上传一个excel,然后服务端解析完也就丢弃此文件了。一是文件较小,二是用户量也不大,就不用那么复杂的通过 OSS 来绕一圈了,我觉得也挺合理的。
  • go-zero 社区也有同学问下载文件怎么通过定义一个 API 文件然后 goctl 自动生成。此类问题之所以通过 Go 来做,问下来一般两个原因,一是业务刚开始,能简单点布一个服务搞定就一个吧;二是希望能吃上 go-zero 的内置 JWT 自动鉴权。

仅以此为示例,无需深入探讨上传下载是否应该通过 Go 来实现。那么接下来我们就看看我们怎么通过 go-zero 来解决这么一个单体服务,我们称之为文件(file)服务。架构如下图:

单体实现

API 定义

使用过 go-zero 的同学都知道,我们提供了一个 API 格式的文件来描述 RESTful API,然后可以通过 goctl 一键生成对应的代码,我们只需要在 logic 文件里填写对应的业务逻辑即可。我们就来看看 download 和 upload 服务怎么定义 API.

Download 服务定义

示例需求如下:

  • 通过 /static/<filename> 路径下载名为 <filename> 的文件
  • 直接返回文件内容即可

我们在 api 目录下创建一个名为 download.api 的文件,内容如下:

syntax = "v1"
type DownloadRequest {
  File string `path:"file"`
}
service file-api {
  @handler DownloadHandler
  get /static/:file(DownloadRequest)

zero-api 的语法还是比较能自解释的,含义如下:

  • syntax = “v1” 表示这是 zero-api 的 v1 语法
  • type DownloadRequest 定义了 Download 的请求格式
  • service file-api 定义了 Download 的请求路由

Upload 服务定义

示例需求如下:

  • 通过 /upload 路径上传文件
  • 通过 json 返回上传状态,其中的 code 可用于表达比 HTTP code 更丰富的场景

我们在 api 目录下创建一个名为 upload.api 的文件,内容如下:

syntax = "v1"
type UploadResponse {
  Code int `json:"code"`
}
service file-api {
  @handler UploadHandler
  post /upload returns (UploadResponse)
}

解释如下:

  • syntax = “v1” 表示这是 zero-api 的 v1 语法
  • type UploadResponse 定义了 Upload 的返回格式
  • service file-api 定义了 Upload 的请求路由

问题来了

Download 和 Upload 服务我们都定义好了,那怎么才能放到一个服务里给用户提供服务呢?

不知道细心的你有没注意到一些细节:

  • 不管是 Download 还是 Upload 我们在 request 和 response 数据定义的时候都加了前缀,并没有直接使用诸如 Request 或 Response 这样的
  • 我们在 download.api 和 upload.api 里面定义 service 的时候都是用的 file-api 这个 service name,并没有分别用 download-api 和 upload-api

这么做的目的其实就是为了我们接下来把这两个服务放到同一个单体里自动生成对应的 Go 代码。让我们来看看怎么把 Download 和 Upload 合并起来~

定义单体服务接口

出于简单考虑,goctl 只支持接受单一 API 文件作为参数,同时接受多个 API 文件的问题不在此讨论,如有简单高效的方案,后续可能支持。

我们在 api 目录下创建一个新的 file.api 的文件,内容如下:

syntax = "v1"
import "download.api"
import "upload.api"

这样我们就像 C/C++ 的 #include 一样把 Download 和 Upload 服务都导入进来了。但其中有几点需要注意的:

  • 定义的结构体不能重名
  • 所有文件里包含的 service name 必须是同一个

最外层的 API 文件也可以包含同一个 service 的部分定义,但我们推荐保持对称,除非这些 API 确实属于父层级,比如跟 Download 和 Upload 属于同一个逻辑层次,那么就不应该放到 file.api 里面定义。

至此,我们的文件结构如下:

.
└── api
    ├── download.api
    ├── file.api
    └── upload.api

生成单体服务

既然已经有了 API 接口定义,那么对于 go-zero 来说,接下来的事情就很简单直接了(当然,定义 API 也挺简单的,不是吗?),让我们来使用 goctl 生成单体服务代码。

$ goctl api go -api api/file.api -dir .

我们来看看生成后的文件结构:

.
├── api
│   ├── download.api
│   ├── file.api
│   └── upload.api
├── etc
│   └── file-api.yaml
├── file.go
├── go.mod
├── go.sum
└── internal
    ├── config
    │   └── config.go
    ├── handler
    │   ├── downloadhandler.go
    │   ├── routes.go
    │   └── uploadhandler.go
    ├── logic
    │   ├── downloadlogic.go
    │   └── uploadlogic.go
    ├── svc
    │   └── servicecontext.go
    └── types
        └── types.go

我们来按目录解释一下项目代码的构成:

  • api 目录:我们前面定义的 API 接口描述文件,无需多言
  • etc 目录:这个是用来放置 yaml 配置文件的,所有的配置项都可以写在 file-api.yaml 文件里
  • file.gomain 函数所在文件,文件名跟 service 同名,去掉了后缀 -api
  • internal/config 目录:服务的配置定义
  • internal/handler 目录:API 文件里定义的路由对应的 handler 实现
  • internal/logic 目录:用来放每个路由对应的业务处理逻辑,之所以区分 handler 和 logic 是为了让业务处理部分尽可能减少依赖,把 HTTP requests 和逻辑处理代码隔离开,便于后续按需拆分成 RPC service
  • internal/svc 目录:用来定义业务逻辑处理的依赖,我们可以在 main 里面创建依赖的资源,然后通过 ServiceContext 传递给 handler 和 logic
  • internal/types 目录:定义了 API 请求和返回数据结构

咱们什么也不改,先来跑一下看看效果。

$ go run file.go -f etc/file-api.yaml
Starting server at 0.0.0.0:8888...

实现业务逻辑

接下来我们需要实现相关的业务逻辑,但是这里的逻辑其实只是一个演示用途,无需过于关注实现细节,只需要理解我们应该把业务逻辑写在 logic 层即可。

这里一共做了以下几件事:

增加配置项里的 Path 设置,用来放置上传文件,默认值我写了当前目录,因为是示例,如下:

type Config struct {
  rest.RestConf
  // 新增
  Path string `json:",default=."`
}

调整了请求体的大小限制,如下:

Name: file-api
Host: localhost
Port: 8888
# 新增
MaxBytes: 1073741824

由于 Download 需要写文件给客户端,所以我们把 ResponseWriter 当成 io.Writer 传递给了 logic 层,修改后的代码如下:

func (l *DownloadLogic) Download(req *types.DownloadRequest) error {
  logx.Infof("download %s", req.File)
  body, err := ioutil.ReadFile(req.File)
  if err != nil {
    return err
  }
  n, err := l.writer.Write(body)
  if err != nil {
    return err
  }
  if n < len(body) {
    return io.ErrClosedPipe
  }
  return nil
}

由于 Upload 需要读取用户上传的文件,所以我们把 http.Request 传递给了 logic 层,修改后的代码如下:

func (l *UploadLogic) Upload() (resp *types.UploadResponse, err error) {
  l.r.ParseMultipartForm(maxFileSize)
  file, handler, err := l.r.FormFile("myFile")
  if err != nil {
    return nil, err
  }
  defer file.Close()
  logx.Infof("upload file: %+v, file size: %d, MIME header: %+v",
    handler.Filename, handler.Size, handler.Header)

  tempFile, err := os.Create(path.Join(l.svcCtx.Config.Path, handler.Filename))
  if err != nil {
    return nil, err
  }
  defer tempFile.Close()
  io.Copy(tempFile, file)
  return &types.UploadResponse{
    Code: 0,
  }, nil
}

完整代码:https://github.com/zeromicro/zero-examples/tree/main/monolithic

我们可以通过启动 file 单体服务:

$ go run file.go -f etc/file-api.yaml

可以通过 curl 来验证 Download 服务:

$ curl -i "http://localhost:8888/static/file.go"
HTTP/1.1 200 OK
Traceparent: 00-831431c47d162b4decfb6b30fb232556-dd3b383feb1f13a9-00
Date: Mon, 25 Apr 2022 01:50:58 GMT
Content-Length: 584
Content-Type: text/plain; charset=utf-8
...

示例仓库里包含了 upload.html,浏览器打开这个文件就可以尝试 Upload 服务了。

单体开发的总结

我把用 go-zero 开发单体服务的完整流程归纳如下:

  • 定义各个子模块的 API 文件,比如:download.api 和 upload.api
  • 定义总的 API 文件,比如:file.api。用来 import 步骤一定义的各个子模块的 API 文件
  • 通过 goctl api go 命令生成单体服务框架代码
  • 增加和调整配置,实现对应的子模块的业务逻辑

另外,goctl 可以根据 SQL 一键生成 CRUD 以及 cache 代码,可以帮助大家更快速的开发单体服务。

项目地址

https://github.com/zeromicro/go-zero

到此这篇关于Go单体服务开发最佳实践的文章就介绍到这了,更多相关go单体服务内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们!

(0)

相关推荐

  • go-micro使用Consul做服务发现的方法和原理解析

    目录 安装Consul 安装Consul插件 服务端使用Consul 服务注册 注册过程 健康检查 客户端使用Consul 调用服务 发现过程 效果展示 go-micro v4默认使用mdns做服务发现.不过也支持采用其它的服务发现中间件,因为多年来一直使用Consul做服务发现,为了方便和其它服务集成,所以还是选择了Consul.这篇文章将介绍go-micro使用Consul做服务发现的方法.关于Consul的使用方式请参考我的另一篇文章:搭建Consul服务发现与服务网格 . 安装Consu

  • Golang开发gRPC服务入门介绍

    目录 1.安装protoc 2.安装protoc的Golang gRPC插件 3.编写proto文件 4.生成gRPC代理代码 5.编写gRPC服务端程序 6.编写gRPC客户端程序 7.运行程序 gRPC是Google发起的一个开源RPC框架,使用HTTP/2传输协议,使用Protocol Buffers编码协议,相比RESTful框架的程序性能提高不少,而且当前流行的编程语言基本都已经支持. Golang开发gRPC应用程序的套路也已经很清晰,这篇文章就来做一个简单的介绍,算是入门. 1.安

  • golang中net的tcp服务使用

    目录 服务端监听端口 listen() 接受客户端的链接conn.Accept() 接收客户端发过来的数据newConn.Read() 获取客户端的IP地址newConn.RemoteAddr().String() 向客户端发送数据newConn.Write() 关闭客户端连接newConn.Close() 客户端连接tpc服务端 连接服务端net.Dial() 服务端监听端口 listen() 方法:net.listen({监听类型},{监听的ip和端口})(conn, err){} 返回值:

  • Go单体服务开发最佳实践总结

    目录 单体最佳实践的由来 单体示例 单体实现 API 定义 Download 服务定义 Upload 服务定义 问题来了 定义单体服务接口 生成单体服务 实现业务逻辑 单体开发的总结 项目地址 单体最佳实践的由来 对于很多初创公司来说,业务的早期我们更应该关注于业务价值的交付,并且此时用户体量也很小,QPS 也非常低,我们应该使用更简单的技术架构来加速业务价值的交付,此时单体的优势就体现出来了. 正如我直播分享时经常提到,我们在使用单体快速交付业务价值的同时,也需要为业务的发展预留可能性,我们可

  • 浅谈Spring Boot 开发REST接口最佳实践

    本文介绍了Spring Boot 开发REST接口最佳实践,分享给大家,具体如下: HTTP动词与SQL命令对应 GET 从服务器获取资源,可一个或者多个,对应SQL命令中的SELECT GET /users 获取服务器上的所有的用户信息 GET /users/ID 获取指定ID的用户信息 POST 在服务器上创建一个新资源,对应SQL命令中的CREATE POST /users 创建一个新的用户 PUT 在服务器上更新一个资源,客户端提供改变后的完整资源,对应SQL命令中的UPDATE PUT

  • Vue开发高德地图应用的最佳实践

    目录 前言 异步加载 封装组件 使用组件 自定义界面最佳实践 总结 前言 之前做不过不少关于地图交互的产品系统,目前国内主流的地图应用 SDK 只有几家:高德.百度和腾讯.所以个人觉得在 PC 应用上高德地图开发相对好一些,至少体验起来没有很明显的坑.这篇文章算是总结下开发地图应用总结吧. 异步加载 因为使用 js sdk 应用,脚本文件本身体积很大,所以要注意下加载的白屏时间,解决用户体验问题,目前绝大部分产品应用都是 SPA 单页面应用系统,所以我封装一个异步加载的方法: const loa

  • 基于AngularJS前端云组件最佳实践

    AngularJS是google设计和开发的一套前端开发框架,他能帮助开发人员更便捷地进行前端开发.AngularJS是为了克服HTML在构建应用上的不足而设计的,它非常全面且简单易学习,因此AngularJS快速的成为了javascript的主流框架. 一.Amazing的Angular AnguarJS的特性 方便的REST: RESTful逐渐成为了一种标准的服务器和客户端沟通的方式.你只需使用一行javascript代码,就可以快速的从服务器端得到数据.AugularJS将这些变成了JS

  • Java编程异常处理最佳实践【推荐】

    Java中的异常处理不是一个简单的话题.初学者很难理解,甚至有经验的开发人员也会花几个小时来讨论应该如何抛出或处理这些异常.这就是为什么大多数开发团队都有自己的异常处理的规则和方法.如果你是一个团队的新手,你可能会惊讶于这些方法与你之前使用过的那些方法有多么不同.常见的异常类型: NullPointerException -空指针引用异常 ClassCastException-类型强制转换异常 lllegalArgumentException-传递非法参数异常 ArithmeticExcepti

  • 浅谈Spring Batch在大型企业中的最佳实践

    在大型企业中,由于业务复杂.数据量大.数据格式不同.数据交互格式繁杂,并非所有的操作都能通过交互界面进行处理.而有一些操作需要定期读取大批量的数据,然后进行一系列的后续处理.这样的过程就是"批处理". 批处理应用通常有以下特点: 数据量大,从数万到数百万甚至上亿不等: 整个过程全部自动化,并预留一定接口进行自定义配置: 这样的应用通常是周期性运行,比如按日.周.月运行: 对数据处理的准确性要求高,并且需要容错机制.回滚机制.完善的日志监控等. 什么是Spring batch Sprin

  • .NET Core 2.1中HttpClientFactory的最佳实践记录

    前言 ASP.NET Core 2.1中出现一个新的HttpClientFactory功能, 它有助于解决开发人员在使用HttpClient实例从其应用程序发出外部Web请求时可能遇到的一些常见问题. 介绍 在.NETCore平台的2.1新增了HttpClientFactory,虽然HttpClient这个类实现了disposable,但使用它的时候用声明using包装块的方式通常不是最好的选择.处理HttpClient,底层socket套接字不会立即释放.该HttpClient类是专为多个请求

  • react后台系统最佳实践示例详解

    目录 一.中后台系统的技术栈选型 1. 要做什么 2. 要求 3. 技术栈怎么选 二.hooks时代状态管理库的选型 context redux recoil zustand MobX 三.hooks的使用问题与解决方案 总结 一.中后台系统的技术栈选型 本文主要讲三块内容:中后台系统的技术栈选型.hooks时代状态管理库的选型以及hooks的使用问题与解决方案. 1. 要做什么 我们的目标是搭建一个适用于公司内部中后台系统的前端项目最佳实践. 2. 要求 由于业务需求比较多,一名开发人员需要负

  • vue中使用Axios最佳实践方式

    目录 1.前言 2.使用 2.1安装 2.2基本用例 2.2.1 get请求 2.2.2post请求 3.配置 3.1语法 3.2别名 4.Axios实例 4.1语法 4.2请求配置 4.3响应的配置 配置的优先级 5.拦截器 6.错误拦截 7.取消请求 8.完整封装 建立http.ts文件编写clas Http类 9.总结 1.前言 最近在写vue3的项目,需要重新搭建脚手架并且使用网络请求接口,对于js的网络请求接口的一般有几种常用的方式: fetch XMLHttpRequests aja

  • jQuery最佳实践完整篇

    上周,我整理了<jQuery设计思想>. 那篇文章是一篇入门教程,从设计思想的角度,讲解"怎么使用jQuery".今天的文章则是更进一步,讲解"如何用好jQuery". 我主要参考了Addy Osmani的PPT<提高jQuery性能的诀窍>(jQuery Proven Performance Tips And Tricks).他是jQuery开发团队的成员,具有一定的权威性,提出的结论都有测试数据支持,非常有价值. ============

随机推荐