Administrator
2026-08-13 e70e04de37946bbb516b40aca0b1c086528398cd
refs
author Administrator <15274802129@163.com>
Thursday, August 13, 2026 15:08 +0800
committer Administrator <15274802129@163.com>
Monday, August 24, 2026 14:04 +0800
commite70e04de37946bbb516b40aca0b1c086528398cd
tree c308d12b5bf87546de41ccd9ee6095dcd873fe19 tree | zip | gz
parent e129a02db0b655d97806ddb3c55297ede56e6a6f view | diff
feat(gate): 添加策略远程控制和监控功能

- 新增指令确认消息模型 CmdAckMsg 用于响应 Station 指令
- 实现 CommandQueueInitializer 动态创建专属命令队列 QUEUE_GATE_CMD_{apiKeyMd5}
- 添加 GateCommand 模型定义 Station 下发的启停和参数更新指令
- 创建 GateCommandConsumer 消费远程指令并执行相应操作
- 扩展 GateConfigDTO 添加参数快照和默认值工厂方法
- 在 GateGridTradeService 中集成埋点功能发送策略事件统计
- 新增 GateStatsEvent 模型定义 JAR 上报的策略事件格式
- 更新 GateWebSocketClientManager 支持远程配置更新和重载启动
- 添加 HeartbeatMsg 模型和 HeartbeatScheduler 定时发送心跳
- 创建 InstanceInfo 模型存储 JAR 实例注册信息
- 配置 RabbitMQ 添加 Gate 管理交换机和相关队列绑定
- 实现 StatsEventProducer 统一消息发送器处理心跳和事件上报
10 files added
4 files modified
780 ■■■■■ changed files
config/gate-config-7332fa3f94276d3dcc44fcd3bfff2379.json 28 ●●●●● diff | view | raw | blame | history
src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java 39 ●●●●● diff | view | raw | blame | history
src/main/java/com/xcong/excoin/modules/gateApi/CommandQueueInitializer.java 70 ●●●●● diff | view | raw | blame | history
src/main/java/com/xcong/excoin/modules/gateApi/GateCommandConsumer.java 111 ●●●●● diff | view | raw | blame | history
src/main/java/com/xcong/excoin/modules/gateApi/GateConfigDTO.java 63 ●●●●● diff | view | raw | blame | history
src/main/java/com/xcong/excoin/modules/gateApi/GateGridTradeService.java 112 ●●●●● diff | view | raw | blame | history
src/main/java/com/xcong/excoin/modules/gateApi/GateWebSocketClientManager.java 50 ●●●● diff | view | raw | blame | history
src/main/java/com/xcong/excoin/modules/gateApi/HeartbeatScheduler.java 92 ●●●●● diff | view | raw | blame | history
src/main/java/com/xcong/excoin/modules/gateApi/StatsEventProducer.java 72 ●●●●● diff | view | raw | blame | history
src/main/java/com/xcong/excoin/modules/station/model/CmdAckMsg.java 24 ●●●●● diff | view | raw | blame | history
src/main/java/com/xcong/excoin/modules/station/model/GateCommand.java 29 ●●●●● diff | view | raw | blame | history
src/main/java/com/xcong/excoin/modules/station/model/GateStatsEvent.java 26 ●●●●● diff | view | raw | blame | history
src/main/java/com/xcong/excoin/modules/station/model/HeartbeatMsg.java 30 ●●●●● diff | view | raw | blame | history
src/main/java/com/xcong/excoin/modules/station/model/InstanceInfo.java 34 ●●●●● diff | view | raw | blame | history