使用go-zero快速构建微服务

本文是对 使用go-zero快速构建微服务[1]的亲手实践


编写API Gateway代码


mkdir bookstore && cd bookstore
go mod init bookstore

mkdir api && goctl api -o api/bookstore.api

syntax = "v1"

info(
    title: "xx使用go-zero"
    desc: "xx用来上手go-zero"
    author: "xxxx"
    email: "xxxx@gmail.com"
)

type (
    addReq struct {
        book string `form:"book"`
        price int64 `form:"price"`
    }

    addResp struct {
        ok bool `json:"ok"`
    }
)

type (
    checkReq struct {
        book string `form:"book"`
    }

    checkResp struct {
        found bool `json:"found"`
        price int64 `json:"price"`
    }
)


service bookstore-api {
    @handler AddHandler
    get /add (addReq) returns (addResp)

    @handler CheckHandler
    get /check (checkReq) returns (checkResp)
}

cd api && goctl api go -api bookstore.api -dir .

alt 
api
├── bookstore.api                  // api定义
├── bookstore.go                   // main入口定义
├── etc
│   └── bookstore-api.yaml         // 配置文件
└── internal
    ├── config
    │   └── config.go              // 定义配置
    ├── handler
    │   ├── addhandler.go          // 实现addHandler
    │   ├── checkhandler.go        // 实现checkHandler
    │   └── routes.go              // 定义路由处理
    ├── logic
    │   ├── addlogic.go            // 实现AddLogic
    │   └── checklogic.go          // 实现CheckLogic
    ├── svc
    │   └── servicecontext.go      // 定义ServiceContext
    └── types
        └── types.go               // 定义请求、返回结构体


go run bookstore.go -f etc/bookstore-api.yaml

启动API Gateway服务，默认侦听在8888端口

因为默认生成的api/etc/bookstore-api.yml为:

Name: bookstore-api
Host: 0.0.0.0
Port: 8888
alt

按提示下载，再次运行:

alt
alt 
{"@timestamp":"2023-02-16T16:31:09.658+08:00","caller":"stat/usage.go:61","content":"CPU: 0m, MEMORY: Alloc=2.5Mi, TotalAlloc=2.5Mi, Sys=14.5Mi, NumGC=0","level":"stat"}
{"@timestamp":"2023-02-16T16:31:09.662+08:00","caller":"load/sheddingstat.go:61","content":"(api) shedding_stat [1m], cpu: 0, total: 0, pass: 0, drop: 0","level":"stat"}
{"@timestamp":"2023-02-16T16:31:15.044+08:00","caller":"stat/metrics.go:210","content":"(bookstore-api) - qps: 0.0/s, drops: 0, avg time: 0.0ms, med: 0.0ms, 90th: 0.0ms, 99th: 0.0ms, 99.9th: 0.0ms","level":"stat"}

会定时(默认一分钟)输出cpu，内存等的统计信息，可以通过 logx.DisableStat()禁用 (可以做到自定义模板.tpl里)
alt

返回的是null，并不是预期的{"found":false,"price":0}

这是因为：

alt

resp是一个指针，这样直接return会是nil，需要如下显式声明

alt

重启服务，再次发起请求，这样的response就符合预期了~

alt

目前只返回了个空值，接下来会在rpc服务里实现业务逻辑

可以修改internal/svc/servicecontext.go来传递服务依赖（如果需要,比如Config，Auth，后续用到的RPC等）

实现逻辑可以修改internal/logic下的对应文件(如果接口较多，可以在.api里定义不同的group，使用goctl生成代码时，会自动在logic下根据group名称创建不同的文件夹)

可以通过goctl生成各种客户端语言的api调用代码(供客户端同学使用；支持多种语言)


编写RPC代码


编写add rpc服务


切到bookstore目录下

mkdir -p rpc/add && cd rpc/add

goctl rpc template -o add.proto

修改后文件内容如下：

syntax = "proto3";

package add;

option go_package = "./pb";

message addReq {
  string book = 1;
  int64 price = 2;
}

message addResp {
  bool ok = 1;
}

service adder {
  rpc add(addReq) returns(addResp);
}

goctl rpc protoc add.proto --go_out=./pb --go-grpc_out=./pb --zrpc_out=.

alt 
rpc/add
├── add.go                      // rpc服务main函数
├── add.proto                   // rpc接口定义
├── adder
│   ├── adder.go                // 提供了外部调用方法，无需修改
│   ├── adder_mock.go           // mock方法，测试用
│   └── types.go                // request/response结构体定义
├── etc
│   └── add.yaml                // 配置文件
├── internal
│   ├── config
│   │   └── config.go           // 配置定义
│   ├── logic
│   │   └── addlogic.go         // add业务逻辑在这里实现
│   ├── server
│   │   └── adderserver.go      // 调用入口, 不需要修改
│   └── svc
│       └── servicecontext.go   // 定义ServiceContext，传递依赖
└── pb
    └── add.pb.go

