golang微服务框架go-zero系列-1:适合创业的golang微服务框架go-zero + 金光灿灿的gorm V2实践
为什么使用go-zero
可以有第三个选择
- golang圈子不大,微服务框架框架屈指可数:除了go-micro、go-kit,几乎没有其他选择。go-zero为此提供第三个可能。
- go-micro 对webapi支持并不友好,需要运行micro指令,难以定制
创业产品需要一款支持业务成长的框架
我们到底需要什么样的框架?我们需要一款可以支持业务成长的框架!产品运营初期,比如需求验证阶段,我们并不需要采取微服务架构,因为运营成本太高。一款单体应用足以应付。随着业务发展,微服务成为必要,此时我们希望不进行太多的代码工作量,柔性升级。这正是go-zero价值所在
go-zero是什么
以下安利是copy的的,具体参考https://github.com/tal-tech/go-zero
go-zero是一个集成了各种工程实践的包含web和rpc框架,有如下主要特点:
- 强大的工具支持,尽可能少的代码编写
- 极简的接口
- 完全兼容net/http
- 支持中间件,方便扩展
- 高性能
- 面向故障编程,弹性设计
- 内建服务发现、负载均衡
- 内建限流、熔断、降载,且自动触发,自动恢复
- API参数自动校验
- 超时级联控制
- 自动缓存控制
- 链路跟踪、统计报警等
- 高并发支撑,稳定保障了晓黑板疫情期间每天的流量洪峰
怎么用
在阅读本文档前,请将golang 升级到go14
及以上版本,并开启go module支持,GO14以上只是为了支持Gorm
export GOPROXY=https://goproxy.io,direct
export GO111MODULE=on
安装goctl
goctl是go-zero配套的代码生成器,偷懒神器,毕竟写代码大多时间是体力活
如何安装呢?先把源代码下载下来吧!
git clone https://github.com/tal-tech/go-zero
cd go-zero/tools/goctl
go build goctl.go
最后生成goctl.exe 复制到$gopath/bin
下
goctl指令说明
自行浏览文档吧https://github.com/tal-tech/go-zero/blob/master/tools/goctl/goctl.md
本文用到指令如下
goctl api go -api open.api -dir .
#代码说明如下
goctl api go -api open.api -dir .| | | | | | | 生成api go语言 指定api模板文件 模板文件名称 指定生成代码存放路径 当前文件夹
创建项目
生成go.mod文件
以如下指令创建项目
mkdir hello
cd hello
go mod init hello
定义hello.api
本文设计API如下
描述 | 格式 | 方法 | 参数 | 返回 |
---|---|---|---|---|
用户注册 | /open/register | post | mobile:手机号,passwd:密码,code:图片验证码 | id:用户ID,token:用户token |
用户登录 | /open/authorization | post | mobile:手机号,passwd:密码,code:图片验证码 | id:用户ID,token:用户token |
图片验证码请求 | /open/verify | get | ticket:图片验证码的id | data:base64格式的图片 |
根据以上描述,书写api的模板文件如下
type (UserOptReq struct {mobile string `json:"mobile"`passwd string `json:"passwd"`code string `json:"code"`}UserOptResp struct {id uint `json:"id"`token string `json:"token"`}//图片验证码支持VerifyReq struct {ticket string `json:"ticket"`}//图片验证码支持VerifyResp struct {data string `json:"data"`}
)service open-api {@doc(summary: 公开的api函数desc: >register 用户注册,authorization 用户登录,verify 图片验证码接口)@server(handler: registerHandlerfolder: open)post /open/register(UserOptReq) returns(UserOptResp)@server(handler: authorizationHandlerfolder: open)post /open/authorization(UserOptReq) returns(UserOptResp)@server(handler: verifyHandlerfolder: open)post /open/verify(VerifyReq) returns(VerifyResp)}
注意
- 一个文件里面只能有一个service
- 工具最后会以type里面模型为样板生成各种结构体,所以参数和结构体保持一致即可
- 如果我们需要分文件夹管理业务, 可以用folder属性来定义
生成代码
采用如下指令生成代码
goctl api go -api open.api -dir .
最后代码结构如下
#tree /F /A
| go.mod
| go.sum
| hello.api
| open.go
|
+---etc
| open-api.yaml
|
\---internal+---config| config.go|+---handler| | routes.go| || \---open| authorizationhandler.go| registerhandler.go| verifyhandler.go|+---logic| \---open| authorizationlogic.go| registerlogic.go| verifylogic.go|+---svc| servicecontext.go|\---typestypes.go
运行一下
go run open.go
测试一下
curl http://127.0.0.1:8888/open/register -X POST -H "Content-Type: application/json" -d {\"mobile\":\"15367151352\",\"passwd\":\"testpwd\",\"code\":\"asdf\"}
{"id":0,"token":""}
集成明星产品Gorm V2
金珠大佬升级了Gorm V2集成测试一下吧
配置文件
配置文件在etc/open-api.yaml
Name: open-api
Host: 0.0.0.0
Port: 8888
DataSourceName: root:1D007648b4f8@(127.0.0.1:3306)/gozero?charset=utf8
在etc/open-api.yaml
中添加参数DataSourceName,
在internal/config/config.go
中添加DataSourceName
type Config struct {rest.RestConfDataSourceName string
}
关于配置文件,系统内置了一部分关键字 如Cache,资料不多;基本上可以随便配置,然后在Conf中定义同名变量即可。
启动Gorm支持
修改svc/servicecontext.go
代码如下
package svcimport ("hello/internal/config""hello/internal/models""gorm.io/driver/mysql""gorm.io/gorm""gorm.io/gorm/schema"
)type ServiceContext struct {Config config.ConfigDbEngin *gorm.DB
}func NewServiceContext(c config.Config) *ServiceContext {//启动Gorm支持db, err := gorm.Open(mysql.Open(c.DataSourceName), &gorm.Config{NamingStrategy: schema.NamingStrategy{TablePrefix: "tech_", // 表名前缀,`User` 的表名应该是 `t_users`SingularTable: true, // 使用单数表名,启用该选项,此时,`User` 的表名应该是 `t_user`},})//如果出错就GameOver了if err != nil {panic(err)}//自动同步更新表结构,不要建表了O(∩_∩)O哈哈~db.AutoMigrate(&models.User{})return &ServiceContext{Config: c, DbEngin: db}
}
新建模型文件
新建models\models.go
文件
//models\models.go文件
package modelsimport ("errors""hello/internal/utils""gorm.io/gorm"
)type User struct {gorm.ModelMobile string `gorm:"index:mobile;type:varchar(13)"`Passwd string `gorm:"type:varchar(64)"`
}
//在创建前检验验证一下密码的有效性
func (u *User) BeforeCreate(db *gorm.DB) error {if len(u.Passwd) < 6 {return errors.New("密码太简单了")}//对密码进行加密存储u.Passwd = utils.Password(u.Passwd)return nil
}
utils.Password是我们编写的工具包,代码如下
package utilsimport ("fmt""golang.org/x/crypto/bcrypt"
)//密码加密
func Password(plainpwd string) string {//谷歌的加密包hash, err := bcrypt.GenerateFromPassword([]byte(plainpwd), bcrypt.DefaultCost) //加密处理if err != nil {fmt.Println(err)}encodePWD := string(hash) // 保存在数据库的密码,虽然每次生成都不同,只需保存一份即可return encodePWD
}
//密码校验
func CheckPassword(plainpwd, cryptedpwd string) bool {err := bcrypt.CompareHashAndPassword([]byte(cryptedpwd), []byte(plainpwd)) //验证(对比)return err == nil
}
实现业务逻辑
在logic\open\registerlogic.go
中修改代码如下
package logicimport ("context""hello/internal/models""hello/internal/svc""hello/internal/types""github.com/tal-tech/go-zero/core/logx"
)type RegisterLogic struct {ctx context.Contextlogx.LoggersvcCtx *svc.ServiceContext
}func NewRegisterLogic(ctx context.Context, svcCtx *svc.ServiceContext) RegisterLogic {return RegisterLogic{ctx: ctx,Logger: logx.WithContext(ctx),svcCtx: svcCtx,}
}func (l *RegisterLogic) Register(req types.UserOptReq) (*types.UserOptResp, error) {user := models.User{Mobile: req.Mobile,Passwd: req.Passwd,}result := l.svcCtx.DbEngin.Create(&user)return &types.UserOptResp{Id: user.ID,}, result.Error
}
- RegisterLogic中添加svcCtx *svc.ServiceContext,因为需要用到里面的DbEngin
- NewRegisterLogic 配置svcCtx
- 在Register函数中实现逻辑
result := l.svcCtx.DbEngin.Create(&user)
测试一下
>curl http://127.0.0.1:8888/open/register -X POST -H "Content-Type: application/json" -d {\"mobile\":\"15367151352\",\"passwd\":\"testpwd\"}
{"id":3,"token":""}
期待更新的功能点
go-zero
接口定义希望支持多种content-type
UserOptReq struct {mobile string `json:"mobile" form:"mobile" xml:"mobile"`passwd string `json:"passwd" form:"passwd" xml:"passwd"`code string `json:"code" form:"code" xml:"code"`
}
一种可能的解决方法是
修改github.com/tal-tech/go-zero/rest/httpx/requests.go
中的Parse
成如下模型
func Parse(r *http.Request, v interface{}) error {if err := ParsePath(r, v); err != nil {return err}if strings.Contains(r.Header.Get(ContentType), multipartFormData) {return ParseForm(r, v)} else if strings.Contains(r.Header.Get(ContentType), urlencodeformdata) {return ParseForm(r, v)} else if strings.Contains(r.Header.Get(ContentType), applicationjson) {return ParseJsonBody(r, v)} else {return errors.New("不支持的请求类型")}
}
支持一个文件多个方法
比如如下写法,则生成俩个方法在verifyHandler.go文件中
@server(handler: verifyHandlerfolder: open)post /open/verify(VerifyReq) returns(VerifyResp)post /open/authorization(UserOptReq) returns(UserOptResp)
gorm v2
建议默认SingularTable
属性为true
NamingStrategy: schema.NamingStrategy{TablePrefix: "tech_", // 表名前缀,`User` 的表名应该是 `t_users`SingularTable: true, // 使用单数表名,启用该选项,此时,`User` 的表名应该是 `t_user`},
建议增强缓存功能
建议提供缓存如redis/memcache/内存缓存支持
本文代码获取
关注公众号betaidea
输入gozero或者gormv2即可获得
广而告之
送福利了uniapp用户福音来啦!
历经数十万用户考验,我们的客服系统终于对外提供服务了。
你还在为商城接入客服烦恼吗?只需一行代码,即可接入啦!!
只需一行代码!!!
/*kefu.vue*/
<template><view><IdeaKefu :siteid="siteId" ></IdeaKefu></view>
</template><script>import IdeaKefu from "@/components/idea-kefu/idea-kefu.vue"export default {components:{IdeaKefu},data() {return {siteId:2}}}
效果杠杠的
开发文档地址
http://kefu.techidea8.com/html/wiki/
golang微服务框架go-zero系列-1:适合创业的golang微服务框架go-zero + 金光灿灿的gorm V2实践相关推荐
- 《一步一步看源码:Nacos》框架源码系列之一(其1,配置服务源码)
Nacos源码 因为最近项目在做容器化处理,容器化后涉及到不同进程对同一个文件的读写,考虑到可能会存在同一文件的配置文件,可能会把彼此覆盖掉,所以这里学习一下Nacos源码. 整体结构图 这边 ...
- go web框架_golang微服务框架go-micro 入门笔记2.2 micro工具之微应用利器micro web
micro web micro 功能非常强大,本文将详细阐述micro web 命令行的功能 阅读本文前你可能需要进行如下知识储备 golang分布式微服务框架go-micro 入门笔记1:搭建go- ...
- ASP.NET CORE 微服务(简化版)实战系列-没有比这性价比再高的实战课程了
ASP.NET CORE 微服务(简化版)实战系列,最后1天298,现在注册购买再减50.作者jesse 腾飞在2.14 早上我买了他的课程后,他才做了下面这个活动: 作者jesse 腾飞花了大量的时 ...
- Spring Cloud入门系列(1)- Spring生态体系发展史+全系框架介绍
Spring发展史 2000年,Java EE和EJB迅速发展,很多知名公司都是采用此技术方案进行项目开发,但是EJB 属于重量级框架,开发繁琐.于是一个叫Rod Johnson的大佬写了一本叫做&l ...
- 【分布式系列】分布式事务:TX-LCN分布式事务框架整合实践
热门系列: [分布式系列]分布式锁原理篇-Redisson.Zookeeper.Database 程序人生,精彩抢先看 目录 1.前序 2.过程 2.1 TX-LCN框架介绍 2.2 环境搭建 2.2 ...
- 单体 soa 微服务 区别_漫谈何时从单体架构迁移到微服务?
面对微服务如火如荼的发展,很多人都在了解,学习希望能在自己的项目中帮得上忙,当你对微服务的庐山真面目有所了解后,接下来就是说服自己了,到底如何评估微服务,什么时候使用微服务,什么时间点最合适,需要哪些 ...
- 介绍6款热门的SpringCloud微服务开源项目,总有适合你的!
今天介绍六款比较热门的SpringCloud微服务项目,感兴趣的可以clone下来研究一下,相信对你学习微服务架构很有帮助. 一.Cloud-Platform 介绍 Cloud-Platform是国内 ...
- 当我们谈微服务,我们在谈什么?谈谈我对微服务的理解!
作者:fredal fredal.xin/talking-msa-understand-msa 阅读目录 微服务是什么 微服务是什么样的 服务化的前提 服务的发布与引用 服务的注册与发现 服务的远程通 ...
- 2020 年微服务领域开源数字化报告发布,阿里扛起微服务大旗
2020 年 8 月 18 日,由阿里云主办的首届云原生微服务大会于线上隆重召开,大会邀请25位全球顶级球微服务领域先行者和权威技术专家深入探讨云原生语境下,微服务的挑战和趋势. 国产微服务框架表现抢 ...
最新文章
- Android Studio Day02-2
- 科学解释超级计算机,超级计算机:彻底“改变”科学
- ping -c3 baidu.com ping过去是这样,代表网络畅通
- oauth过滤login_OAuth2AuthenticationProcessingFilter资源认证服务器过滤器
- 编程疑难杂症の怪诞的【黄色警告】
- SQLServer数据库如何收缩日志空间?
- python操作redis的set
- NetCore2.0Web应用之Startup
- python统计英文单词个数_python统计英文文本中的回文单词数
- (秒杀项目) 4.2 用户登录和注册
- 基于android的酒店客房预订客户端app
- 大一到研二我收藏了数百个网址,从中挑选了十五个最值得收藏的网址推荐给你
- el-cascader级联选择器当子节点的children为空数组的话,有bug(前端解决办法)
- MC9S12XS128nbsp;16位PWMnbsp;电…
- x64dbg 自带脚本系统
- VC浏览器相关的学习(六)(IDispEventImpl包装的主要方法)
- 如何用看板工具做轻量级项目管理
- 【Rust日报】2023-01-07 shura-一个安全的2D 游戏引擎,易于创建易于管理的游戏
- Android项目:手机安全卫士(6)—— 手机防盗设置向导
- CF645C Enduring Exodus 题解