go zero入门

news2024/11/18 14:36:00

一、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
│   │   ├── 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.coloradmin.cn/o/1896738.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

0/1背包问题总结

0/1背包问题总结

文章目录 🍇什么是0/1背包问题？🍈例题🍉1.分割等和子集🍉2.目标和🍉3.最后一块石头的重量Ⅱ 🍊总结 博客主页：lyyyyrics 🍇什么是0/1背包问题？ 0/1背包问题是…
阅读更多...
html三级菜单

html三级菜单

示例 <!DOCTYPE html> <html lang"en"> <head> <meta charset"UTF-8"> <meta name"viewport" content"widthdevice-width, initial-scale1.0"> <title>Menu Example</title> <link re…
阅读更多...
加速度传感器信号处理注意事项

加速度传感器信号处理注意事项

1 传感器分类 对于压电式压力传感器而言&#xff0c;输出信号是最重要的选择标准之一。压电式压力传感器与电子电路相连&#xff0c;电子电路将传感器产生的电荷成比例转换为电压。 如果选用外部设备&#xff08;电荷放大器&#xff09;充当电子元件&#xff0c;则称其为电…
阅读更多...
MYSQL篇二：数据库的操作

MYSQL篇二：数据库的操作

文章目录 1. 创建数据库1.1 查看数据库列表1.2 创建与删除数据库 2. 数据的编码问题3. 字符集和校验规则3.1 查看系统默认字符集以及校验规则3.2 查看数据库支持的字符集3.3 查看数据库支持的字符集校验规则3.4 校验规则对数据库的影响 4. 操纵数据库4.1 查看当前是哪一个数据库…
阅读更多...
力扣热100 滑动窗口

力扣热100 滑动窗口

这里写目录标题 3. 无重复字符的最长子串438. 找到字符串中所有字母异位词 3. 无重复字符的最长子串 左右指针left和right里面的字符串一直是没有重复的 class Solution:def lengthOfLongestSubstring(self, s: str) -> int:# 左右指针leftright0ans0#初始化结果tablecolle…
阅读更多...
LMT加仿真，十一届大唐杯全国总决赛

LMT加仿真，十一届大唐杯全国总决赛

这次省赛带了太多个省一了&#xff0c;并且很多都进入了国赛总决赛&#xff0c;具体可看下面的图片&#xff0c;只放了一部分。目前只有B组是只有一个商用设备赛也就是LMT&#xff0c;A组和高职组都是仿真实践赛加上商用设备赛。 针对商用设备赛有对应的资料&#xff…
阅读更多...
基于IIS的Windows系统Django项目本地部署

基于IIS的Windows系统Django项目本地部署

参考&#xff1a; 1. 基于Windows平台的Django本地部署和腾讯云服务器上部署&#xff08;1&#xff09;_如何在服务器上发布部署django程序 csdn-CSDN博客 2.Windows server iis部署Django详细操作 - Django中文 - 博客园 (cnblogs.com) 3.在IIS中部署pythonDjango项目时出…
阅读更多...
大模型范式下的知识检索增强实践（非常详细）零基础入门到精通，收藏这一篇就够了

大模型范式下的知识检索增强实践（非常详细）零基础入门到精通，收藏这一篇就够了

导读 OpenKG新开设“TOC专家谈”栏目&#xff0c;推送OpenKG TOC&#xff08;技术监督委员会&#xff09;专家成员的观点文章。本期邀请到阿里巴巴通义实验室自然语言处理方向负责人黄非研究员介绍通义大模型在知识检索增强方面的一些实践。 随着人工智能技术的飞速发展&…
阅读更多...
AI绘画 Stable Diffusion图像的脸部细节控制——采样器全解析

AI绘画 Stable Diffusion图像的脸部细节控制——采样器全解析

大家好&#xff0c;我是画画的小强 我们在运用AI绘画 Stable Diffusion 这一功能强大的AI绘图工具时&#xff0c;我们往往会发现自己对提示词的使用还不够充分。在这种情形下&#xff0c;我们应当如何调整自己的策略&#xff0c;以便更加精确、全面地塑造出理想的人物形象呢&a…
阅读更多...
数据特征采样在 MySQL 同步一致性校验中的实践

数据特征采样在 MySQL 同步一致性校验中的实践

作者&#xff1a;vivo 互联网存储研发团队 - Shang Yongxing 本文介绍了当前DTS应用中&#xff0c;MySQL数据同步使用到的数据一致性校验工具&#xff0c;并对它的实现思路进行分享。 一、背景 在 MySQL 的使用过程中&#xff0c;经常会因为如集群拆分、数据传输、数据聚合等…
阅读更多...
24_嵌入式系统输入输出设备

24_嵌入式系统输入输出设备

