关于golang:我用-gozero-一周实现了一个中台系统已开源

39次阅读

共计 15101 个字符,预计需要花费 38 分钟才能阅读完成。

作者:Jack

最近发现 golang 社区里出了一个新星的微服务框架,来自好将来,光看这个名字,就很有奔头,之前,也只是玩过 go-micro,其实真正的还没有在我的项目中使用过,只是感觉 微服务,grpc 这些很高大尚,还没有在我的项目中,真正的玩过,我看了一下官网提供的工具真的很好用,只须要定义好,舒服文件 jia 构造 都生成了,只须要关怀业务,加上最近 有个投票的流动,加上最近这几年中台也比拟火,所以决定玩一下,

开源地址: https://github.com/jackluo201…

先聊聊中台架构思路吧:

中台的概念大略就是把一个一个的 app 对立起来,反正我是这样了解的。

先聊用户服务吧,当初一个公司有很多的公众号,小程序,微信的,支付宝的,还有 xxx xxx , 很多的平台,每次开发的时候,咱们总是须要做用户登陆的服务,不停的复制代码,而后咱们就在思考能不能有一套独立的用户服务,只须要通知我你须要传个你要登陆的平台(比方微信),微信登陆,须要的是客户端返回给服务端一个 code,而后服务端拿着这个 code 去微信获取用户信息,反正大家都明确。

咱们决定,将所有的信息 弄到 配置公共服务中去,外面在存,微信,支付宝,以及其它平台的 appid ,appkey, 还有领取的 appid,appkey,这样就写一套。


最初说说实现吧,整个就一个 repo:

  • 网关,咱们用的是: go-zero 的 Api 服务
  • 其它它的是服务,咱们就是用的 go-zero 的 rpc 服务

看下目录构造

整个我的项目实现,我一个人操刀,写了 1 个来星期,我就实现了下面的中台零碎。

datacenter-api 服务

先看官网文档 https://www.yuque.com/tal-tec…

咱们先把网关搭建起来

➜ blogs mkdir datacenter && cd datacenter
➜ datacenter go mod init datacenter
go: creating new go.mod: module datacenter
➜ datacenter

查看 book 目录:

➜  datacenter tree
.
└── go.mod

0 directories, 1 file

创立 api 文件

➜  datacenter goctl api -o datacenter.api
Done.
➜  datacenter tree
.
├── datacenter.api
└── go.mod

定义 api 服务

别离蕴含了下面的 公共服务 用户服务 投票流动服务

info(
    title: "中台零碎"
    desc: "中台零碎"
    author: "jackluo"
    email: "net.webjoy@gmail.com"
)

// 获取 利用信息
type Beid struct {Beid int64 `json:"beid"`}
type Token struct{Token string `json:"token"`}
type WxTicket struct{Ticket string `json:"ticket"`}
type Application struct {
    Sname string `json:"Sname"` // 名称
    Logo string `json:"logo"` // login
    Isclose int64 `json:"isclose"` // 是否敞开
    Fullwebsite string `json:"fullwebsite"` // 全站名称
}
type SnsReq struct{
    Beid
    Ptyid int64  `json:"ptyid"` // 对应平台
    BackUrl string `json:"back_url"` // 登陆返回的地址
}
type SnsResp struct{
    Beid
    Ptyid int64  `json:"ptyid"` // 对应平台
    Appid string  `json:"appid"` //sns 平台的 id
    Title string  `json:"title"` // 名称
    LoginUrl string `json:"login_url"` // 微信登陆的地址
}

type WxShareResp struct {
    Appid string `json:"appid"`
    Timestamp int64 `json:"timestamp"`
    Noncestr string `json:"noncestr"`
    Signature string `json:"signature"`
}

@server(group: common)
service datacenter-api {
    @doc(summary: "获取站点的信息")
    @handler votesVerification
    get /MP_verify_NT04cqknJe0em3mT.txt (SnsReq) returns (SnsResp)
    
    @handler appInfo
    get /common/appinfo (Beid) returns (Application)
    
    @doc(summary: "获取站点的社交属性信息")
    @handler snsInfo
    post /common/snsinfo (SnsReq) returns (SnsResp)
    // 获取分享的
    @handler wxTicket
    post /common/wx/ticket (SnsReq) returns (WxShareResp)
    
}

// 上传须要登陆
@server(
    jwt: Auth
    group: common
)
service datacenter-api {
    @doc(summary: "七牛上传凭证")
    @handler qiuniuToken
    post /common/qiuniu/token (Beid) returns (Token)
}