go run add.go -f etc/add.yaml 可运行该服务

默认每隔一分钟输出cpu和内存信息

{"@timestamp":"2023-02-16T20:02:10.640+08:00","caller":"stat/usage.go:61","content":"CPU: 0m, MEMORY: Alloc=3.3Mi, TotalAlloc=6.2Mi, Sys=15.9Mi, NumGC=3","level":"stat"}
{"@timestamp":"2023-02-16T20:02:10.656+08:00","caller":"load/sheddingstat.go:61","content":"(rpc) shedding_stat [1m], cpu: 0, total: 0, pass: 0, drop: 0","level":"stat"}

编写check rpc服务

切到bookstore目录下

mkdir -p rpc/check && cd rpc/check

goctl rpc template -o check.proto

修改后文件内容如下：

syntax = "proto3";

package check;

option go_package = "./pb";

message checkReq {
  string book = 1;
}

message checkResp {
  bool found = 1;
  int64 price = 2;
}

service checker {
  rpc check(checkReq) returns(checkResp);
}

goctl rpc protoc check.proto --go_out=./pb --go-grpc_out=./pb --zrpc_out=.

alt 
rpc/check
├── check.go                    // rpc服务main函数
├── check.proto                 // rpc接口定义
├── checker
│   ├── checker.go              // 提供了外部调用方法，无需修改
│   ├── checker_mock.go         // mock方法，测试用
│   └── types.go                // request/response结构体定义
├── etc
│   └── check.yaml              // 配置文件
├── internal
│   ├── config
│   │   └── config.go           // 配置定义
│   ├── logic
│   │   └── checklogic.go       // check业务逻辑在这里实现
│   ├── server
│   │   └── checkerserver.go    // 调用入口, 不需要修改
│   └── svc
│       └── servicecontext.go   // 定义ServiceContext，传递依赖
└── pb
    └── check.pb.go

go run check.go -f etc/check.yaml 可运行该服务

修改etc/check.yaml的端口为8081（因为8080已经被add服务使用了）


再回去修改API Gateway代码，调用add/check rpc服务


api/etc/bookstore-api.yaml，增加如下内容

Add:
  Etcd:
    Hosts:
      - localhost:2379
    Key: add.rpc
Check:
  Etcd:
    Hosts:
      - localhost:2379
    Key: check.rpc

通过etcd自动去发现可用的add和check服务

alt

修改api/internal/config/config.go如下，增加add&check服务依赖

alt

修改api/internal/svc/servicecontext.go，如下：

alt

通过ServiceContext在不同业务逻辑之间传递依赖

(问：怎么解决依赖注入问题)


修改api/internal/logic/addlogic.go里的Add方法，如下：

alt alt

通过调用adder的Add方法实现添加图书到bookstore系统


修改api/internal/logic/checklogic.go里的Check方法，如下：

alt

通过调用checker的Check方法实现从bookstore系统中查询图书的价格


定义数据库表结构，并生成CRUD+cache代码


bookstore下创建rpc/model目录

mkdir -p rpc/model （不过一般习惯把这个model文件夹抽出来，和api，rpc在一层）

在rpc/model目录下编写创建book表的sql文件book.sql，如下：

