init

.gitignore

@@ -0,0 +1,13 @@
+.buildpath
+.hgignore.swp
+.project
+.orig
+.swp
+.idea/
+.settings/
+.vscode/
+vender/
+gitpush.sh
+bin/
+cbuild
+*/.DS_Store

Makefile

@@ -0,0 +1,29 @@
+# helm
+## helm地址
+HELM_TEMP_DIR := "manifest/framework_tool/k8s/temp_helm" # 进入helm地址
+HELM_IMAGE := "go-ddd-demo.tgz"
+HELM_DIR := "go-ddd-demo"
+HELM_IMAGE_REPO := "go-ddd-demo-helm" # helm远程仓库地址
+
+.PHONY: init-helm
+init-helm: ## 安装helm环境
+	@cd /tmp && wget https://get.helm.sh/helm-v3.8.2-linux-amd64.tar.gz \
+	&& tar -zxvf helm-v3.8.2-linux-amd64.tar.gz \
+	&& cp linux-amd64/helm /usr/local/bin \
+	&& helm version
+
+.PHONY: install-rds
+install-rds: ## 安装项目依赖的db
+	@docker-compose -f deploy/framework_tool/mysql/docker-compose.yaml up -d
+
+.PHONY: uninstall-rds
+uninstall-rds: ## 卸载项目依赖的db
+	@docker-compose -f deploy/framework_tool/mysql/docker-compose.yaml down
+
+.PHONY: install-otel
+install-otel: ## 安装项目的可观测性
+	@docker-compose -f deploy/framework_tool/otel-jaeger/docker-compose.yaml up -d
+
+.PHONY: uninstall-otel
+uninstall-otel: ## 协助项目的可观测性
+	@docker-compose -f deploy/framework_tool/otel-jaeger/docker-compose.yaml down

README-DDD.md

