Go
话题列表 社区 Wiki 优质外文 招聘求职 Go 实战教程 社区文档
登录
注册

go-zero 实现一个中台系统的

秦晓武 的个人博客 / 400 / 2 / 创建于 3年前

原文地址

最近发现 golang 社区里出了一个新星的微服务框架，来自好未来，光看这个名字，就很有奔头，之前，也只是玩过 go-micro，其实真正的还没有在项目中运用过，只是觉得 微服务，grpc 这些很高大尚，还没有在项目中，真正的玩过，我看了一下官方提供的工具真的很好用，只需要定义好，舒适文件夹结构都生成了，只需要关心业务，

加上最近有个投票的活动，加上最近这几年中台也比较火，所以决定玩一下，

开源地址: github.com/jackluo2012/datacenter

先聊聊中台架构思路吧，look 先看架

中台的概念大概就是把一个一个的app 统一起来，反正我是这样理解的

先聊用户服务吧，现在一个公司有很多的公众号，小程序，微信的，支付宝的，还有xxx xxx ,很多的平台，每次开发的时候，我们总是需要做用户登陆的服务，不停的复制代码，然后我们就在思考能不能有一套独立的用户服务，

只需要告诉我你需要传个你要登陆的平台(比如微信)，微信登陆，需要的是客户端返回给服务端一个code ，然后服务端拿着这个code去微信获取用户信息，反正大家都明白，

我们决定，将所有的信息 弄到 配置公共服务中去，里面在存，微信，支付宝，以及其它平台的 appid ,appkey,还有支付的appid,appkey,

这样就写一套

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

最后说说实现吧，整个就一个repo

网关，我们用的是: go-zero的Api服务

其它它的是服务，我们就是用的go-zero的rpc服务

看下目录结构

整个项目完成，我一个人操刀， 写了1个来星期，我就实现了上面的中台系统;

go-zero作者私聊我说，可不可以写得丰富点，所以我决定把我的源码也加到文章里面

先看官方文档 www.yuque.com/tal-tech/**go-zero**...

我们先把网关搭建起来

创建 datacenter-api 服务

? 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: "中台系统"// TODO: add title
    desc: "中台系统"// TODO: add description
    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: nodeUserRpc:
  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

上面的 UserRpc，和 CommonRpc ,还有VotesRpc 这些我先写上，后面再来慢慢加

我们先来写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,
    }
}

上面的代码已经将rpc 和 model 数据库关联起来了，我们现在再将rpc 和 api关联起来

?  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
}

这样，基本就连接起来了，其它基本上就不用改了，UserRPC,和VotesRPC类似，这里就不在写了

下面我说说使用心得吧

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官方库中的jsonpb来实现,官方在它的设定中有一个结构体用来实现protoc buffer转换为JSON结构，并可以根据字段来配置转换的要求

跨域问题：

go-zero的设置了，感觉没有效果，大佬说通过nginx 设置，后面发现还是不行，最近 ，强行弄到了一个域名下，后面有时间再解决

go-zero的sqlx 问题，这个真的费了很长的时间，

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驱动,
将连接mysql的dsn:(因为我这使用的是gorm,所以dsn可能跟原生的格式不太一样,不过没关系,只需要关注charset和collation就行了)
root:password@/name?parseTime=True&loc=Local&charset=utf8
修改为:
root:password@/name?parseTime=True&loc=Local&charset=utf8mb4&collation=utf8mb4_unicode_ci

信息分享
本作品采用《CC 协议》，转载必须注明作者和本文链接
本帖由系统于 2年前 自动加精
秦晓武
课程读者 267 声望
技术负责人 @ 爱华通讯
功能可以挂，代码必须美
讨论数量: 2
排序：
时间 投票
剑尘
课程读者 168 声望

学习了

3年前 评论
中文
课程读者 44 声望

我想问下你的生产环境咋部署的，有没有教程

1年前 评论

讨论应以学习和精进为目的。请勿发布不友善或者负能量的内容，与人为善，比聪明更重要！
支持 MD 帮助
秦晓武
技术负责人 @ 爱华通讯
文章
36
粉丝
22
喜欢
11
收藏
11
排名：1184
访问：3760
私信
所有博文
文章归档
4 篇 2021 年 6 月 2 篇 2021 年 4 月 7 篇 2021 年 3 月 1 篇 2021 年 2 月 3 篇 2021 年 1 月 19 篇 2020 年 12 月
最新文章 最受欢迎
2年前 把 session 存在 redis 里 2年前 session 共享 2年前 360卫士阻止进程创建，导致各种异常 2年前 Oracle in 查询优化 3年前 windows 下安装 yarn
6 go-zero 实现一个中台系统的 1 PHP 8 踩坑记 1 社区使用笔记 - 先从阅读和评论开始 1 微服务思想 1 ThinkPHP 5 模型使用历程 - 小结
博客标签
学习笔记
12
 信息分享
6
 思考总结
9
 干货分享
5
社区赞助商
成为赞助商

关于 LearnKu

LearnKu 是终身编程者的修道场
做最专业、严肃的技术论坛
LearnKu 诞生的故事

资源推荐

  • 《社区使用指南》
  • 《文档撰写指南》
  • 《LearnKu 社区规范》
  • 《提问的智慧》

    • 服务提供商

    其他信息

  • 成为版主
  • 所有测验
  • 联系站长（反馈建议）

    • 粤ICP备18099781号-6 | 粤公网安备 44030502004330号 | 违法和不良信息举报

    由 Summer 设计和编码 ❤

    请登录

    内容举报
    匿名举报，为防止滥用，仅管理员可见举报者。

    我要举报该，理由是：

    取消