目录 GPIO原理与结构 A/D接口基本原理 A/D接口原理 A/D转换的重要指标 D/A接口基本原理 D/A接口原理 DAC的分类 D/A转换器的主要指标 键盘接口基本原理 键盘接口原理 用I/O口实现键盘接口 显示接口基本原理 基本结构和特点 基本原理 LCD种类 市面上出售的LCD的类…
阅读更多...
python怎么样将一段程序无效掉

python怎么样将一段程序无效掉

1、python中可以用注释屏蔽一段语句&#xff0c;具体方法如下&#xff0c;首先打开一段python的示例程序&#xff1a; 2、然后单行注释的方法是在语句前面加上#&#xff0c;程序运行后添加注释的地方的语句会被自动跳过&#xff0c;这里可以看到将打印变量a的语句添加注释就没有…
阅读更多...
STM32F1+HAL库+FreeTOTS学习5——内核中断管理及中断控制函数

STM32F1+HAL库+FreeTOTS学习5——内核中断管理及中断控制函数

STM32F1HAL库FreeTOTS学习5——中断管理和临界段代码保护 中断简介中断优先级寄存器拓展FreeRTOS中PendSV和Systick中断优先级配置三个中断屏蔽寄存器FreeRTOS中断管理函数代码验证 上一期我们学习了FreeRTOS中任务挂起与恢复&#xff0c;在中断服务程序中恢复任务过程中&#…
阅读更多...
利用谷歌云serverless代码托管服务Cloud Functions构建Gemini Pro API

利用谷歌云serverless代码托管服务Cloud Functions构建Gemini Pro API

谷歌在2024年4月发布了全新一代的多模态模型Gemini 1.5 Pro&#xff0c;Gemini 1.5 Pro不仅能够生成创意文本和代码&#xff0c;还能理解、总结上传的图片、视频和音频内容&#xff0c;并且支持高达100万tokens的上下文。在多个基准测试中表现优异&#xff0c;性能超越了ChatGP…
阅读更多...
竞赛选题 协同过滤电影推荐系统

竞赛选题 协同过滤电影推荐系统

文章目录 1 简介1 设计概要2 课题背景和目的3 协同过滤算法原理3.1 基于用户的协同过滤推荐算法实现原理3.1.1 步骤13.1.2 步骤23.1.3 步骤33.1.4 步骤4 4 系统实现4.1 开发环境4.2 系统功能描述4.3 系统数据流程4.3.1 用户端数据流程4.3.2 管理员端数据流程 4.4 系统功能设计 …
阅读更多...
【Proteus】按键的实现『⒉种』

【Proteus】按键的实现『⒉种』

&#x1f6a9; WRITE IN FRONT &#x1f6a9; &#x1f50e; 介绍&#xff1a;"謓泽"正在路上朝着"攻城狮"方向"前进四" &#x1f50e;&#x1f3c5; 荣誉&#xff1a;2021|2022年度博客之星物联网与嵌入式开发TOP5|TOP4、2021|2222年获评…
阅读更多...
13-错误-ERROR: duplicate key value violates unique constraint “ux_xxx“

13-错误-ERROR: duplicate key value violates unique constraint “ux_xxx“

13-错误-ERROR: duplicate key value violates unique constraint “ux_xxx” 更多内容欢迎关注我&#xff08;持续更新中&#xff0c;欢迎Star✨&#xff09; Github&#xff1a;CodeZeng1998/Java-Developer-Work-Note 技术公众号&#xff1a;CodeZeng1998&#xff08;纯纯…
阅读更多...
Vite: Bundler实现JavaScript的AST解析器—词法分析、语义分析

Vite: Bundler实现JavaScript的AST解析器—词法分析、语义分析

概述 基于前文&#xff0c;我们写了一个迷你版的 no-bundle 开发服务&#xff0c;也就是 Vite 开发阶段的 Dev Server&#xff0c;而在生产环境下面&#xff0c;处于页面性能的考虑&#xff0c;Vite 还是选择进行打包(bundle)&#xff0c;并且在底层使用 Rollup 来完成打包的过…
阅读更多...
liunx清理服务器内存和日志

liunx清理服务器内存和日志

1、查看服务器磁盘占用情况 # 查看磁盘占用大小 df -h 2、删除data文件夹下面的日志 3、查看每个服务下面的日志输出文件&#xff0c;过大就先停掉服务再删除out文件再重启服务 4、先进入想删除输入日志的服务文件夹下&#xff0c;查看服务进程&#xff0c;杀掉进程&#xff…
阅读更多...
【算法】（C语言）：二分查找

【算法】（C语言）：二分查找

二分查找&#xff1a; 获取查找区域的中间位置。若中间位置的数据就是要找的值&#xff0c;则返回true。若要找的值 小于 中间位置的数据&#xff0c;则往左边查找。若要找的值 大于 中间位置的数据&#xff0c;则往右边查找。重复1和2&#xff0c;若没有要找的值&#xff0c;…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023