@@ -0,0 +1,152 @@
+# DDD 项目
+
+## 层级说明
+```base
+├── interfaces 接入层 【http/grpc适配, 这一层调用application层; 比如interfaces层定义了输入层的相关方法，以使用gin提供http接口为例，这里的handler等为使用gin提供的一些http接口，这一层调用application层】
+│   ├── grpc
+│   └── http
+│   └── facade  引用其他微服务（接口防腐层）
+│   ├── event 事件
+│   │   └── subscribe mq消费入口
+│   ├── job 定时任务
+├── application 应用层 【主要是调用domain层与infrastructure层来实现功能】
+│   ├── assembler   负责将内部领域模型转化为可对外的DTO
+│   └── dto Application层的所有接口返回值为DTO -- 入参/出参
+│   └── service 负责业务流程的编排，但本身不负责任何业务逻辑
+├── domain 领域层 【主要是定义了entity，以及repository接口；entity里头会包含一些领域逻辑,Domain模块仅依赖Types模块】
+│   ├── aggregate 聚合 【对于需要两个repo一起操作的，可以进行聚合，比如创建用户的时候有userRepo,还有日志的userLogRepo】
+│   ├── entity 实体 业务逻辑。也可以参数校验，扩展一些简单方法，减轻service的压力
+│   ├── event 事件
+│   │   ├── publish 所有发送mq在此处理
+│   │   └── subscribe 所有接受到mq处理逻辑在此处理
+│   ├── irepository 接口
+│   ├── srv 领域服务 【单一操作，比如查看用户信息。没有聚合的操作的时候，在此实现】
+└── infrastructure 基础设施层 【这里提供了针对domain层的repository接口的实现，还有其他一些基础的组件，提供给application层或者interfaces层使用】
+│   ├── config 配置文件
+│   ├── consts 系统常量
+│   ├── pkg 常用工具类封装（DB,log,util等）
+│   └── repository 针对domain层的repository接口的实现
+│   │   └── converter domain内对象转化 po {互转}
+│   │   └── repo 针对domain层的repository接口的具体实现
+│   │   └── po 数据库映射对象
+└── types 完全独立的模块(DP)，封装自定义的参数类型,例如 phone 相关的类型，校验合法、区号等。  
+```
+
+## DDD小结
+DDD一般分为interfaces、application、domain、infrastructure这几层；
+
+其中domain层不依赖其他层，它定义repository接口，infrastructure层会实现；
+
+application层会调用domain、infrastructure层；
+
+interfaces层一般调用application层或者infrastructure层。
+
+
+## 相关概念
+
+- DDD等相关概念：https://domain-driven-design.org/zh/ddd-concept-reference.html
+
+- VO（View Object）：视图对象，用于展示层，它的作用是把某个指定页面（或组件）的所有数据封装起来。
+- DTO（Data Transfer Object）：数据传输对象，这个概念来源于J2EE的设计模式，原来的目的是为了EJB的分布式应用提供粗粒度的数据实体，以减少分布式调用的次数，从而提高分布式调用的性能和降低网络负载，但在这里，我泛指用于展示层与服务层之间的数据传输对象。
+- DO（Domain Object）：领域对象(entity)，就是从现实世界中抽象出来的有形或无形的业务实体。
+- PO（Persistent Object）：持久化对象，它跟持久层（通常是关系型数据库）的数据结构形成一一对应的映射关系，如果持久层是关系型数据库，那么，数据表中的每个字段（或若干个）就对应PO的一个（或若干个）属性。
+
+> ```
+> 用户发出请求（可能是填写表单），表单的数据在展示层被匹配为VO。
+> 展示层把VO转换为服务层对应方法所要求的DTO，传送给服务层。
+> 服务层首先根据DTO的数据构造（或重建）一个DO，调用DO的业务方法完成具体业务。
+> 服务层把DO转换为持久层对应的PO（可以使用ORM工具，也可以不用），调用持久层的持久化方法，把PO传递给它，完成持久化操作。
+> 对于一个逆向操作，如读取数据，也是用类似的方式转换和传递
+> ```
+
+
+
+# 项目运行
+
+## 配置
+
+manifest/config/config.yaml
+
+```yaml
+# HTTP Server.
+server:
+  lang: zh-CN # "zh-CN", "zh-TW", "en"
+  public_port: 21800 # 对外端口
+  private_port: 21801 # 对内端口
+  server_name: "AitextGoDdd"
+  mode: "debug" # gin的模式配置 debug, test, release
+  dev: true # true,false;校验token等,开发模式的时候打开
+  enable_event: false # 是否开启事件
+  enable_job: false # 是否开启任务
+  enable_grpc: true # 是否开启grpc
+
+# GRPC Server.
+gserver:
+  host: "0.0.0.0" # 当前服务
+  public_port: 21802 # 当前服务
+  max_msg_size: 1024 # 最大发送接收字节数,单位 m
+  client_goods_host: "0.0.0.0" # goods服务的host
+  client_goods_port: 18080 # goods服务的port
+
+# Database.
+mysql:
+  username: "root"
+  password: "admin123"
+  db_host: "10.4.7.71"
+  db_port: 3306
+  db_name: "go_demo"
+  charset: "utf8mb4"
+  max_open_conn: 50 # 设置数据库连接池最大连接数
+  max_idle_conn: 10 # 连接池最大允许的空闲连接数
+  conn_max_lifetime: 500 # 设置连接可复用的最大时间
+  log_mode: 4 # gorm错误级别; 1: Silent, 2:Error,3:Warn,4:Info
+  slow_threshold: 10 # 慢查询
+
+# Log.
+log:
+  log_file_dir: "/tmp/logs/"
+  max_size: 512
+  max_backups: 64
+  max_age: 7
+  log_level: "debug" #自定义日志； trace, debug, info,panic, fatal, error, warn
+  log_out: "console" # console, file
+
+# nsq.
+nsq:
+  nsq_producer_host: "10.4.7.71"
+  nsq_producer_port: 4150 # tcp
+  nsq_subscribe_host: "10.4.7.71"
+  nsq_subscribe_port: 4150 # tcp
+
+# otel
+otel:
+  enable: false
+  export_endpoint: "10.4.7.71:4317"
+
+```
+
+## 运行
+- 直接运行： go run main.go
+- 指定环境运行: go run main.go -env test
+- 编译：go build
+
+
+# 更多
+
+## 支持多配置运行
+
+```
+go run main.go # 会使用默认的开发配置，即 debug模式
+go run main.go -env test # 会使用test的配置，即测试环境
+go run main.go -env release # 会使用release的配置，即正式环境
+```
+
+## 支持多协议并存
+
+程序可以支持：http协议，又分为内部接口、外部接口。比如
+
+外部接口: http://127.0.0.1:21800/api/pc/v1/sys/menu/1
+
+内部接口：http://127.0.0.1:21801/private/pc/v1/sys/demo
+
+grpc接口：127.0.0.1:21802