CREATE TABLE `book`
(
  `book` varchar(255) NOT NULL COMMENT 'book name',
  `price` int NOT NULL COMMENT 'book price',
  PRIMARY KEY(`book`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

进入mysql命令行，创建DB和table

create database gozero;
source book.sql;

在rpc/model目录下执行如下命令生成CRUD+cache代码，-c表示使用redis cache

goctl model mysql ddl -c -src book.sql -dir .

alt

修改add rpc和check rpc，调用crud+cache代码


修改rpc/add/etc/add.yaml和rpc/check/etc/check.yaml，均增加如下内容：

DataSource: root:123456@@tcp(xxx.xxx.xx.xx:3306)/gozero
#DataSource: root:123456@@tcp(localhost:3306)/gozero?charset=utf8mb4&parseTime=true&loc=Asia%2FShanghai #可以这样指定一些其他信息
Table: book
Cache:
  - Host: localhost:6379

alt

可以使用多个redis作为cache，支持redis单点或者redis集群


修改rpc/add/internal/config.go和rpc/check/internal/config.go，如下：

alt
alt

修改rpc/add/internal/svc/servicecontext.go和rpc/check/internal/svc/servicecontext.go，如下：

alt
alt

修改rpc/add/internal/logic/addlogic.go，如下

alt
alt

修改rpc/check/internal/logic/checklogic.go，如下：

alt

项目使用


需要先全部启动api服务所依赖的rpc服务。如果先启动api，则会报错：

error: context deadline exceeded, make sure rpc service "add.rpc" is already started

全部启动：

alt
alt
alt

(后面可以 -f指定不同环境的xxx.yaml)

调用add api,新增图书

curl -i "http://localhost:8888/add?book=Bible&price=10"

alt

此时看数据库，book表里新增了一行数据


调用check api,检查某本图书的价格

curl -i "http://localhost:8888/check?book=Bible"

alt
alt

重启check rpc，再次执行curl -i "http://localhost:8888/check?book=Bible"

alt

完整项目代码[2]

参考资料

[1]

使用go-zero快速构建微服务: http://www.jikejiaocheng.com/c/gozero-microservices.html

 [2]

完整项目代码: https://github.com/cuishuang/bookstore

本文由 mdnice 多平台发布

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：/a/64596.html

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

Visual Studio配置PCL库

Visual Studio配置PCL库

Visual Studio配置PCL库 Debug和Release配置新建项目配置属性表测试参考 Debug和Release Debug和Release的配置过程一模一样，唯一区别就在于最后一步插入的附加依赖项不同，因此下面以debug为例。 配置新建项目 1、新建一个C空项目，模式设置…
阅读更多...
SQL分类及通用语法数据类型（超详细版）

SQL分类及通用语法数据类型（超详细版）

一、SQL分类 SQL是结构化查询语言（Structured Query Language）的缩写。它是一种用于管理和操作关系型数据库系统的标准化语言。SQL分类如下： DDL: 数据定义语言，用来定义数据库对象（数据库、表、字段）DML:…
阅读更多...
16-2_Qt 5.9 C++开发指南_使用样式表Qss自定义界面

16-2_Qt 5.9 C++开发指南_使用样式表Qss自定义界面

进行本篇介绍学习前，请先参考链接01_1_Qt工程实践_Qt样式表Qss，后再结合本篇进行融合学习如何使用样式表定义界面。 文章目录 1. Qt样式表2. Qt样式表句法2.1 一般句法格式2.2 选择器 (selector)2.3 子控件（sub-controls）2.4 伪状…
阅读更多...
UE5.2 LyraDemo源码阅读笔记（四）

UE5.2 LyraDemo源码阅读笔记（四）

上一篇（三）讲到在模式玩法UI点击Elimination进入淘汰赛模式。 UI选择点击Elimination后，触发蓝图W_HostSessionScreen的HostSession节点，有： 调用这个方法切换关卡后，会调用到LyraGameMode.cpp的 ALyraGam…
阅读更多...
【Gitee的使用】Gitee的简单使用，查看/创建SSH公匙、创建版本库、拉取代码、提交代码

【Gitee的使用】Gitee的简单使用，查看/创建SSH公匙、创建版本库、拉取代码、提交代码

推荐阅读 CSDN主页GitHub开源地址Unity3D插件分享简书地址我的个人博客 大家好，我是佛系工程师☆恬静的小魔龙☆，不定时更新Unity开发技巧，觉得有用记得一键三连哦。 一、前言 本篇文章简单介绍，如何在Gitee上面创建版本库、拉取…
阅读更多...
Zookeeper基础操作

Zookeeper基础操作

搭建Zookeeper服务器 windows下部署 下载地址: https://mirrors.cloud.tencent.com/apache/zookeeper/zookeeper-3.7.1/ 修改配置文件 打开conf目录，将 zoo_sample.cfg复制一份，命名为 zoo.cfg打开 zoo.cfg，修改 dataDir路径&#xff0c…
阅读更多...
2023最新性能测试面试题（带答案）

2023最新性能测试面试题（带答案）

一、性能测试开展过程： 答：第一步：找产品沟通哪些接口需要压测，需要达到什么样的预期值(TPS和响应时间) 第二步：编写测试计划，人员、时间周期、工具 第三步：环境搭建 第四步：造数…
阅读更多...
产品缺陷管理软件：了解功能与选择要点

产品缺陷管理软件：了解功能与选择要点

在现代社会，产品缺陷管理软件已经成为了各个行业必不可少的工具。它可以帮助企业更好地管理和解决产品中存在的缺陷问题，提高产品质量和客户满意度。然而，市场上存在着众多的产品缺陷管理软件，如何选择一款好用、适合自己的软件成…
阅读更多...
山东气象 × 和鲸科技：第一届齐鲁风云气象智能算法挑战赛圆满收官

山东气象 × 和鲸科技：第一届齐鲁风云气象智能算法挑战赛圆满收官

7 月 20 日，中国气象局印发《人工智能气象应用工作方案（2023 - 2030年）》，旨在加快布局国产人工智能气象应用技术体系建设，推动人工智能技术在气象观测、预报及服务中的深度融合应用，为监测精密、预报精准、…
阅读更多...
word转pdf怎么转？几种常用方法分享

word转pdf怎么转？几种常用方法分享

word转pdf怎么转？在日常工作和学习中，将Word文档转换为PDF格式是一项必要的任务。不仅可以保证文档的格式不变，还可以防止文档被他人篡改。但是，Word文档并不是所有人都能够轻松打开和编辑的，而PDF文件则可以在各种设备…
阅读更多...
【vue3】vue3和vue2的区别:

【vue3】vue3和vue2的区别:

文章目录 Vue3框架的优点特点:一、生命周期:二、组合式api（Composition API）三、setup函数四、响应式原理1. 原理2. Object.defineProperty的缺陷3.proxy的优势 五、reactive函数和ref函数1. reactive函数》通常使用它复杂类型的响应式数据2. ref函数》使…
阅读更多...
Postman如何做接口测试

Postman如何做接口测试

目录 Postman如何做接口测试1：如何导入 swagger 接口文档 Postman如何做接口测试2：如何切换测试环境 Postman如何做接口测试3：什么？postman 还可以做压力测试？ Postman如何做接口测试4：如何自动添加请求…
阅读更多...
【TypeScript】安装的坑！

【TypeScript】安装的坑！

TypeScript安装 安装TypeScript安装时候可能报错这样开头的数据（无法枚举容器中的对象）——原因：没权限先解决没权限的问题如果发现无法修改-高级-修改继续安装想使用tsc-发现，tsc不能用解决方法：配置环境变量最后的最…
阅读更多...
IDEA的实用快捷键大全

IDEA的实用快捷键大全

目录 1.常规快捷键 1.1通用类 1.2注释类 1.3操作类 1.4展开与关闭 2.智能补全类快捷键 3.程序结构类快捷键 4.统一操作快捷键 1.常规快捷键 1.1通用类 像 Ctrl C 复制， Ctrl V 粘贴， Ctrl S保存文件， Ctrl X剪切，这种…
阅读更多...
【VUE】项目本地开启https访问模式(vite4)

【VUE】项目本地开启https访问模式(vite4)

在实际开发中，有时候需要项目以https形式进行页面访问/调试，下面介绍下非vue-cli创建的vue项目如何开启https 环境 vue: ^3.2.47vite: ^4.1.4 根据官方文档：开发服务器选项 | Vite 官方中文文档 ps：首次操作，不要被类…
阅读更多...
flutter开发实战-flutter_spinkit实现多种风格进度指示器

flutter开发实战-flutter_spinkit实现多种风格进度指示器

flutter开发实战-flutter_spinkit实现多种风格进度指示器 最近开发过程中flutter_spinkit，这个拥有多种种风格加载指示器 一、flutter_spinkit 引入flutter_spinkit # 多种风格的模糊进度指示器flutter_spinkit: ^5.1.0效果示例 const spinkit SpinKitRotatingC…
阅读更多...
【网络基础实战之路】基于OSPF协议建立两个MGRE网络的实验详解

【网络基础实战之路】基于OSPF协议建立两个MGRE网络的实验详解

系列文章传送门： 【网络基础实战之路】设计网络划分的实战详解 【网络基础实战之路】一文弄懂TCP的三次握手与四次断开 【网络基础实战之路】基于MGRE多点协议的实战详解 【网络基础实战之路】基于OSPF协议建立两个MGRE网络的实验详解 PS：本要求基于…
阅读更多...
案例：Docker 镜像的创建及使用（commit与dockerfile方式）

案例：Docker 镜像的创建及使用（commit与dockerfile方式）

文章目录 1、commit方式创建镜像1.1、前期准备1.2、制成镜像1.3、启动镜像1.3.1、启动镜像启动nginx1.3.2、一个命令直接全部启动1.3.3、两种方式区别 1.4、commit创建镜像方式的本质 2、Dockerfile的使用2.1、Dockerfile指令2.2、nginx镜像制作案例2.3、查看构建历史&#xff…
阅读更多...
C高级【day4】

C高级【day4】

思维导图： 写一个函数，获取用户的uid和gid并使用变量接收： #!/bin/bashfunction get_uid {my_uidid -umy_gidid -g }get_uid echo "当前用户的UID：$my_uid" echo "当前用户的GID：$my_gid"整理冒泡…
阅读更多...
Object Map 的相互转换

Object Map 的相互转换

学生业务对象定义&#xff1a;Student Student student new Student(); student.setId(1L); student.setName("令狐冲") student.setAge(10) 第一种&#xff1a;通过Alibaba Fastjson实现 pom.xml 文件依赖 <dependency><groupId>com.alibaba</g…
阅读更多...
最新文章

Copyright @ 2022~2023