序言 我们通过一个系列文章跟大家详细展示一个 go-zero 微服务示例，整个系列分十篇文章，目录结构如下：

1. 环境搭建
2. 服务拆分
3. 用户服务
4. 产品服务（本文）
5. 订单服务
6. 支付服务
7. RPC 服务 Auth 验证
8. 服务监控
9. 链路追踪
10. 分布式事务

期望通过本系列带你在本机利用 Docker 环境利用 go-zero 快速开发一个商城系统，让你快速上手微服务。
完整示例代码：https://github.com/nivin-studio/go-zero-mall
首先，我们来看一下整体的服务拆分图：
【带你十天轻松搞定|带你十天轻松搞定 Go 微服务系列（四）】
文章图片

4. 产品服务（product）

• 进入服务工作区

$ cd mall/service/product

4.1 生成 product model 模型

• 创建 sql 文件

$ vim model/product.sql

• 编写 sql 文件

CREATE TABLE `product` ( `id` bigint unsigned NOT NULL AUTO_INCREMENT, `name` varchar(255)NOT NULL DEFAULT '' COMMENT '产品名称', `desc` varchar(255)NOT NULL DEFAULT '' COMMENT '产品描述', `stock` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '产品库存', `amount` int(10) unsigned NOT NULL DEFAULT '0'COMMENT '产品金额', `status` tinyint(3) unsigned NOT NULL DEFAULT '0' COMMENT '产品状态', `create_time` timestamp NULL DEFAULT CURRENT_TIMESTAMP, `update_time` timestamp NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, PRIMARY KEY (`id`) ) ENGINE=InnoDBDEFAULT CHARSET=utf8mb4;

• 运行模板生成命令

$ goctl model mysql ddl -src ./model/product.sql -dir ./model -c

4.2 生成 product api 服务

• 创建 api 文件

$ vim api/product.api

• 编写 api 文件