// 注册申请
type RegisterReq struct {
    // TODO: add members here and delete this comment
    Mobile   string `json:"mobile"` // 根本一个手机号码就完事
    Password string `json:"password"`
    Smscode    string `json:"smscode"` // 短信码
}
// 登陆申请
type LoginReq struct{
    Mobile   string `json:"mobile"`
    Type int64 `json:"type"`    // 1. 明码登陆,2. 短信登陆
    Password string `json:"password"`
}
// 微信登陆
type WxLoginReq struct {
    Beid      int64  `json:"beid"` // 利用 id
    Code string `json:"code"` // 微信登陆密钥
    Ptyid      int64  `json:"ptyid"` // 对应平台
}

// 返回用户信息
type UserReply struct {
    Auid       int64  `json:"auid"`
    Uid       int64  `json:"uid"`
    Beid      int64  `json:"beid"` // 利用 id
    Ptyid      int64  `json:"ptyid"` // 对应平台
    Username string `json:"username"`
    Mobile   string `json:"mobile"`
    Nickname string `json:"nickname"`
    Openid string `json:"openid"`
    Avator string `json:"avator"`
    JwtToken
}
// 返回 APPUser
type AppUser struct{
    Uid       int64  `json:"uid"`
    Auid       int64  `json:"auid"`
    Beid      int64  `json:"beid"` // 利用 id
    Ptyid      int64  `json:"ptyid"` // 对应平台
    Nickname string `json:"nickname"`
    Openid string `json:"openid"`
    Avator string `json:"avator"`
}

type LoginAppUser struct{
    Uid       int64  `json:"uid"`
    Auid       int64  `json:"auid"`
    Beid      int64  `json:"beid"` // 利用 id
    Ptyid      int64  `json:"ptyid"` // 对应平台
    Nickname string `json:"nickname"`
    Openid string `json:"openid"`
    Avator string `json:"avator"`
    JwtToken
}

type JwtToken struct {
    AccessToken  string `json:"access_token,omitempty"`
    AccessExpire int64  `json:"access_expire,omitempty"`
    RefreshAfter int64  `json:"refresh_after,omitempty"`
}

type UserReq struct{
    Auid       int64  `json:"auid"`
    Uid       int64  `json:"uid"`
    Beid      int64  `json:"beid"` // 利用 id
    Ptyid      int64  `json:"ptyid"` // 对应平台
}

type Request {Name string `path:"name,options=you|me"`}
type Response {Message string `json:"message"`}

@server(group: user)
service user-api {
    @handler ping
    post /user/ping ()
    
    @handler register
    post /user/register (RegisterReq) returns (UserReply)
    
    @handler login
    post /user/login (LoginReq) returns (UserReply)
    
    @handler wxlogin
    post /user/wx/login (WxLoginReq) returns (LoginAppUser)
    
    @handler code2Session
    get /user/wx/login () returns (LoginAppUser)
}
@server(
    jwt: Auth
    group: user
    middleware: Usercheck
)
service user-api {
    @handler userInfo
    get /user/dc/info (UserReq) returns (UserReply)
}