README.md

@@ -0,0 +1,7 @@
+# aitext-go-ddd-multi
+
+## 介绍
+
+go-ddd-multi ，是实现ddd的多模块的案例。在业务开发中，会分common、biz1、biz2等等；
+
+因此此项目是参考java的设计，然后汇集而成。

common/README.md

@@ -0,0 +1,2 @@
+# common
+公共模块

common/go.mod

@@ -0,0 +1,62 @@
+module jettjia/go-ddd-demo-multi-common
+
+go 1.20
+
+require (
+	github.com/BurntSushi/toml v1.3.2
+	github.com/dtm-labs/rockscache v0.1.1
+	github.com/gin-gonic/gin v1.9.1
+	github.com/go-playground/validator/v10 v10.15.4
+	github.com/gogf/gf/v2 v2.5.4
+	github.com/oklog/ulid/v2 v2.1.0
+	github.com/pkg/errors v0.9.1
+	github.com/redis/go-redis/v9 v9.2.0
+	github.com/sirupsen/logrus v1.9.3
+	gopkg.in/natefinch/lumberjack.v2 v2.2.1
+	gopkg.in/yaml.v3 v3.0.1
+	gorm.io/driver/mysql v1.5.1
+	gorm.io/gorm v1.25.4
+)
+
+require (
+	github.com/bytedance/sonic v1.9.1 // indirect
+	github.com/cespare/xxhash/v2 v2.2.0 // indirect
+	github.com/chenzhuoyu/base64x v0.0.0-20221115062448-fe3a3abad311 // indirect
+	github.com/clbanning/mxj/v2 v2.7.0 // indirect
+	github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f // indirect
+	github.com/fatih/color v1.15.0 // indirect
+	github.com/fsnotify/fsnotify v1.6.0 // indirect
+	github.com/gabriel-vasile/mimetype v1.4.2 // indirect
+	github.com/gin-contrib/sse v0.1.0 // indirect
+	github.com/go-logr/logr v1.2.4 // indirect
+	github.com/go-logr/stdr v1.2.2 // indirect
+	github.com/go-playground/locales v0.14.1 // indirect
+	github.com/go-playground/universal-translator v0.18.1 // indirect
+	github.com/go-sql-driver/mysql v1.7.0 // indirect
+	github.com/goccy/go-json v0.10.2 // indirect
+	github.com/google/uuid v1.3.0 // indirect
+	github.com/jinzhu/inflection v1.0.0 // indirect
+	github.com/jinzhu/now v1.1.5 // indirect
+	github.com/json-iterator/go v1.1.12 // indirect
+	github.com/klauspost/cpuid/v2 v2.2.4 // indirect
+	github.com/leodido/go-urn v1.2.4 // indirect
+	github.com/lithammer/shortuuid v3.0.0+incompatible // indirect
+	github.com/magiconair/properties v1.8.6 // indirect
+	github.com/mattn/go-colorable v0.1.13 // indirect
+	github.com/mattn/go-isatty v0.0.19 // indirect
+	github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect
+	github.com/modern-go/reflect2 v1.0.2 // indirect
+	github.com/pelletier/go-toml/v2 v2.0.8 // indirect
+	github.com/twitchyliquid64/golang-asm v0.15.1 // indirect
+	github.com/ugorji/go/codec v1.2.11 // indirect
+	go.opentelemetry.io/otel v1.14.0 // indirect
+	go.opentelemetry.io/otel/sdk v1.14.0 // indirect
+	go.opentelemetry.io/otel/trace v1.14.0 // indirect
+	golang.org/x/arch v0.3.0 // indirect
+	golang.org/x/crypto v0.11.0 // indirect
+	golang.org/x/net v0.12.0 // indirect
+	golang.org/x/sync v0.1.0 // indirect
+	golang.org/x/sys v0.10.0 // indirect
+	golang.org/x/text v0.11.0 // indirect
+	google.golang.org/protobuf v1.30.0 // indirect
+)