用Kratos写项目吧！ golang框架学习

A. Kratos快速入门官方文档中写的比较好，建议大概浏览一遍，点击此处查看文档，重点“快速开始.目录结构”、“快速开始.创建项目”、“框架组件”里的内容
1. 安装命令： go get -u github.com/go-kratos/kratos/cmd/kratos/v2@latest
2. 目录结构与DDD的对应关系

这个非常重要，可以从DDD层面上去理解框架的设计和整理我们写代码的思路

B. 开始写项目吧！ 1. 初始化项目创建项目
命令： kratos new 你的项目
项目编译和运行
命令行运行方式

cd 你的项目 make all kratos run

Golang运行方式（推荐，支持断点调试） PB文件有更新时需在编译前运行命令如下命令： make all
GoBuild配置 RunKind： Package
PackagePath：你的项目/cmd/你的项目
WorkingDirectory： “你的项目”的绝对路径
Go Tool arguments： -o “你的项目”的绝对路径/bin/server -ldflags "-X main.Version=程序版本-X main.Name=服务名"

main.Version和main.Name 在Kratos程序内部中会使用

Program arguments： --conf 你的配置文件绝对路径
2. 定义API Protocolbuffers 新建PB文件
cd 你的项目
kratos proto add api/问题域/版本/领域对象.proto
名称解析
问题域：
指的是你要处理的这个服务下某一个子问题抽象的名称（建议子问题不要太细）
版本：
API的版本，通常为v1、v2、v3
领域对象：
就是你在这个子问题下给出的解法的抽象，一般可以是功能名或者子问题域的核心对象名，根据实际情况而定
举个例子：
问题域为“元数据处理”，抽象名为 metadata
版本定为v1
处理子问题为“提供环境数据管理”，抽象名为 environment
最终效果为 api/metadata/v1/environment.proto
定义PB文件
初始化PB文件示例
生成的PB文件会有基本的curd的，示例如下
syntax = "proto3";
package api.metadata.v1;
option go_package = "test/api/metadata/v1; v1";
option java_multiple_files = true;
option java_package = "api.metadata.v1";
service Environment {

rpc CreateEnvironment (CreateEnvironmentRequest) returns (CreateEnvironmentReply); rpc UpdateEnvironment (UpdateEnvironmentRequest) returns (UpdateEnvironmentReply); rpc DeleteEnvironment (DeleteEnvironmentRequest) returns (DeleteEnvironmentReply); rpc GetEnvironment (GetEnvironmentRequest) returns (GetEnvironmentReply); rpc ListEnvironment (ListEnvironmentRequest) returns (ListEnvironmentReply);

}
message CreateEnvironmentRequest {}
message CreateEnvironmentReply {}
message UpdateEnvironmentRequest {}
message UpdateEnvironmentReply {}
message DeleteEnvironmentRequest {}
message DeleteEnvironmentReply {}
message GetEnvironmentRequest {}
message GetEnvironmentReply {}
message ListEnvironmentRequest {}
message ListEnvironmentReply {}
添加HTTP支持
初始化文件中仅支持rpc调用，要添加HTTP可以在 service 里具体某个方法中添加以下option
option (google.api.http) = {

$HTTPMethod: "$URL"

};
举个例子
Get方法为
option (google.api.http) = {

get: "/api/v1/environment"

};
Post方法为
option (google.api.http) = {

post: "/api/v1/environment" body: "*" # post 方法必须要的body

};
Put方法
option (google.api.http) = {

put: "/api/v1/environment/{id}" body: "*"

};
Delete方法
option (google.api.http) = {

delete: "/api/v1/environment/{id}"

};
关于message的定义
在message可以定义你的请求参数体和返回体，更多的设置语法可以看这里，简单示例如下
message UpdateEnvironmentRequest {
int32 id = 1 [(validate.rules).int32 = {gt:0}];
string name = 2 [(validate.rules).string.min_len = 1];
string cnName = 3;
int32 product_id = 4;
string region_name = 5;
}
message UpdateEnvironmentReply {
int32 code = 1;
string message = 2;
}
关于参数验证
在使用 validate 之前首先需要安装 proto-gen-validate
go get -d github.com/envoyproxy/protoc-gen-validate
需要在pb文件头部导入 validate.proto 文件,既import "validate/validate.proto";
具体验证语法，可查看此处，或查看kratos官网的参数校验文档
生成API代码&文档
在你的项目的根目录下运行命令
make api
运行完后会发现原先定义的文档里新增了Go文件以及SwaggerJson文件，对应的是代码以及文档文件
3. 编写Service 根据pb生成Service代码
运行命令，即可生成代码
kratos proto server PB文件 -t internal/service
生成代码后，即可在internal/service中编写你的逻辑
service一般仅编写 DTO 和 DO转换逻辑代码，不会涉及到业务逻辑代码
注册Service
Kratos新增一个Service注册，会比较繁琐需注意流程
internal/service 注册服务编写完Service之后，需要在internal/service/service.go中注册服务New方法
这里kratos运用wire作为依赖注入
示例如下
package service
import (

"github.com/google/wire"

)
// ProviderSet is service providers.
var ProviderSet = wire.NewSet(

NewEnvironmentService,

)
server/http、 server/grpc 注册服务更改 server/http 的 NewHTTPServer方法加入你的服务类对象，grpc同理
示例如下
func NewHTTPServer(c conf.Server, environment metadataSrv.EnvironmentService, logger log.Logger) *http.Server {

... ... // 必须加入以下代码完成注册 metdataV1.RegisterEnvironmentHTTPServer(srv, environment)

}
4. 编写Biz 定义DO 根据你自身处理的子问题领域抽象，设计字段
注意DO定义不代表PO，DO主要围绕如何实现业务逻辑去思考，也就更多是操作、实体与实体、实体与值对象的关系梳理，对于数据的存储并不在这里考虑
示例
type Environment struct {

IDint32 Namestring CnNamestring Signature string Product*Product Region*Region CreatedAt int64 UpdatedAt int64

}
定义Repository接口 Repository主要负责持久化数据存储、读取等问题，因DO在这样的设计上，对应到底层的PO可能是1对N的关系，为了让这些对上层解耦，抽象出Repository层来管理持久化数据的生命周期
抽象成接口是为了与管理持久化数据的实现解耦，因为持久化数据的存储引擎有可以是mysql、mongodb，而加了这层之后上层就无须关心了
接口在biz定义的思考在于下层变化不应该影响上层，所以该定义由上层决定，下层实现，有利于屏蔽该影响。
当然就可以理解成“上层仅需知道自己要什么，但不需要知道怎么来”
示例
type EnvironmentRepo interface {

CreateEnvironment(ctx context.Context, product *Environment) error UpdateEnvironment(ctx context.Context, id int32, product *Environment) error DeleteEnvironment(ctx context.Context, id int32) error GetEnvironment(ctx context.Context, id int32) (*Environment, error) ListEnvironment(ctx context.Context, page, pageSize int32, names []string, productNames []string) ([]*Environment, int32, error)

}
编写业务逻辑这里采用了贫血模型，对于面向过程的GO语言实现来说极其友好
声明UseCase来实现逻辑，示例
type EnvironmentUseCase struct {

repo EnvironmentRepo log*log.Helper

}
在此UseCase绑定方法实现业务逻辑代码即可，逻辑实现注重组装业务流程，数据处理，完成业务目标
注册UseCase 编写完一个UseCase后，需要在biz/biz.go中加入该UseCase的New方法，完成注册
示例
package biz
import (

"github.com/google/wire"

【用Kratos写项目吧！】)
// ProviderSet is biz providers.
var ProviderSet = wire.NewSet(

NewEnvironmentUseCase,

}
5. 编写Data 定义PO 这里需要注意你自身选择的ORM，当前我使用的是EntORM，出至Facebook，采用定义生成静态代码的形式提供ORM功能，功能不黑盒，容易调试，暂时对比GORM的反射实现的黑盒运行，更喜欢Ent的透明，这里选择因人而异，最好贴近团队选择。
Ent定义生成代码
安装Ent go get entgo.io/ent/cmd/ent
生成Schema文件在data目录下执行以下命令
go run entgo.io/ent/cmd/ent init PO名
更改Schema文件定义字段增加字段：在 FIelds 方法中加入字段即可, 示例如下 func (Environment) Fields() []ent.Field {

return []ent.Field{ field.String("name").NotEmpty(), field.String("cn_name").Default(""), field.String("signature").NotEmpty().Unique(), field.Int64("created_at").DefaultFunc(func() int64 { return time.Now().Unix() }).Immutable(), field.Int64("updated_at").DefaultFunc(func() int64 { return time.Now().Unix() }).UpdateDefault(func() int64 { return time.Now().Unix() }), }

}
增加实体关系：在 Edges 方法中加入定义即可，这里涉及多对多，1对1，1对多的关系定义，可以查看这里，示例如下 func (Environment) Edges() []ent.Edge {

return []ent.Edge{ edge.To("product", Product.Type).Unique(), edge.To("region", Region.Type).Unique(), }

}
// 这里演示的是一个environment只跟一个 product有关系，一个environment只跟一个region有关系，
生成静态代码在data目录中运行命令
ent generate ./ent/schema
Data类中管理ORMClient
更改data/data.go文件，根据自身所使用的缓存库、数据库库，更改Data结构体字段以及在NewData方法增加它们的初始化逻辑
比如示例如下，我使用Ent、localCache
// Data .
type Data struct {

// TODO wrapped database client db*ent.Client cache *cache.Cache

}
// NewData .
func NewData(c conf.Data, logger log.Logger) (Data, func(), error) {

logHelper := log.NewHelper(logger)client, err := ent.Open( conf.Database.Driver, conf.Database.Source, )// Run the auto migration tool. if err := client.Schema.Create(context.Background()); err != nil { logHelper.Errorf("failed creating schema resources: %v", err) return nil, nil, err }var d = &Data{ db:client, cache: cache.New(c.Cache.Expiration.AsDuration(), c.Cache.CleanupInterval.AsDuration()), } return d, func() { logHelper.Info("message", "closing the data resources") if err := d.db.Close(); err != nil { logHelper.Error(err) } }, nil

}
依据biz定义的Repo实现逻辑
定义实现类，示例如下
type environmentRepo struct {

data *Data log*log.Helper

}
实现Repository逻辑
接下来只需要实现BIZ定义的Repository接口即可
注册Repository
编写完一个Repo后，需要在data/data.go中加入该Repository的New方法，完成注册
示例
var ProviderSet = wire.NewSet(

NewData, NewEnvironmentRepo,

)
// NewData不能变，是Repo基础依赖库
6. 更新配置修改配置 kratos统一采用了pb管理conf，所以仅需在internal/conf/conf.proto修改配置字段即可
更新配置代码在你的项目根目录下运行以下命令，更新配置代码
make config
7. Reference https://go-kratos.dev
https://github.com/envoyproxy...
https://developers.google.com...
https://developers.google.com...
https://colobu.com/2017/03/16...
https://entgo.io/zh/docs/gett...