type ( // 产品创建 CreateRequest { Namestring `json:"name"` Descstring `json:"desc"` Stockint64`json:"stock"` Amount int64`json:"amount"` Status int64`json:"status"` } CreateResponse { Id int64 `json:"id"` } // 产品创建// 产品修改 UpdateRequest { Idint64`json:"id"` Namestring `json:"name,optional"` Descstring `json:"desc,optional"` Stockint64`json:"stock"` Amount int64`json:"amount,optional"` Status int64`json:"status,optional"` } UpdateResponse { } // 产品修改// 产品删除 RemoveRequest { Id int64 `json:"id"` } RemoveResponse { } // 产品删除// 产品详情 DetailRequest { Id int64 `json:"id"` } DetailResponse { Idint64`json:"id"` Namestring `json:"name"` Descstring `json:"desc"` Stockint64`json:"stock"` Amount int64`json:"amount"` Status int64`json:"status"` } // 产品详情 )@server( jwt: Auth ) service Product { @handler Create post /api/product/create(CreateRequest) returns (CreateResponse)@handler Update post /api/product/update(UpdateRequest) returns (UpdateResponse)@handler Remove post /api/product/remove(RemoveRequest) returns (RemoveResponse)@handler Detail post /api/product/detail(DetailRequest) returns (DetailResponse) }

• 运行模板生成命令

$ goctl api go -api ./api/product.api -dir ./api

4.3 生成 product rpc 服务

• 创建 proto 文件

$ vim rpc/product.proto

• 编写 proto 文件

syntax = "proto3"; package productclient; option go_package = "product"; // 产品创建 message CreateRequest { string Name = 1; string Desc = 2; int64 Stock = 3; int64 Amount = 4; int64 Status = 5; } message CreateResponse { int64 id = 1; } // 产品创建// 产品修改 message UpdateRequest { int64 id = 1; string Name = 2; string Desc = 3; int64 Stock = 4; int64 Amount = 5; int64 Status = 6; } message UpdateResponse { } // 产品修改// 产品删除 message RemoveRequest { int64 id = 1; } message RemoveResponse { } // 产品删除// 产品详情 message DetailRequest { int64 id = 1; } message DetailResponse { int64 id = 1; string Name = 2; string Desc = 3; int64 Stock = 4; int64 Amount = 5; int64 Status = 6; } // 产品详情service Product { rpc Create(CreateRequest) returns(CreateResponse); rpc Update(UpdateRequest) returns(UpdateResponse); rpc Remove(RemoveRequest) returns(RemoveResponse); rpc Detail(DetailRequest) returns(DetailResponse); }

• 运行模板生成命令

$ goctl rpc proto -src ./rpc/product.proto -dir ./rpc

4.4 编写 product rpc 服务 4.4.1 修改配置文件

• 修改 product.yaml 配置文件

$ vim rpc/etc/product.yaml

• 修改服务监听地址，端口号为0.0.0.0:9001，Etcd 服务配置，Mysql 服务配置，CacheRedis 服务配置

Name: product.rpc ListenOn: 0.0.0.0:9001Etcd: Hosts: - etcd:2379 Key: product.rpcMysql: DataSource: root:123456@tcp(mysql:3306)/mall?charset=utf8mb4&parseTime=true&loc=Asia%2FShanghaiCacheRedis: - Host: redis:6379 Type: node # node可以不写，可以设为cluster # Pass: xxx # 如果有密码

4.4.2 添加 product model 依赖

• 添加 Mysql 服务配置，CacheRedis 服务配置的实例化

$ vim rpc/internal/config/config.go

package configimport ( "github.com/tal-tech/go-zero/core/stores/cache" "github.com/tal-tech/go-zero/zrpc" )type Config struct { zrpc.RpcServerConfMysql struct { DataSource string }CacheRedis cache.CacheConf }

• 注册服务上下文 product model 的依赖

$ vim rpc/internal/svc/servicecontext.go

package svcimport ( "mall/service/product/model" "mall/service/product/rpc/internal/config""github.com/tal-tech/go-zero/core/stores/sqlx" )type ServiceContext struct { Config config.ConfigProductModel model.ProductModel }func NewServiceContext(c config.Config) *ServiceContext { conn := sqlx.NewMysql(c.Mysql.DataSource) return &ServiceContext{ Config:c, ProductModel: model.NewProductModel(conn, c.CacheRedis), } }

4.4.3 添加产品创建逻辑 Create

$ vim rpc/internal/logic/createlogic.go

package logicimport ( "context""mall/service/product/model" "mall/service/product/rpc/internal/svc" "mall/service/product/rpc/product""github.com/tal-tech/go-zero/core/logx" "google.golang.org/grpc/status" )type CreateLogic struct { ctxcontext.Context svcCtx *svc.ServiceContext logx.Logger }func NewCreateLogic(ctx context.Context, svcCtx *svc.ServiceContext) *CreateLogic { return &CreateLogic{ ctx:ctx, svcCtx: svcCtx, Logger: logx.WithContext(ctx), } }func (l *CreateLogic) Create(in *product.CreateRequest) (*product.CreateResponse, error) { newProduct := model.Product{ Name:in.Name, Desc:in.Desc, Stock:in.Stock, Amount: in.Amount, Status: in.Status, }res, err := l.svcCtx.ProductModel.Insert(&newProduct) if err != nil { return nil, status.Error(500, err.Error()) }newProduct.Id, err = res.LastInsertId() if err != nil { return nil, status.Error(500, err.Error()) }return &product.CreateResponse{ Id: newProduct.Id, }, nil }

4.4.4 添加产品详情逻辑 Detail

$ vim rpc/internal/logic/detaillogic.go

package logicimport ( "context""mall/service/product/model" "mall/service/product/rpc/internal/svc" "mall/service/product/rpc/product""github.com/tal-tech/go-zero/core/logx" "google.golang.org/grpc/status" )type DetailLogic struct { ctxcontext.Context svcCtx *svc.ServiceContext logx.Logger }func NewDetailLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DetailLogic { return &DetailLogic{ ctx:ctx, svcCtx: svcCtx, Logger: logx.WithContext(ctx), } }func (l *DetailLogic) Detail(in *product.DetailRequest) (*product.DetailResponse, error) { // 查询产品是否存在 res, err := l.svcCtx.ProductModel.FindOne(in.Id) if err != nil { if err == model.ErrNotFound { return nil, status.Error(100, "产品不存在") } return nil, status.Error(500, err.Error()) }return &product.DetailResponse{ Id:res.Id, Name:res.Name, Desc:res.Desc, Stock:res.Stock, Amount: res.Amount, Status: res.Status, }, nil }

4.4.5 添加产品更新逻辑 Update

$ vim rpc/internal/logic/updatelogic.go

package logicimport ( "context""mall/service/product/model" "mall/service/product/rpc/internal/svc" "mall/service/product/rpc/product""github.com/tal-tech/go-zero/core/logx" "google.golang.org/grpc/status" )type UpdateLogic struct { ctxcontext.Context svcCtx *svc.ServiceContext logx.Logger }func NewUpdateLogic(ctx context.Context, svcCtx *svc.ServiceContext) *UpdateLogic { return &UpdateLogic{ ctx:ctx, svcCtx: svcCtx, Logger: logx.WithContext(ctx), } }func (l *UpdateLogic) Update(in *product.UpdateRequest) (*product.UpdateResponse, error) { // 查询产品是否存在 res, err := l.svcCtx.ProductModel.FindOne(in.Id) if err != nil { if err == model.ErrNotFound { return nil, status.Error(100, "产品不存在") } return nil, status.Error(500, err.Error()) }if in.Name != "" { res.Name = in.Name } if in.Desc != "" { res.Desc = in.Desc } if in.Stock != 0 { res.Stock = in.Stock } if in.Amount != 0 { res.Amount = in.Amount } if in.Status != 0 { res.Status = in.Status }err = l.svcCtx.ProductModel.Update(res) if err != nil { return nil, status.Error(500, err.Error()) }return &product.UpdateResponse{}, nil }

4.4.6 添加产品删除逻辑 Remove

$ vim rpc/internal/logic/removelogic.go

package logicimport ( "context""mall/service/product/model" "mall/service/product/rpc/internal/svc" "mall/service/product/rpc/product""github.com/tal-tech/go-zero/core/logx" "google.golang.org/grpc/status" )type RemoveLogic struct { ctxcontext.Context svcCtx *svc.ServiceContext logx.Logger }func NewRemoveLogic(ctx context.Context, svcCtx *svc.ServiceContext) *RemoveLogic { return &RemoveLogic{ ctx:ctx, svcCtx: svcCtx, Logger: logx.WithContext(ctx), } }func (l *RemoveLogic) Remove(in *product.RemoveRequest) (*product.RemoveResponse, error) { // 查询产品是否存在 res, err := l.svcCtx.ProductModel.FindOne(in.Id) if err != nil { if err == model.ErrNotFound { return nil, status.Error(100, "产品不存在") } return nil, status.Error(500, err.Error()) }err = l.svcCtx.ProductModel.Delete(res.Id) if err != nil { return nil, status.Error(500, err.Error()) }return &product.RemoveResponse{}, nil }

4.5 编写 product api 服务 4.5.1 修改配置文件

• 修改 product.yaml 配置文件

$ vim api/etc/product.yaml

• 修改服务地址，端口号为0.0.0.0:8001，Mysql 服务配置，CacheRedis 服务配置，Auth 验证配置

Name: Product Host: 0.0.0.0 Port: 8001Mysql: DataSource: root:123456@tcp(mysql:3306)/mall?charset=utf8mb4&parseTime=true&loc=Asia%2FShanghaiCacheRedis: - Host: redis:6379 Type: node # node可以不写，可以设为cluster # Pass: xxx # 如果有密码Auth: AccessSecret: uOvKLmVfztaXGpNYd4Z0I1SiT7MweJhl AccessExpire: 86400

4.5.2 添加 product rpc 依赖

• 添加 product rpc 服务配置

$ vim api/etc/product.yaml

Name: Product Host: 0.0.0.0 Port: 8001 ... ProductRpc: Etcd: Hosts: - etcd:2379 Key: product.rpc

• 添加 product rpc 服务配置的实例化

$ vim api/internal/config/config.go

package configimport ( "github.com/tal-tech/go-zero/rest" "github.com/tal-tech/go-zero/zrpc" )type Config struct { rest.RestConfAuth struct { AccessSecret string AccessExpire int64 }ProductRpc zrpc.RpcClientConf }

• 注册服务上下文 product rpc 的依赖

$ vim api/internal/svc/servicecontext.go

package svcimport ( "mall/service/product/api/internal/config" "mall/service/product/rpc/productclient""github.com/tal-tech/go-zero/zrpc" )type ServiceContext struct { Config config.ConfigProductRpc productclient.Product }func NewServiceContext(c config.Config) *ServiceContext { return &ServiceContext{ Config:c, ProductRpc: productclient.NewProduct(zrpc.MustNewClient(c.ProductRpc)), } }

4.5.3 添加产品创建逻辑 Create

$ vim api/internal/logic/createlogic.go

package logicimport ( "context""mall/service/product/api/internal/svc" "mall/service/product/api/internal/types" "mall/service/product/rpc/product""github.com/tal-tech/go-zero/core/logx" )type CreateLogic struct { logx.Logger ctxcontext.Context svcCtx *svc.ServiceContext }func NewCreateLogic(ctx context.Context, svcCtx *svc.ServiceContext) CreateLogic { return CreateLogic{ Logger: logx.WithContext(ctx), ctx:ctx, svcCtx: svcCtx, } }func (l *CreateLogic) Create(req types.CreateRequest) (resp *types.CreateResponse, err error) { res, err := l.svcCtx.ProductRpc.Create(l.ctx, &product.CreateRequest{ Name:req.Name, Desc:req.Desc, Stock:req.Stock, Amount: req.Amount, Status: req.Status, }) if err != nil { return nil, err }return &types.CreateResponse{ Id: res.Id, }, nil }

4.5.4 添加产品详情逻辑 Detail

$ vim api/internal/logic/detaillogic.go

package logicimport ( "context""mall/service/product/api/internal/svc" "mall/service/product/api/internal/types" "mall/service/product/rpc/product""github.com/tal-tech/go-zero/core/logx" )type DetailLogic struct { logx.Logger ctxcontext.Context svcCtx *svc.ServiceContext }func NewDetailLogic(ctx context.Context, svcCtx *svc.ServiceContext) DetailLogic { return DetailLogic{ Logger: logx.WithContext(ctx), ctx:ctx, svcCtx: svcCtx, } }func (l *DetailLogic) Detail(req types.DetailRequest) (resp *types.DetailResponse, err error) { res, err := l.svcCtx.ProductRpc.Detail(l.ctx, &product.DetailRequest{ Id: req.Id, }) if err != nil { return nil, err }return &types.DetailResponse{ Id:res.Id, Name:res.Name, Desc:res.Desc, Stock:res.Stock, Amount: res.Amount, Status: res.Status, }, nil }

4.5.5 添加产品更新逻辑 Update

$ vim api/internal/logic/updatelogic.go

package logicimport ( "context""mall/service/product/api/internal/svc" "mall/service/product/api/internal/types" "mall/service/product/rpc/product""github.com/tal-tech/go-zero/core/logx" )type UpdateLogic struct { logx.Logger ctxcontext.Context svcCtx *svc.ServiceContext }func NewUpdateLogic(ctx context.Context, svcCtx *svc.ServiceContext) UpdateLogic { return UpdateLogic{ Logger: logx.WithContext(ctx), ctx:ctx, svcCtx: svcCtx, } }func (l *UpdateLogic) Update(req types.UpdateRequest) (resp *types.UpdateResponse, err error) { _, err = l.svcCtx.ProductRpc.Update(l.ctx, &product.UpdateRequest{ Id:req.Id, Name:req.Name, Desc:req.Desc, Stock:req.Stock, Amount: req.Amount, Status: req.Status, }) if err != nil { return nil, err }return &types.UpdateResponse{}, nil }

4.5.6 添加产品删除逻辑 Remove

$ vim api/internal/logic/removelogic.go

package logicimport ( "context""mall/service/product/api/internal/svc" "mall/service/product/api/internal/types" "mall/service/product/rpc/product""github.com/tal-tech/go-zero/core/logx" )type RemoveLogic struct { logx.Logger ctxcontext.Context svcCtx *svc.ServiceContext }func NewRemoveLogic(ctx context.Context, svcCtx *svc.ServiceContext) RemoveLogic { return RemoveLogic{ Logger: logx.WithContext(ctx), ctx:ctx, svcCtx: svcCtx, } }func (l *RemoveLogic) Remove(req types.RemoveRequest) (resp *types.RemoveResponse, err error) { _, err = l.svcCtx.ProductRpc.Remove(l.ctx, &product.RemoveRequest{ Id: req.Id, }) if err != nil { return nil, err }return &types.RemoveResponse{}, nil }

4.6 启动 product rpc 服务

提示：启动服务需要在 golang 容器中启动

$ cd mall/service/product/rpc $ go run product.go -f etc/product.yaml Starting rpc server at 127.0.0.1:9001...

4.7 启动 product api 服务

提示：启动服务需要在 golang 容器中启动

$ cd mall/service/product/api $ go run product.go -f etc/product.yaml Starting server at 0.0.0.0:8001...

项目地址 https://github.com/zeromicro/go-zero
欢迎使用 go-zero 并 star 支持我们！
微信交流群 关注『微服务实践』公众号并点击 交流群 获取社区群二维码。

推荐阅读

• 

  在游戏圈中哪几款神作玩家一直在等？
• 

  高密度gpu 图片分析
• 

  搞笑短信网 超搞笑短信铃声
• 

  华为手机日历如何去消已建的活动
• 

  美容霜什么时候用
• 

  癌细胞|癌细胞转移、扩散前有什么表现？手术难道就不能根治吗？答案来了
• 

  印度将会成为人口第一，中国将失去人口第一大国
• 

  什么是一元回归分析法
• 

  安卓外国聊天视频,即时通讯软件可结合外国person聊天
• 

  ironhe苹果将推出「CarPlay升级版」可用iPhone控制座椅
• 

  ios14负一屏设置方法
• 

  wOPPO未来玩机发布会开启，”三屏“联动打造超能玩家硬核体验
• 

  怎样挑选真的杭白菊
• 

  皇帝柑的皮有什么用
• 

  2019-01-22复盘
• 

  尼康d300怎么调模式 尼康d300模式说明书
• 

  隐瞒犯罪所得是什么罪名 隐瞒犯罪所得罪既遂怎么处罚?
• 

  签劳动合同起止日期和终止日期怎么确定的
• 

  汽车车身树脂怎么清洗 汽车有树脂怎么清洗
• 

  魅族pro6呼吸灯在哪里设置

• 网络攻城狮的世界|【逗老师带你学IT】Windows Server Network Policy Service（NPS）记账与审计
• 【数据结构·水滴计划】|【数据结构】一篇文章带你彻底吃透·算法复杂度
• python 表情包下载器，轻松下载上万个表情包、斗图不用愁
• HarmonyOS|HarmonyOS USB DDK助你轻松实现USB驱动开发
• C/C++|轻松学做C语言课程设计（学生成绩管理系统-链表实现）
• 研发管理|学习笔记（47):150讲轻松搞定Python网络爬虫-爬虫前奏小结和作业
• milvus|PaddleRec与Milvus深度结合，手把手带你体验工业级推荐系统召回速度
• 备战蓝桥杯|【蓝桥python冲刺17天】——如何轻松拿捏必考数论题（（第三弹））
• 备战蓝桥杯|【蓝桥python冲刺31天】——如何轻松拿捏必考数论题（（第一弹））
• java并查集算法带你领略热血江湖