go zero入门

news/2024/10/5 13:06:54/

goctl_1">一、goctl安装

goctl 是 go-zero 的内置脚手架，可以一键生成代码、文档、部署 k8s yaml、dockerfile 等。

# Go 1.16 及以后版本
go install github.com/zeromicro/go-zero/tools/goctl@latest

检查是否安装成功

$ goctl -v
goctl version 1.6.6 darwin/amd64

vscode安装插件goctl

二、简单的http服务请求

goctlapi_17">2.1 通过goctl生成api项目

下面利用goctl实现一个单体服务，通过订单id获取订单信息（id、名称、价格）
在order目录下

go mod init order
touch order.api

结构如下

    go-zero└── order├── go.mod└── order.api

order.api的代码

go">syntax = "v2"type (// 定义请求体OrderInfoReq {OrderId int64 'json:"order_id"' // 订单ID  }// 定义响应体OrderInfoResp {OrderId int64 'json:"order_id"' // 订单IDGoodsName string 'json:"goods_name"' // 商品名称Price int64 'json:"price"' // 商品价格}
)// 定义 HTTP 服务
// 微服务名称为 order-api
service order-api {// 标记了订单信息查询接口的文档注释。@doc(summary: "获取订单信息")// 指定处理该请求的处理器为orderInfo。@handler orderInfo// 定义接口// 请求方法是post，路径是/order/info，参数是OrderInfoReq，返回值是OrderInfoResppost /oder/info (OrderInfoReq) returns (OrderInfoResp)
}

在当前目录下执行

$ goctl api go -api *.api -dir ./  --style=goZero    
Done.// 下载所需要的依赖
$ go mod tidy

该指令的作用是使用 goctl 工具生成 Go 语言的 API 代码项目

  • api go: 指定生成 Go 语言的 API 代码。
  • -api *.api: 指定输入的 API 描述文件，*.api 表示所有的 .api 文件，可以生成多个 API。
  • -dir ./: 指定输出目录为当前目录 (./)，生成的代码将会放置在当前目录中。
  • --style=goZero: 指定生成代码的风格为 goZero

当前目录生成的api项目结构如下

.
├── etc							// 配置文件
│   └── order-api.yaml
├── go.mod
├── internal
│   ├── config					// 配置对应的数据结构
│   │   └── config.go
│   ├── handler					// http部分的代码
│   │   ├── orderInfoHandler.go
│   │   └── routes.go
│   ├── logic					// 需要自己写的代码逻辑
│   │   └── orderInfoLogic.go
│   ├── svc						// 上下文相关依赖
│   │   └── serviceContext.go
│   └── types
│       └── types.go
├── order.api
└── order.go					// 启动代码

2.2 实现业务逻辑

根据路由追踪到OrderInfo方法，实现业务逻辑
在这里插入图片描述

go">func (l *OrderInfoLogic) OrderInfo(req *types.OrderInfoReq) (resp *types.OrderInfoResp, err error) {// todo: add your logic here and delete this lineresp  = &types.OrderInfoResp{OrderId: req.OrderId,GoodsName: "车",Price: 100000,}return resp, nil
}

2.3 执行

// 启动服务
$ go run order.go -f etc/order-api.yaml

etc/order-api.yaml文件定义了启动的端口号和ip

$ curl -X POST -H "Content-Type: application/json" http://localhost:8888/order/info -d '{"order_id":34}'{"order_id":34,"goods_name":"车","price":100000}%

三、集成Gorm

基于上面的基础，再增加一个功能：记录订单信息（id、名称、价格）到数据库

3.1 配置Gorm

在etc/order-api.yaml文件中配置参数DataSourceName

Name: order-api
Host: 0.0.0.0
Port: 8888
DataSourceName: root:zxm123578@(127.0.0.1:3306)/MING_DB?charset=utf8

在这里插入图片描述
在internal/config/config.go中添加DataSourceName

go">type Config struct {rest.RestConfDataSourceName string
}

3.2 启动Gorm支持

在internal目录下新建模型文件models\models.go

go">package modelsimport ("gorm.io/gorm"
)type Order struct {gorm.ModelOrderId   int64   `gorm:"index:order_id"`GoodsName string  `gorm:"type:varchar(64)"`Price     float64 `gorm:"type:decimal(10,2);default:0"`
}

修改svc/servicecontext.go代码如下

go">package svcimport ("order/internal/config""order/internal/models""gorm.io/driver/mysql""gorm.io/gorm""gorm.io/gorm/schema"
)type ServiceContext struct {Config config.Config// DbEngin 数据库引擎DbEngin *gorm.DB
}func NewServiceContext(c config.Config) *ServiceContext {// 启动Gorm支持db, err := gorm.Open(mysql.Open(c.DataSourceName), &gorm.Config{NamingStrategy: schema.NamingStrategy{TablePrefix:   "o_", // 表名前缀SingularTable: true, // 使用单数表名},})if err != nil {panic(err)}//自动同步更新表结构db.AutoMigrate(&models.Order{})return &ServiceContext{Config:  c,DbEngin: db,}
}

