1、学习课程 带你十天轻松搞定 Go 微服务系列（四）
2、产品服务（product） 进入服务工作区

$ cd mall/service/product

2.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;

运行模板生成命令（和昨天一样要在golang容器下运行）

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

2.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) }

运行模板生成命令（一样要在golang容器下运行）

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

2.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); }

运行模板生成命令（一样要在golang容器下运行）

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

2.4 编写 product rpc 服务 2.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 # 如果有密码

2.4.2 添加 product model 依赖
添加 Mysql 服务配置，CacheRedis 服务配置的实例化

$ vim rpc/internal/config/config.go

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

【学习笔记（带你十天轻松搞定|学习笔记：带你十天轻松搞定 Go 微服务系列（四）- 产品服务）】注册服务上下文 product model 的依赖

$ vim rpc/internal/svc/servicecontext.go

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

2.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/zeromicro/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 }

2.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/zeromicro/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 }

2.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/zeromicro/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 }

2.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/zeromicro/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 }

2.5 编写 product api 服务 2.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

2.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/zeromicro/go-zero/rest" "github.com/zeromicro/go-zero/zrpc" )type Config struct { rest.RestConf Auth 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/zeromicro/go-zero/zrpc" )type ServiceContext struct { Config config.Config ProductRpc productclient.Product }func NewServiceContext(c config.Config) *ServiceContext { return &ServiceContext{ Config:c, ProductRpc: productclient.NewProduct(zrpc.MustNewClient(c.ProductRpc)), } }

2.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/zeromicro/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 }

2.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/zeromicro/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 }

2.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/zeromicro/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 }

2.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/zeromicro/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 }

2.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...

文章图片

2.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...

文章图片

推荐阅读

• 

  北控水务为什么不涨 北控水务到底好不好
• 

  牵组词语 汉字牵组词语
• 

  月季花扦插的最佳时间 月季花扦插的最佳时间现在可以插吗?
• 

  2023重庆医科大学研究生成绩复查申请时间+方式
• 

  n95口罩能防尘吗 n95口罩可以用几次
• 

  摩托罗拉里程碑2刷机
• 

  如果你爱的人总是以怨报德,你会怎么样？
• 

  宝马525多少钱落地 宝马525价格多少钱
• 

  电商铺货是什么意思 电商货架什么意思，货架市场
• 

  胡萝卜怎样吃最有营养啊视频 胡萝卜怎样吃最有营养啊
• 

  巴戟天药材多少钱一斤，巴戟天药店多少钱一斤
• 

  吕锅上的污渍怎么去除啊
• 

  非主流图片唯美霸气 非主流相框素材
• 

  白金膏的功效与作用 皮白金膏的功效与作用?
• 

  虚拟机怎么开网页游戏模式，虚拟机怎样打开网页
• 

  闻鸡起舞的主人公是谁 囊萤映雪的主人公是谁
• 

  口红吃饭的时候怎么办
• 

  宝宝长期咳嗽易得肺炎
• 

  包贝尔大婚柳岩遭闹伴娘 柳岩伴娘事件是什么?
• 

  未婚生子罚款多少2022年 未婚生子罚款多少2022？

• 深度学习（基于pytorch）|深度学习笔记（七）——pytorch数据处理工具箱（一）
• 深度学习|NLP文本的离散表示
• 深度学习|【吴恩达深度学习】03_week2_quiz Autonomous driving (case study)
• 微服务学习|Redis6学习笔记(下)
• 前端|最全的TypeScript学习指南
• React|【学习笔记】React+React全家桶学习笔记
• 个人笔记|SpringBoot Admin 系统监控
• 视频教程-生成对抗网络案例实践-深度学习
• python学习|利用python爬虫技术获取每天每场的每位球员NBA数据以及每日范特西评分
• JavaSE学习笔记Day07