// 投票流动 api
type Actid struct {Actid       int64  `json:"actid"` // 流动 id}

type VoteReq struct {
    Aeid       int64  `json:"aeid"` // 作品 id
    Actid
}
type VoteResp struct {
    VoteReq
    Votecount       int64  `json:"votecount"` // 投票票数
    Viewcount       int64  `json:"viewcount"` // 浏览数
}


// 流动返回的参数
type ActivityResp struct {
    Actid           int64  `json:"actid"`
    Title           string  `json:"title"` // 流动名称
    Descr           string  `json:"descr"` // 流动形容
    StartDate       int64  `json:"start_date"` // 流动工夫
    EnrollDate      int64  `json:"enroll_date"` // 投票工夫
    EndDate           int64  `json:"end_date"` // 流动完结工夫
    Votecount       int64  `json:"votecount"` // 以后流动的总票数
    Viewcount       int64  `json:"viewcount"` // 以后流动的总浏览数
    Type            int64 `json:"type"` // 投票形式
    Num                int64 `json:"num"` // 投票几票
}


// 报名
type EnrollReq struct {
    Actid
    Name           string  `json:"name"` // 名称
    Address           string  `json:"address"` // 地址
    Images           []string  `json:"images"` // 作品图片
    Descr           string  `json:"descr"` // 作品形容
}

// 作品返回
type EnrollResp struct {
    Actid
    Aeid        int64 `json:"aeid"` // 作品 id
    Name           string  `json:"name"` // 名称
    Address           string  `json:"address"` // 地址
    Images           []string  `json:"images"` // 作品图片
    Descr           string  `json:"descr"` // 作品形容
    Votecount       int64  `json:"votecount"` // 以后流动的总票数
    Viewcount       int64  `json:"viewcount"` // 以后流动的总浏览数
    
}

@server(group: votes)
service votes-api {
    @doc(summary: "获取流动的信息")
    @handler activityInfo
    get /votes/activity/info (Actid) returns (ActivityResp)
    @doc(summary: "流动拜访 +1")
    @handler activityIcrView
    get /votes/activity/view (Actid) returns (ActivityResp)
    @doc(summary: "获取报名的投票作品信息")
    @handler enrollInfo
    get /votes/enroll/info (VoteReq) returns (EnrollResp)
    @doc(summary: "获取报名的投票作品列表")
    @handler enrollLists
    get /votes/enroll/lists (Actid)    returns(EnrollResp)
}

@server(
    jwt: Auth
    group: votes
    middleware: Usercheck
)
service votes-api {
    @doc(summary: "投票")
    @handler vote
    post /votes/vote (VoteReq) returns (VoteResp)
    @handler enroll
    post /votes/enroll (EnrollReq) returns (EnrollResp)
}

下面基本上写就写的 API 及文档的思路

生成 datacenter api 服务

➜  datacenter goctl api go -api datacenter.api -dir .
Done.
➜  datacenter tree
.
├── datacenter.api
├── etc
│   └── datacenter-api.yaml
├── go.mod
├── internal
│   ├── config
│   │   └── config.go
│   ├── handler
│   │   ├── common
│   │   │   ├── appinfohandler.go
│   │   │   ├── qiuniutokenhandler.go
│   │   │   ├── snsinfohandler.go
│   │   │   ├── votesverificationhandler.go
│   │   │   └── wxtickethandler.go
│   │   ├── routes.go
│   │   ├── user
│   │   │   ├── code2sessionhandler.go
│   │   │   ├── loginhandler.go
│   │   │   ├── pinghandler.go
│   │   │   ├── registerhandler.go
│   │   │   ├── userinfohandler.go
│   │   │   └── wxloginhandler.go
│   │   └── votes
│   │       ├── activityicrviewhandler.go
│   │       ├── activityinfohandler.go
│   │       ├── enrollhandler.go
│   │       ├── enrollinfohandler.go
│   │       ├── enrolllistshandler.go
│   │       └── votehandler.go
│   ├── logic
│   │   ├── common
│   │   │   ├── appinfologic.go
│   │   │   ├── qiuniutokenlogic.go
│   │   │   ├── snsinfologic.go
│   │   │   ├── votesverificationlogic.go
│   │   │   └── wxticketlogic.go
│   │   ├── user
│   │   │   ├── code2sessionlogic.go
│   │   │   ├── loginlogic.go
│   │   │   ├── pinglogic.go
│   │   │   ├── registerlogic.go
│   │   │   ├── userinfologic.go
│   │   │   └── wxloginlogic.go
│   │   └── votes
│   │       ├── activityicrviewlogic.go
│   │       ├── activityinfologic.go
│   │       ├── enrollinfologic.go
│   │       ├── enrolllistslogic.go
│   │       ├── enrolllogic.go
│   │       └── votelogic.go
│   ├── middleware
│   │   └── usercheckmiddleware.go
│   ├── svc
│   │   └── servicecontext.go
│   └── types
│       └── types.go
└── datacenter.go

14 directories, 43 files

咱们关上 etc/datacenter-api.yaml 把必要的配置信息加上

Name: datacenter-api
Log:
  Mode: console
Host: 0.0.0.0
Port: 8857
Auth:
  AccessSecret: 你的 jwtwon Secret
  AccessExpire: 86400
CacheRedis:
- Host: 127.0.0.1:6379
  Pass: 明码
  Type: node                     
UserRpc:
  Etcd:
    Hosts:
      - 127.0.0.1:2379
    Key: user.rpc
CommonRpc:
  Etcd:
    Hosts:
      - 127.0.0.1:2379
    Key: common.rpc
VotesRpc:
  Etcd:
    Hosts:
      - 127.0.0.1:2379
    Key: votes.rpc        

下面的 UserRpcCommonRpc , 还有 VotesRpc 这些我先写上,前面再来缓缓加。

咱们先来写 CommonRpc 服务。

CommonRpc 服务

新建我的项目目录

➜  datacenter mkdir -p common/rpc && cd common/rpc

间接就新建在了,datacenter 目录中,因为 common 外面,可能当前会不只会提供 rpc 服务,可能还有 api 的服务, 所以又加了 rpc 目录

goctl 创立模板

➜  rpc goctl rpc template -o=common.proto
➜  rpc ls
common.proto

往里面填入内容:

➜  rpc cat common.proto
syntax = "proto3";

package common;


message BaseAppReq{int64 beid=1;}

message BaseAppResp{
  int64 beid=1;
  string logo=2;
  string sname=3;
  int64 isclose=4;
  string fullwebsite=5;
}

// 申请的 api
message AppConfigReq {
  int64 beid=1;
  int64 ptyid=2;
}

// 返回的值
message AppConfigResp {
  int64 id=1;
  int64 beid=2;
  int64 ptyid=3;
  string appid=4;
  string appsecret=5;
  string title=6;
}

service Common {rpc GetAppConfig(AppConfigReq) returns(AppConfigResp);
  rpc GetBaseApp(BaseAppReq) returns(BaseAppResp);
} 

gotcl 生成 rpc 服务

➜  rpc goctl rpc proto -src common.proto -dir .
protoc  -I=/Users/jackluo/works/blogs/datacenter/common/rpc common.proto --go_out=plugins=grpc:/Users/jackluo/works/blogs/datacenter/common/rpc/common
Done.
➜ rpc tree
.
├── common
│  └── common.pb.go
├── common.go
├── common.proto
├── commonclient
│  └── common.go
├── etc
│  └── common.yaml
└── internal
├── config
│  └── config.go
├── logic
│  ├── getappconfiglogic.go
│  └── getbaseapplogic.go
├── server
│  └── commonserver.go
└── svc
└── servicecontext.go

8 directories, 10 files

基本上,就把所有的目录标准和构造的货色都生成了,就不必纠结我的项目目录了,怎么放了,怎么组织了。

看一下,配置信息,外面能够写入 mysql 和其它 redis 的信息:

Name: common.rpc
ListenOn: 127.0.0.1:8081
Mysql:
  DataSource: root:admin@tcp(127.0.0.1:3306)/datacenter?charset=utf8&parseTime=true&loc=Asia%2FShanghai
CacheRedis:
- Host: 127.0.0.1:6379
  Pass:
  Type: node  
Etcd:
  Hosts:
  - 127.0.0.1:2379
  Key: common.rpc

咱们再来加上数据库服务:

➜  rpc cd ..
➜  common ls
rpc
➜  common pwd
/Users/jackluo/works/blogs/datacenter/common
➜  common goctl model mysql datasource -url="root:admin@tcp(127.0.0.1:3306)/datacenter" -table="base_app" -dir ./model -c
Done.
➜  common tree
.
├── model
│   ├── baseappmodel.go
│   └── vars.go
└── rpc
    ├── common
    │   └── common.pb.go
    ├── common.go
    ├── common.proto
    ├── commonclient
    │   └── common.go
    ├── etc
    │   └── common.yaml
    └── internal
        ├── config
        │   └── config.go
        ├── logic
        │   ├── getappconfiglogic.go
        │   └── getbaseapplogic.go
        ├── server
        │   └── commonserver.go
        └── svc
            └── servicecontext.go

10 directories, 12 files

这样根本的一个 rpc 就写完了,而后咱们将 rpc 和 model 还有 api 串连起来,这个官网的文档曾经很具体了,这里就只是贴一下代码:

➜  common cat rpc/internal/config/config.go
package config

import (
    "github.com/tal-tech/go-zero/core/stores/cache"
    "github.com/tal-tech/go-zero/zrpc"
)

type Config struct {
    zrpc.RpcServerConf
    Mysql struct {DataSource string}
    CacheRedis cache.ClusterConf
}

再在 svc 中批改:

➜  common cat rpc/internal/svc/servicecontext.go
package svc

import (
    "datacenter/common/model"
    "datacenter/common/rpc/internal/config"

    "github.com/tal-tech/go-zero/core/stores/sqlx"
)

type ServiceContext struct {
    c              config.Config
    AppConfigModel model.AppConfigModel
    BaseAppModel   model.BaseAppModel
}

func NewServiceContext(c config.Config) *ServiceContext {conn := sqlx.NewMysql(c.Mysql.DataSource)
    apm := model.NewAppConfigModel(conn, c.CacheRedis)
    bam := model.NewBaseAppModel(conn, c.CacheRedis)
    return &ServiceContext{
        c:              c,
        AppConfigModel: apm,
        BaseAppModel:   bam,
    }
}

下面的代码曾经将 rpcmodel 数据库关联起来了,咱们当初再将 rpcapi 关联起来:

➜  datacenter cat internal/config/config.go

package config

import (
    "github.com/tal-tech/go-zero/core/stores/cache"
    "github.com/tal-tech/go-zero/rest"
    "github.com/tal-tech/go-zero/zrpc"
)

type Config struct {
    rest.RestConf

    Auth struct {
        AccessSecret string
        AccessExpire int64
    }
    UserRpc   zrpc.RpcClientConf
    CommonRpc zrpc.RpcClientConf
    VotesRpc  zrpc.RpcClientConf

    CacheRedis cache.ClusterConf
}

退出 svc 服务中:

➜  datacenter cat internal/svc/servicecontext.go
package svc

import (
    "context"
    "datacenter/common/rpc/commonclient"
    "datacenter/internal/config"
    "datacenter/internal/middleware"
    "datacenter/shared"
    "datacenter/user/rpc/userclient"
    "datacenter/votes/rpc/votesclient"
    "fmt"
    "net/http"
    "time"

    "github.com/tal-tech/go-zero/core/logx"
    "github.com/tal-tech/go-zero/core/stores/cache"
    "github.com/tal-tech/go-zero/core/stores/redis"
    "github.com/tal-tech/go-zero/core/syncx"
    "github.com/tal-tech/go-zero/rest"
    "github.com/tal-tech/go-zero/zrpc"
    "google.golang.org/grpc"
)

type ServiceContext struct {
    Config           config.Config
    GreetMiddleware1 rest.Middleware
    GreetMiddleware2 rest.Middleware
    Usercheck        rest.Middleware
    UserRpc          userclient.User // 用户
    CommonRpc        commonclient.Common
    VotesRpc         votesclient.Votes
    Cache            cache.Cache
    RedisConn        *redis.Redis
}

func timeInterceptor(ctx context.Context, method string, req, reply interface{}, cc *grpc.ClientConn, invoker grpc.UnaryInvoker, opts ...grpc.CallOption) error {stime := time.Now()
    err := invoker(ctx, method, req, reply, cc, opts...)
    if err != nil {return err}

    fmt.Printf("调用 %s 办法 耗时: %v\n", method, time.Now().Sub(stime))
    return nil
}
func NewServiceContext(c config.Config) *ServiceContext {ur := userclient.NewUser(zrpc.MustNewClient(c.UserRpc, zrpc.WithUnaryClientInterceptor(timeInterceptor)))
    cr := commonclient.NewCommon(zrpc.MustNewClient(c.CommonRpc, zrpc.WithUnaryClientInterceptor(timeInterceptor)))
    vr := votesclient.NewVotes(zrpc.MustNewClient(c.VotesRpc, zrpc.WithUnaryClientInterceptor(timeInterceptor)))
    // 缓存
    ca := cache.NewCache(c.CacheRedis, syncx.NewSharedCalls(), cache.NewCacheStat("dc"), shared.ErrNotFound)
    rcon := redis.NewRedis(c.CacheRedis[0].Host, c.CacheRedis[0].Type, c.CacheRedis[0].Pass)
    return &ServiceContext{
        Config:           c,
        GreetMiddleware1: greetMiddleware1,
        GreetMiddleware2: greetMiddleware2,
        Usercheck:        middleware.NewUserCheckMiddleware().Handle,
        UserRpc:          ur,
        CommonRpc:        cr,
        VotesRpc:         vr,
        Cache:            ca,
        RedisConn:        rcon,
    }
}

这样基本上,咱们就能够在 logic 的文件目录中调用了:

cat internal/logic/common/appinfologic.go

package logic

import (
    "context"

    "datacenter/internal/svc"
    "datacenter/internal/types"
    "datacenter/shared"

    "datacenter/common/model"
    "datacenter/common/rpc/common"

    "github.com/tal-tech/go-zero/core/logx"
)

type AppInfoLogic struct {
    logx.Logger
    ctx    context.Context
    svcCtx *svc.ServiceContext
}

func NewAppInfoLogic(ctx context.Context, svcCtx *svc.ServiceContext) AppInfoLogic {
    return AppInfoLogic{Logger: logx.WithContext(ctx),
        ctx:    ctx,
        svcCtx: svcCtx,
    }
}

func (l *AppInfoLogic) AppInfo(req types.Beid) (appconfig *common.BaseAppResp, err error) {

    // 查看 缓存中是否有值
    err = l.svcCtx.Cache.GetCache(model.GetcacheBaseAppIdPrefix(req.Beid), appconfig)
    if err != nil && err == shared.ErrNotFound {
        appconfig, err = l.svcCtx.CommonRpc.GetBaseApp(l.ctx, &common.BaseAppReq{Beid: req.Beid,})
        if err != nil {return}
        err = l.svcCtx.Cache.SetCache(model.GetcacheBaseAppIdPrefix(req.Beid), appconfig)
    }

    return
}

这样,根本就连接起来了,其它基本上就不必改了,UserRPCVotesRPC 相似,这里就不在写了。

应用心得

go-zero 确实香,因为它有一个 goctl 的工具,他能够主动的把代码构造全副的生成好,咱们就不再去纠结,目录构造,怎么组织,没有个好几年的架构能力是不好实现的,有什么标准那些,并发,熔断,齐全不必,考滤其它的,分心的实现业务就好,像微服务,还要有服务发现,一系列的货色,都不必关怀,因为 go-zero 外部曾经实现了。

我写代码也写了有 10 多年了,之前始终用的 php,比拟闻名的就 laravel,thinkphp,基本上就是模块化的, 像微服那些实现直来真的有老本,然而你用上 go-zero,你就像调 api 接口一样简略的开发,其它什么服务发现,那些基本就不必关注了,只须要关注业务。

一个好的语言,框架,他们的底层思维,永远都是效率高,不加班的思维,我置信 go-zero 会进步你和你团队或是公司的效率。go-zero 的作者说,他们有个团队专门整顿 go-zero 框架,目标也应该很显著,那就是进步,他们本人的开发效率,流程化,标准化,是进步工作效率的准则,像咱们平时遇到了问题,或是遇到了 bug,我第一个想到的不是怎么去解决我的 bug,而是在想我的流程是不是有问题,我的哪个流程会导致 bug,最初我置信 go-zero 能成为 微服务开发 的首选框架。

最初说说遇到的坑吧:

  • grpc

grpc 自己第一次用,而后就遇到了,有些字符为空时,字段值不显示的问题:

通过 grpc 官网库中的 jsonpb 来实现,官网在它的设定中有一个构造体用来实现 protoc buffer 转换为 JSON 构造,并能够依据字段来配置转换的要求。

  • 跨域问题

go-zero 中设置了,感觉没有成果,大佬说通过 nginx 设置,前面发现还是不行,最近强行弄到了一个域名下,前面有工夫再解决。

  • sqlx

go-zerosqlx 问题,这个真的费了很长的工夫:

time.Time 这个数据结构,数据库中用的是 timestamp 这个 比方我的字段 是 delete_at 默认数库设置的是 null,后果插入的时候,就报了 Incorrect datetime value: '0000-00-00' for column 'deleted_at' at row 1"} 这个错,查问的时候报 deleted_at\": unsupported Scan, storing driver.Value type \u003cnil\u003e into type *time.Time"

前面果决去掉了这个字段,字段下面加上 .omitempty 这个标签,如同也有用,db:".omitempty"

其次就是这个 Conversion from collation utf8_general_ci into utf8mb4_unicode_ci,这个导致的大略起因是,当初都喜爱用 emj 表情了,mysql 数据辨认不了。

  • 数据连贯

mysql 这边照样依照原始的形式, 将配置文件批改编码格局,从新创立数据库,并且设置数据库编码为 utf8mb4,排序规定为 utf8mb4_unicode_ci

这样的话, 所有的表还有 string 字段都是这个编码格局, 如果不想所有的都是, 能够独自设置, 这个不是重点. 因为在 navicat 上都好设置, 手动点一下就行了

重点来了:golang 中应用的是 github.com/go-sql-driver/mysql 驱动,将连贯 mysqldsn(因为我这应用的是 gorm,所以 dsn 可能跟原生的格局不太一样,不过没关系,只须要关注 charsetcollation 就行了)

root:password@/name?parseTime=True&loc=Local&charset=utf8 批改为:
root:password@/name?parseTime=True&loc=Local&charset=utf8mb4&collation=utf8mb4_unicode_ci

go-zero 我的项目地址

https://github.com/tal-tech/go-zero

欢送点赞????

我的项目地址:
https://github.com/tal-tech/go-zero

正文完
 0