1 Gorm

对于GORm的详细学习可以看我的上一篇文章juejin.cn/post/726516…

Gorm是一个已经迭代了10年+的功能强大的ORM框架，拥有丰富的开源扩展。

Gorm的约定（默认）

Gorm使用名ID的字段作为主键

使用结构体的蛇形负数作为表名

字段名的蛇形作为列名

使用CreateAt、UpdatedAt字段作为创建、更新时间。

GORM目前支持MySQL、SQLServer、PostgreSQL、SQLite。

连接SQLServer数据库为例：

import(
    "gorm.io/driver/sqlserver"
    "gorm.io/gorm"
)
    //github.com/denisenkom/go-mssqldb
    dsn := "sqlserver://gorm:LoremIpsum@localhost:9930?database=gorm"
    db,err := gorm.Open(sqlserver.Open(dsn),&gorm.Config{})

GORM通过驱动来连接数据库，如果需要连接其他类型的数据库，可以复用/自行开发驱动。

1.1 GORM创建数据

使用clause.OnConflict处理数据冲突

    p := &Product{Code: "D42", ID: 1}
    db.Clauses(clause.OnConflict{DoNothing: true}).Create(&p)

使用默认值：通过使用default标签为字段定义默认值

type User struct{
    ID    int64
    Name  string 'gorm:"default:galeone"'
    Age   int64  'gorm:"default:18"'
}

1.2 GORM查询数据

First使用时，需要注意查询不到数据会返回ErrRecordNotFound。

使用Find查询多条数据时，查询不到数据不会返回错误。

当使用结构体作为条件查询时，GORM只会查询非零字段。这意味着如果您的字段值为0、”、false或其他零值，该字段不会被使用于构建查询条件，使用Map来构建查询条件。

1.3 GORM更新数据

使用Struct更新时，只会更新非零值，如果需要更新零值使用Map更新或者使用Select选择字段。

gorm包里提供了一种方法gorm.Expr(“age * ? + ?”,2,100)，它的含义为age * 2 + 100。

1.4 GORM删除数据

物理删除

软删除

GORM提供了gorm.DeletedAt用于帮助用户实现软删

拥有软删除能力的Model调用Delete时，记录不会被从数据库中真正删除。但GORM会将DeletedAt置为当前时间，并且你不能再通过正常查询找到方法记录。

使用Unscoped可以查询到被软删的数据

1.5 事务

GORM提供了Begin、Commit、Rollback方法用于使用事务

例如，Begin使用时会固化一个链接，并同时执行开始事务的SQL语句，所以不能用原来的db来处理，应该重新赋值给tx。

Tansaction方法

GORM提供了Tansaction方法用于自动提交事务，避免用户漏写Commit、Rollback。

1.6 GORM Hook

GORM在提供了CURD的Hook能力。

Hook是在创建、查询、更新、删除等操作之前、之后自动调用的函数。

如果任何Hook返回错误，GORM将停止后续的操作并回滚事务。

1.7 性能提高

对于写操作（创建、更新、删除），为了确保数据的完整性，GORM会将它们封装在事务内运行。但这会降低性能，你可以使用SkipDefaultTransaction关闭默认事务。

使用PrepareStmt缓存预编译语句可以提高后续调用的速度，本机测试提高大约35%左右。

1.8 GORM生态

GORM拥有非常丰富的扩展生态，以下列举一部分常用扩展。

关于更多的GORM用法可以查看Gorm的文档（gorm.cn）

2 Kitex

Kitex是主要用于Golang微服务RPC框架，具有高性能、强可扩展的主要特点，支持多协议并且拥有丰富的开源扩展。

2.1 安装代码生成工具

Kitex目前对Windows的支持不完善，如果本地开发环境是Windows建议使用虚拟机或WSL2

Kitex相关文档：(www.cloudwego.io/zh/docs/kit…)

安装命令：

    go install github.com/cloudwego/kitex/tool/cmd/kitex@latest
    go install github.com/cloudwego/thriftgo@latest

查看版本：终端输入

    kitex -version

2.2 使用IDL定义服务与接口

如果我们要进行RPC，就需要知道对方的接口是什么，需要传什么参数，同时也需要知道返回值是什么样的。这时候，就需要通过IDL来约定双方的协议，就像在写代码的时候需要调用某个函数，我们需要知道函数签名一样。

Thrift：thrift.apache.org/docs/idl

Proto3:developers.google.com/protocol-bu…

Thrift语句：

namespace go api



struct Request{
    1: string  message
}


struct Request{
    1: string message
}
service Echo{
    Request echo(1: Request req)
}

2.3 Kitex生成代码

使用kitex -module example -service example echo.thrift命令生成代码。

build.sh:构建脚本

kitex_gen:IDL内容相关的生成代码，主要是基础的Server/Client代码。

main.go程序入口。

handler.go用户在该文件里实现IDLService定义的方法。

2.4 Kitex基本使用

服务默认监听8888端口

server端：

package main




import (

    "context"

    "example/kitex_gen/api"
)

 // EchoImpl implements the last service interface defined in the IDL
type EchoImpl struct{}


//Echo implements the EchoImpl interface
func (s *EchoImpl) Echo(ctx context.Context,req *api.Request) (resp *api.Response,err error) {
    //TODO: Your code here...
    return 
}

2.5 Kitex Client发起请求：

创建Client

import "example/kitex_gen/api/echo"
import "github.com/cloudwego/kitex/client"
...

c, err := echo.NewClient("example",client.WithHostPorts("0.0.0.0:8888"))
if err != nil {

    log.Fatal(err)

}

发起请求

import "example/kitex_gen/qpi"
...

req := &api.Request{Message: "my request"}
resp, err := c.Echo(context.Background(),req,callopt.WithRPCTimeout(3*time.Second))
if err != nil {

    log.Fatal(err)

}

log.Println(resp)

2.6 Kitex服务注册与发现

目前Kitex的服务注册与发现已经对接了主流的服务注册与发现中心，如ETCD，Nacos等。

2.7 Kitex生态

Kitex拥有非常丰富的扩展生态，以下列举一部分常用扩展。

3 Hertz

3.1 hertz基本使用

Hertz是一个HTTP框架，参考了其他开源框架的优势，具有高易用、高性能、高扩展性特点。

使用Hertz实现，服务监听8080端口并注册了一个GET方法的路由函数。

package main




import (

    "context"

    "github.com/cloudwego/hertz/pkg/app"
    "github.com/cloudwego/hertz/pkg/app/server"
    "github.com/cloudwugo/hertz/pkg/common/utils"
    "github.com/cloudwego/hertz/pkg/protocol/consts"
)


func main() {
    h := server.Default(server.WithHostPorts("127.0.0.1:8080"))
    h.GET("/ping",func(c context.Context,ctx *app.RequestContext){
        ctx.JSON(consts.StatusOK,utils.H{"ping":"pong"})
    })
    h.Spin()
}