全新重构，希望更多开源爱好者能加入共同开发练手，共同进步，请联系下方wx

demo project

graph TD
    classDef done fill:#2ecc71,stroke:#27ae60,color:#fff  
    classDef pending fill:#bdc3c7,stroke:#95a5a6,color:#333

    A[交易所<br>Exchange]

    A --> aa[基础数据<br>Base]
    aa --> aa1[资产种类<br>Asset]
    aa --> aa2[交易品种<br>Product]

    A --> AA[用户中心<br>UserCenter]
    AA --> AAa[用户资产<br>UserAssets]
    class AAa done
    AA--> AAb[用户订单<br>UserOrders]
    class AAb done
    A --> AC[交易核心<br>TradingCore]
    A --> AC3[行情系统<br>Quote]
    class AC3 pending
    A --> AD[消息推送<br>Notification]
    class AD pending
    A --> AZ[...<br>Other]

    AC --> AC1[撮合引擎<br>MatchingEngine]
    class AC1 done
    AC --> AC2[订单结算<br>Settlement]
    class AC2 done
    

轻量、可扩展的交易引擎示例（撮合引擎、订单处理、结算与通知），用于研究、演示与二次开发。

• 高性能撮合引擎（限价/市价、优先撮合逻辑）
• 事件驱动的订单处理与结算流水
• 使用 fx 进行模块化依赖注入，支持快速组合与测试
• GORM + Postgres 持久化，Redis 用作缓存/消息队列（开发模式）
• 已包含示例前端（frontend/example）用于功能演示

• cmd/：程序入口与 CLI（迁移/运行/版本）
• internal/di/：依赖注入与 providers（Viper、Gorm、Redis、Gin 等）
• internal/modules/：业务模块（base, tradingcore, usercenter, notification, quote, example）
• internal/persistence/：Repository 接口与数据库实现
• pkg/matching：可复用撮合引擎包（含测试）
• frontend/example：示例前端（Vite + 框架）

先确保已安装 docker 与 docker-compose。

1. 启动依赖服务（Postgres、Redis、RocketMQ (dev)）

docker compose up -d

2. 启动服务（开发模式）

# 在项目根目录
make run

3. 前端 demo（另开终端）

cd frontend/example
npm install
npm run dev:h5
# 打开浏览器: http://127.0.0.1:5174/example/?symbol=btcusdt

4. 数据库迁移（示例）

# 使用仓库提供的迁移脚本
make migrate-up

注意：仓库包含一个「仅在开发模式」的自动迁移实现，已对自动迁移策略进行改进（逐模型新增缺失列）。生产环境请使用可审计的 SQL migration 流程并禁用自动迁移。

• 代码风格：遵循 Go 约定，使用 gofmt / go vet / golangci-lint。
• 运行单元与包级测试：

# 运行所有测试（较大仓库建议按包运行）
go test ./... 
# 运行匹配模块测试（建议加 race 检测）
go test ./pkg/matching -race -v

撮合引擎封装为可复用包，典型用法：

ctx := context.Background()
opts := []matching.Option{
        matching.WithPriceDecimals(2),
        matching.WithQuantityDecimals(2),
}
engine := matching.NewEngine(ctx, "btcusdt", opts...)

// 添加订单
engine.AddItem(item)
// 撤单
engine.RemoveItem(side, orderId, removeType)

// 订阅事件
engine.OnTradeResult(func(r matching_types.TradeResult) { /* handle */ })
engine.OnRemoveResult(func(r matching_types.RemoveResult) { /* handle */ })

// 获取深度
asks := engine.GetAskOrderBook(10)
bids := engine.GetBidOrderBook(10)

更多实现细节请查看 pkg/matching 源码与示例测试。

• 自动迁移：已改为按模型新增缺失列以降低风险；生产环境仍建议禁用自动迁移并采用明确的 SQL migration。
• 认证：部分 API（如订单相关）受 JWT 中间件保护，调用时需携带有效 token（示例前端包含认证流程）。
• 消息队列：当前开发实现中 Produce 使用 Redis LPUSH 作为轻量消息通道；可按需替换为 RocketMQ 或其他中间件。

欢迎贡献：请先阅读代码、运行测试并在变更前提 issue 或 PR。建议流程：

1. Fork 仓库并创建新分支
2. 本地运行并验证变更：go test ./...、golangci-lint run
3. 提交 PR，并在描述中说明变更目的、影响范围与回归验证步骤

如果你希望参与核心模块（撮合/结算/迁移策略等），请先与仓库维护者讨论实现方案。