go zero入门

一、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服务请求

2.1 通过goctl生成api项目

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

go mod init order
touch order.api

结构如下

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

order.api的代码

syntax = "v2"

type (
    // 定义请求体
    OrderInfoReq {
        OrderId int64 'json:"order_id"' // 订单ID  
    }
    // 定义响应体
    OrderInfoResp {
        OrderId int64 'json:"order_id"' // 订单ID
        GoodsName string 'json:"goods_name"' // 商品名称
        Price int64 'json:"price"' // 商品价格
    }
)

// 定义 HTTP 服务
// 微服务名称为 order-api
service order-api {
    // 标记了订单信息查询接口的文档注释。
    @doc(
        summary: "获取订单信息"
    )
    // 指定处理该请求的处理器为orderInfo。
    @handler orderInfo
    // 定义接口
    // 请求方法是post，路径是/order/info，参数是OrderInfoReq，返回值是OrderInfoResp
    post /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方法，实现业务逻辑
在这里插入图片描述

func (l *OrderInfoLogic) OrderInfo(req *types.OrderInfoReq) (resp *types.OrderInfoResp, err error) {
	// todo: add your logic here and delete this line
	resp  = &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

type Config struct {
	rest.RestConf
	DataSourceName string
}

3.2 启动Gorm支持

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

package models

import (
	"gorm.io/gorm"
)

type Order struct {
	gorm.Model
	OrderId   int64   `gorm:"index:order_id"`
	GoodsName string  `gorm:"type:varchar(64)"`
	Price     float64 `gorm:"type:decimal(10,2);default:0"`
}

修改svc/servicecontext.go代码如下

package svc

import (
	"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文件实现业务逻辑

func (l *OrderRecordLogic) OrderRecord(req *types.OrderRecordReq) (resp *types.OrderRecordResp, err error) {
	// todo: add your logic here and delete this line
	order := 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服务来获取商品信息。

安装protoc
安装etcd

4.1 通过goctl生成rpc服务

在go-zero下新建目录goods

go mod init goods
touch goods.proto

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

goods.proto代码如下

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中实现业务逻辑

func (l *GetGoodsLogic) GetGoods(in *goods.GoodsRequest) (*goods.GoodsResponse, error) {
	// todo: add your logic here and delete this line
	resp := &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

Name: order-api
Host: 0.0.0.0
Port: 8888

DataSourceName: root:zxm123578@(127.0.0.1:3306)/MING_DB?charset=utf8

Etcd:
  Hosts:
  - 127.0.0.1:2379
  Key: goods.rpc

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

package config

import (
	"github.com/zeromicro/go-zero/rest"
	"github.com/zeromicro/go-zero/zrpc"
)

type Config struct {
	rest.RestConf
	DataSourceName string
	//定义rpc服务
	GoodsRpc zrpc.RpcClientConf
}

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

package svc

import (
	"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

func (l *OrderInfoLogic) OrderInfo(req *types.OrderInfoReq) (resp *types.OrderInfoResp, err error) {
	// todo: add your logic here and delete this line
	goodRequest := new(goods.GoodsRequest)
	goodRequest.GoodsId = req.OrderId
	goodsInfo, 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.mfbz.cn/a/778337.html

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

相关文章

String类对象比较：==和equals的具体细节

String类对象比较：==和equals的具体细节

public class test {public static void main(String[] args) {String name1 "zzz";String name2 "zzz";String name3 new String("zzz");// hashCode() 方法：基于字符串的内容计算哈希值，因此内容相同的字符串对象其 …
阅读更多...
macOS查看系统日志的方法

macOS查看系统日志的方法

1、command空格键打开搜索框，输入‘控制台’并打开 2、选择日志报告，根据日期打开自己需要的文件就可以
阅读更多...
ESP32——物联网小项目汇总

ESP32——物联网小项目汇总

商品级ESP32智能手表 [文章链接] 用ESP32，做了个siri？！开源了！ [文章链接]
阅读更多...
win11中配制了系统的环境变量mvn/java，但是mvn/java就是提示不存在的解决方法。

win11中配制了系统的环境变量mvn/java，但是mvn/java就是提示不存在的解决方法。

1、已经配制了环境变量，但是提示mvn不存在 2、然后我们在开始程序中查看到cmd，然后以管理员运行： 这样的话，是可以mvn这个命令的，而且只有这种方式是可以的，其它的方式，就算设置了以管理员身份运…
阅读更多...
Canary，三种优雅姿势绕过

Canary，三种优雅姿势绕过

Canary（金丝雀），栈溢出保护 canary保护是防止栈溢出的一种措施，其在调用函数时，在栈帧的上方放入一个随机值 ，绕过canary时首先需要泄漏这个随机值，然后再钩爪ROP链时将其作为垃圾数据写入&…
阅读更多...
编程上下文Context及其实现原理

编程上下文Context及其实现原理

编程上下文Context及其实现原理 author:shengfq date:2024-07-06 title:编程上下文Context及其实现原理 category:编程思想1.编程中的上下文Context是指什么? 在编程和软件工程领域，“上下文”（Context）是一个多义词，其含义可以…
阅读更多...
开始尝试从0写一个项目--后端（二）

开始尝试从0写一个项目--后端（二）

实现学生管理 新增学生 接口设计 请求路径：/admin/student 请求方法：POST 请求参数：请求头：Headers："Content-Type": "application/json" 请求体：Body： id 学生id …
阅读更多...
VideoAgent——使用大规模语言模型作为代理来理解长视频

VideoAgent——使用大规模语言模型作为代理来理解长视频

概述 论文地址：https://arxiv.org/pdf/2403.10517 本研究引入了一个新颖的基于代理的系统，名为 VideoAgent。该系统以大规模语言模型为核心，负责识别关键信息以回答问题和编辑视频。VideoAgent 在具有挑战性的 EgoSchema 和 NExT-QA 基准上进…
阅读更多...
MySQL架构和工作流程

MySQL架构和工作流程

引言：MySQL执行一条sql语句期间发生了什么？ 想要搞清楚这个问题，我们必须了解MySQL的体系结构和工作流程 一、MySQL体系结构 MySQL由以下几个部分组成 一、server层 1.MySQL Connnectors连接器，MySQL的连接池组件，…
阅读更多...
【vue组件库搭建05】vitePress中使用vue/antd/demo预览组件

【vue组件库搭建05】vitePress中使用vue/antd/demo预览组件

一、vitepress使用vue及antd组件 1.安装antd之后在docs\.vitepress\theme\index.ts引入文件 // https://vitepress.dev/guide/custom-theme import { h } from vue import type { Theme } from vitepress import DefaultTheme from vitepress/theme import ./style.css impor…
阅读更多...
React 19 竞态问题解决

React 19 竞态问题解决

竞态问题/竞态条件 指的是，当我们在交互过程中，由于各种原因导致同一个接口短时间之内连续发送请求，后发送的请求有可能先得到请求结果，从而导致数据渲染出现预期之外的错误。 因为防止重复执行可以有效的解决竞态问题&#xff0…
阅读更多...
试用笔记之-汇通Exe可执行文件之pe分析

试用笔记之-汇通Exe可执行文件之pe分析

首先下载汇通Exe可执行文件之pe分析 http://www.htsoft.com.cn/download/pedump.rar
阅读更多...
苹果笔记本能玩网页游戏吗 苹果电脑玩steam游戏怎么样 苹果手机可以玩游戏吗 mac电脑安装windows

苹果笔记本能玩网页游戏吗 苹果电脑玩steam游戏怎么样 苹果手机可以玩游戏吗 mac电脑安装windows

苹果笔记本有着优雅的机身、强大的性能，每次更新迭代都备受用户青睐。但是，当需要使用苹果笔记本进行游戏时，很多人会有疑问：苹果笔记本能玩网页游戏吗？苹果笔记本适合打游戏吗？本文将讨论这两个话题&#…
阅读更多...
数据集 | 人脸公开数据集的介绍及下载地址

数据集 | 人脸公开数据集的介绍及下载地址

本文介绍了人脸相关算法的数据集。 1.人脸数据集详情 1.1.Labeled Faces in the Wild (LFW) 论文 下载地址：LFW Face Database : Main (umass.edu) 是目前人脸识别的常用测试集，其中提供的人脸图片均来源于生活中的自然场景，因此识别难度会…
阅读更多...
Google Play上架：恶意软件、移动垃圾软件和行为透明度详细解析和解决办法 （一）

Google Play上架：恶意软件、移动垃圾软件和行为透明度详细解析和解决办法 （一）

近期整理了许多开发者的拒审邮件和内容，也发现了许多问题，今天来说一下关于恶意软件这类拒审的问题。 目标邮件如下： 首先说一下各位小伙伴留言私信的一个方法，提供你的拒审邮件和时间，尽可能的详细，这样会帮助我们的团队了解你们的问题，去帮助小伙伴么解决问题。由于前…
阅读更多...
【CUDA】 扫描 Scan

【CUDA】 扫描 Scan

Scan Scan操作是许多应用程序中常见的操作。扫描操作采用一个二元运算符⊕和一个输入数组并计算输出数组如下： [x0,(x0⊕x1),…,( x0⊕x1⊕…..⊕xn-1)] 分层扫描和多种Scan算法介绍 Kogge-Stones Algorithm Kogge-Stones Algorithm最初是为设计快速加法电路而发…
阅读更多...
【pytorch19】交叉熵

【pytorch19】交叉熵

分类问题的loss MSECross Entropy LossHinge Loss （SVN用的比较多） ∑ i m a x ( 0 , 1 − y i ∗ h θ ( x i ) ) \sum_imax(0,1-y_i*h_\theta(x_i)) ∑i​max(0,1−yi​∗hθ​(xi​)) Entropy（熵） Uncertainty（…
阅读更多...
解决obsidian加粗中文字体显示不突出的问题

解决obsidian加粗中文字体显示不突出的问题

加粗字体显示不突出的原因：默认字体的加粗版本本来就不突出 解决方法：改成显示突出的类型Microsoft YaHei UI 【效果】 修改前：修改后： 其他方法： 修改css（很麻烦，改半天也不一定奏效&#…
阅读更多...
容器：stack

容器：stack

以下是关于stack容器的一些总结： stack容器比较简单，主要包括： 1、构造函数：stack [staName] 2、添加、删除元素: push() 、pop() 3、获取栈顶元素：top() 4、获取栈的大小：size() 5、判断栈是否为空&#x…
阅读更多...
Codeforces Round 903 (Div. 3)A~F

Codeforces Round 903 (Div. 3)A~F

A.Dont Try to Count 输入样例： 12 1 5 a aaaaa 5 5 eforc force 2 5 ab ababa 3 5 aba ababa 4 3 babb bbb 5 1 aaaaa a 4 2 aabb ba 2 8 bk kbkbkbkb 12 2 fjdgmujlcont tf 2 2 aa aa 3 5 abb babba 1 19 m mmmmmmmmmmmmmmmmmmm输出样例： 3 1 2 -1 1 0…
阅读更多...
最新文章

Copyright @ 2022~2023