3.3 实现业务逻辑

在logic/orderRecordLogic.go文件实现业务逻辑

go">func (l *OrderRecordLogic) OrderRecord(req *types.OrderRecordReq) (resp *types.OrderRecordResp, err error) {// todo: add your logic here and delete this lineorder := models.Order{GoodsName: req.GoodsName,Price:     float64(req.Price),OrderId:   req.OrderId,}result := l.svcCtx.DbEngin.Create(&order)return &types.OrderRecordResp{OrderId: order.OrderId,}, result.Error
}

3.4 执行

先启动mysql，再启动服务

// 启动服务
$ go run order.go -f etc/order-api.yaml

$ curl -X POST -H "Content-Type: application/json" http://localhost:8888/order/record -d '{"order_id":34,"goods_name":"手机","price":5000}'{"order_id":34}%

四、通过api调用rpc服务

上面例子的商品名称是写死的，下面通过调用商品的rpc服务来获取商品信息。

go">安装protoc
安装etcd

goctlrpc_251">4.1 通过goctl生成rpc服务

在go-zero下新建目录goods

go mod init goods
touch goods.proto

    go-zero└── goods├── go.mod└── goods.proto└── order

goods.proto代码如下

go">syntax = "proto3";
package goods;
option go_package = "./goods";// 定义请求体
message GoodsRequest {int64 goods_id = 1;
}// 定义响应体
message GoodsResponse {int64 goods_id = 1;string goods_name = 2;double price = 3;
}service Goods {rpc GetGoods(GoodsRequest) returns (GoodsResponse);
}

在当前目录下使用goctl生成一个rpc项目

goctl rpc protoc *.proto --go_out=./types --go-grpc_out=./types --zrpc_out=.

.
├── etc
│   └── goods.yaml
├── go.mod
├── goods.go
├── goods.proto
├── goodsclient
│   └── goods.go
├── internal
│   ├── config
│   │   └── config.go
│   ├── logic
│   │   └── getgoodslogic.go
│   ├── server
│   │   └── goodsserver.go
│   └── svc
│       └── servicecontext.go
└── types└── goods├── goods.pb.go└── goods_grpc.pb.go

4.2 实现业务逻辑

在logic/getgoodslogic.go中实现业务逻辑

go">func (l *GetGoodsLogic) GetGoods(in *goods.GoodsRequest) (*goods.GoodsResponse, error) {// todo: add your logic here and delete this lineresp := &goods.GoodsResponse{GoodsId: in.GoodsId,GoodsName: "乐高",Price: 500,}return resp, nil
}

4.3 api调用rpc服务

不管是rpc之间的互相调用，还是api调用rpc，我们都需要知道rpc的proto文件。本文通过go work来实现

$ go work init order
$ go work use goods

接下来需要对order的api项目进行修改

1. 修改配置文件order/etc/order-api.yaml

go">Name: order-api
Host: 0.0.0.0
Port: 8888DataSourceName: root:zxm123578@(127.0.0.1:3306)/MING_DB?charset=utf8Etcd:Hosts:- 127.0.0.1:2379Key: goods.rpc

2. 修改order/internal/config/config.go文件

go">package configimport ("github.com/zeromicro/go-zero/rest""github.com/zeromicro/go-zero/zrpc"
)type Config struct {rest.RestConfDataSourceName string//定义rpc服务GoodsRpc zrpc.RpcClientConf
}

3. 修改order/internal/svc/serviceContext.go

go">package svcimport ("goods/goodsclient""order/internal/config""order/internal/models""github.com/zeromicro/go-zero/zrpc""gorm.io/driver/mysql""gorm.io/gorm""gorm.io/gorm/schema"
)type ServiceContext struct {Config config.Config// DbEngin 数据库引擎DbEngin *gorm.DB//定义rpc类型Goods goodsclient.Goods
}func NewServiceContext(c config.Config) *ServiceContext {// 启动Gorm支持db, err := gorm.Open(mysql.Open(c.DataSourceName), &gorm.Config{NamingStrategy: schema.NamingStrategy{TablePrefix:   "o_", // 表名前缀SingularTable: true, // 使用单数表名},})if err != nil {panic(err)}//自动同步更新表结构db.AutoMigrate(&models.Order{})return &ServiceContext{Config:  c,DbEngin: db,//引入gprc服务Goods: goodsclient.NewGoods(zrpc.MustNewClient(c.GoodsRpc)),}
}

4. 修改order/internal/logic/orderInfoLogic.go

