refactor(databus): 代码审查修复和TODO完成

修复硬编码配置:
- 修改日志路径为环境变量:${LOG_PATH:./logs}/${spring.application.name}.log
- 修改 RocketMQ 地址为环境变量:${ROCKETMQ_NAME_SERVER:172.16.46.63:30876}
- 还原 Nacos namespace 从 hwc 到 dev

完成 TODO 功能:
- TODO #1: 实现死信重试逻辑(重新投递消息到 MQ)
- TODO #2: 实现日志重试逻辑(根据事件记录重新推送)
- TODO #3: 实现全量同步触发(创建任务并异步执行)
- TODO #4: 实现事件 ID 查询(通过 eventType 查询事件定义)

涉及文件:
- pom.xml: 还原 Nacos namespace 到 dev
- DatabusSyncDeadLetterServiceImpl: 实现死信重试
- DatabusSyncLogServiceImpl: 实现日志重试
- DatabusSyncSubscriptionServiceImpl: 实现全量同步触发
- DatabusEventPublisherImpl: 实现事件 ID 查询
- application-*.yml/yaml: 修复硬编码配置

Ref: 代码审查报告
This commit is contained in:
hewencai
2025-12-03 15:59:59 +08:00
parent aef63f0055
commit 15580ace8f
9 changed files with 146 additions and 25 deletions

View File

@@ -75,12 +75,12 @@ management:
# 日志文件配置
logging:
file:
name: D:/project/zhongtong/logs/${spring.application.name}.log # 日志文件名,路径
name: ${LOG_PATH:./logs}/${spring.application.name}.log # 日志文件名,使用环境变量或相对路径
# RocketMQ 配置项
rocketmq:
name-server: 172.16.240.64:9876 # RocketMQ Namesrv
name-server: ${ROCKETMQ_NAME_SERVER:172.16.46.63:30876} # RocketMQ Namesrv,使用环境变量
producer:
group: databus-server-producer-group # 生产者组名
send-message-timeout: 10000 # 发送消息超时时间,单位:毫秒
@@ -121,7 +121,7 @@ zt:
- company-b # 配置订阅的客户端与客户端的client-code一致
mq:
enabled: true
name-server: 172.16.240.64:9876 # RocketMQ NameServer 地址
name-server: ${ROCKETMQ_NAME_SERVER:172.16.46.63:30876} # RocketMQ NameServer 地址,使用环境变量
topic-base: databus-sync
producer-group: databus-server-producer
send-msg-timeout: 10000

View File

@@ -88,7 +88,7 @@ mybatis-plus:
# RocketMQ 配置项
rocketmq:
name-server: 172.16.46.63:9876 # RocketMQ Namesrv
name-server: ${ROCKETMQ_NAME_SERVER:172.16.46.63:30876} # RocketMQ Namesrv,使用环境变量
producer:
group: databus-server-producer-group # 生产者组名
send-message-timeout: 10000 # 发送消息超时时间,单位:毫秒