基于Golang+Kratos+MySQL+Redis+Kafka+elk+Opentracing实现的微服务项目
- 房源列表
- 房源详情 (TODO)
- 点击房源title，代表查看了房源，会生成一条查看历史记录
- 输入用户名进行登录
- 看房历史记录 (TODO)
- 微服务架构（BFF、Service、Admin、Job、Task 分模块）
- API 设计（包括 API 定义、错误码规范、Error 的使用）
- gRPC 的使用
- Go 项目工程化（项目结构、DI、代码分层、ORM 框架）
- 并发的使用（errgroup 的并行链路请求）
- 微服务中间件的使用（ELK、Opentracing、Prometheus、Kafka） (链路追踪)
- 缓存的使用优化（一致性处理、Pipeline 优化）
.
├── README.md
├── api
│ ├── account
│ ├── history
│ └── house
├── app
│ ├── account
│ ├── history
│ └── house
├── deploy
│ └── docker
├── docs
│ └── images
├── gen
├── go.mod
├── go.sum
├── openapi.yaml
├── pkg
│ └── job
├── third_party
│ ├── README.md
│ ├── errors
│ ├── google
│ ├── protoc-gen-openapiv2
│ └── validate
└── web
├── admin
└── kfan
通过kratos构建工具生成，新增了job子目录
.
├── Dockerfile
├── Makefile
├── README.md
├── cmd
│ ├── history
│ └── job
├── configs
│ └── config.yaml
├── generate.go
└── internal
├── biz
├── conf
├── data
├── job
├── server
└── service
- docker-compose运行
cd deploy/docker && make kfan-run- 清除容器
make cleanerrgroup 的并行链路请求
并行请求多个服务获取详情信息
eg, ctx := errgroup.WithContext(ctx)
for _, history := range histories {
history := history
eg.Go(func() error {
house, err := h.data.h1.GetHouse(ctx, &housepb.GetHouseRequest{Id: history.ObjId})
if err != nil {
return err
}
history.ObjDetail = structs.Map(house)
return nil
})
eg.Go(func() error {
account, err := h.data.a1.GetAccount(ctx, &accountpb.GetAccountRequest{Id: int32(history.UserId)})
if err != nil {
return err
}
history.Username = account.GetName()
return nil
})
}
err = eg.Wait()-
生成proto代码
kratos proto client api/account/service/v1/account.proto
- 创建volume
docker volume create kfan-db- SaveHistory
grpcurl -d '{"obj_id": 2,"obj_type": "house","user_id": 1}' -plaintext 127.0.0.1:9002 api.history.service.v1.History/SaveHistory- GetHistory
grpcurl -d '{"user_id": 1}' -plaintext 127.0.0.1:9002 api.history.service.v1.History/GetHistory