go">func (l *OrderInfoLogic) OrderInfo(req *types.OrderInfoReq) (resp *types.OrderInfoResp, err error) {// todo: add your logic here and delete this linegoodRequest := new(goods.GoodsRequest)goodRequest.GoodsId = req.OrderIdgoodsInfo, err := l.svcCtx.Goods.GetGoods(l.ctx, goodRequest)if err != nil {return nil, err}resp = &types.OrderInfoResp{OrderId:   req.OrderId,GoodsName: goodsInfo.GoodsName,Price:     goodsInfo.Price,}return resp, nil
}

4.4 执行

依次启动mysqll、etcd 、rpc和api

$ mysql -u root -p

# goods目录下
$ etcd

# goods目录下
$ go run goods.go -f etc/goods.yaml

# order目录下
$ go run order.go -f etc/order.yaml

通过curl进行post请求，查看结果

$  curl -X POST -H "Content-Type: application/json" http://localhost:8888/order/info -d '{"order_id":34}' {"order_id":34,"goods_name":"乐高","price":500}%

http://www.ppmy.cn/news/1473767.html

相关文章

EtherCAT转Profinet网关配置说明第一讲：配置软件安装及介绍

EtherCAT转Profinet网关配置说明第一讲：配置软件安装及介绍

网关XD-ECPNS20为EtherCAT转Profinet协议网关，使EtherCAT协议和Profinet协议两种工业实时以太网网络之间双向传输 IO 数据。适用于具有EtherCAT协议网络与Profinet协议网络跨越网络界限进行数据交换的解决方案。 本网关通过上位机来进行配置。 首先安装上位机软件 一…
阅读更多...
Unity中使用VectorGraphics插件时，VectorUtils.RenderSpriteToTexture2D方法返回结果错误的解决方法

Unity中使用VectorGraphics插件时，VectorUtils.RenderSpriteToTexture2D方法返回结果错误的解决方法

Unity中使用VectorGraphics插件时，如果使用VectorUtils.BuildSprite方法创建Sprite，那么得到的Sprite往往是一个三角网格数比较多的Sprite，如果想要得到使用贴图只有两个三角面的方形Sprite，可以使用该插件提供的VectorUtils.Rend…
阅读更多...
A61 STM32_HAL库函数 之 TIM扩展驱动 -- C -- 所有函数的介绍及使用

A61 STM32_HAL库函数 之 TIM扩展驱动 -- C -- 所有函数的介绍及使用

A61 STM32_HAL库函数 之 TIM扩展驱动 -- C -- 所有函数的介绍及使用 1 该驱动函数预览1.24 HAL_TIMEx_OnePulseN_Stop1.25 HAL_TIMEx_OnePulseN_Start_IT1.26 HAL_TIMEx_OnePulseN_Stop_IT1.27 HAL_TIMEx_ConfigCommutationEvent1.28 HAL_TIMEx_ConfigCommutationEvent_IT1.29 …
阅读更多...
网络爬虫（二） 哔哩哔哩热榜高频词按照图片形状排列

网络爬虫（二） 哔哩哔哩热榜高频词按照图片形状排列

我们有时候需要爬取结果生成为自定义的词云图 生成自定义的词云图通常需要以下步骤： 1. 爬取数据：使用爬虫工具或库，如requests、BeautifulSoup等，可以爬取网页、论坛、社交媒体等平台上的文本数据。 2. 数据预处理&#xff1a…
阅读更多...
docker使用镜像jms_all部署jumpserver

docker使用镜像jms_all部署jumpserver

创建容器需要挂载出来的服务器对应目录 mkdir -p /data/redis/data mkdir -p /opt/mysql/{data,conf,logs}docker安装redis docker run -d -it --name redis -p 6379:6379 -v /data/redis/data:/data --restart=always
阅读更多...
深入刨析Redis存储技术设计艺术（二）

深入刨析Redis存储技术设计艺术（二）

三、Redis主存储 3.1、存储相关结构体 redisServer：服务器 server.h struct redisServer { /* General */ pid_t pid; /* Main process pid. */ pthread_t main_thread_id; /* Main thread id */ char *configfile; /* Absolut…
阅读更多...
CountDownLatch简介

CountDownLatch简介

引言 在多线程编程中，线程之间的协调和同步是一个常见的需求。Java 提供了多种工具来实现这一目标，其中 CountDownLatch 是一种简单而强大的同步机制。本文将详细介绍 CountDownLatch 的概念、使用方法和实际应用场景。 1. CountDownLatch 概述 Count…
阅读更多...
Python 函数递归

Python 函数递归

以下是一个使用递归计算阶乘的 Python 函数示例 ： 应用场景： 1. 动态规划问题：在一些需要逐步求解子问题并利用其结果的动态规划场景中，递归可以帮助直观地表达问题的分解和求解过程。 2. 遍历具有递归结构的数据：如递…
阅读更多...
最新文章

Copyright @ 2022~2023