修复硬编码配置:
- 修改日志路径为环境变量:${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: 代码审查报告
105 lines
3.8 KiB
YAML
105 lines
3.8 KiB
YAML
spring:
|
||
# 数据源配置项
|
||
autoconfigure:
|
||
# noinspection SpringBootApplicationYaml
|
||
exclude:
|
||
- com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceAutoConfigure # 排除 Druid 的自动配置,使用 dynamic-datasource-spring-boot-starter 配置多数据源
|
||
datasource:
|
||
druid: # Druid 【监控】相关的全局配置
|
||
web-stat-filter:
|
||
enabled: true
|
||
stat-view-servlet:
|
||
enabled: true
|
||
allow: # 设置白名单,不填则允许所有访问
|
||
url-pattern: /druid/*
|
||
login-username: # 控制台管理用户名和密码
|
||
login-password:
|
||
filter:
|
||
stat:
|
||
enabled: true
|
||
log-slow-sql: true # 慢 SQL 记录
|
||
slow-sql-millis: 100
|
||
merge-sql: true
|
||
wall:
|
||
config:
|
||
multi-statement-allow: true
|
||
dynamic: # 多数据源配置
|
||
druid: # Druid 【连接池】相关的全局配置
|
||
initial-size: 1 # 初始连接数
|
||
min-idle: 1 # 最小连接池数量
|
||
max-active: 20 # 最大连接池数量
|
||
max-wait: 600000 # 配置获取连接等待超时的时间,单位:毫秒
|
||
time-between-eviction-runs-millis: 60000 # 配置间隔多久才进行一次检测,检测需要关闭的空闲连接,单位:毫秒
|
||
min-evictable-idle-time-millis: 300000 # 配置一个连接在池中最小生存的时间,单位:毫秒
|
||
max-evictable-idle-time-millis: 900000 # 配置一个连接在池中最大生存的时间,单位:毫秒
|
||
validation-query: SELECT 1 FROM DUAL # 配置检测连接是否有效
|
||
test-while-idle: true
|
||
test-on-borrow: false
|
||
test-on-return: false
|
||
primary: master
|
||
datasource:
|
||
master:
|
||
url: jdbc:dm://172.16.46.247:1050?schema=RUOYI-VUE-PRO
|
||
username: SYSDBA
|
||
password: pgbsci6ddJ6Sqj@e
|
||
slave: # 模拟从库,可根据自己需要修改 # 模拟从库,可根据自己需要修改
|
||
lazy: true # 开启懒加载,保证启动速度
|
||
url: jdbc:dm://172.16.46.247:1050?schema=RUOYI-VUE-PRO
|
||
username: SYSDBA
|
||
password: pgbsci6ddJ6Sqj@e
|
||
|
||
# Redis 配置。Redisson 默认的配置足够使用,一般不需要进行调优
|
||
data:
|
||
redis:
|
||
host: 172.16.46.63 # 地址
|
||
port: 30379 # 端口
|
||
database: 0 # 数据库索引
|
||
# password: 123456 # 密码,建议生产环境开启
|
||
|
||
xxl:
|
||
job:
|
||
admin:
|
||
addresses: http://172.16.46.63:30082/xxl-job-admin # 调度中心部署跟地址
|
||
|
||
# Lock4j 配置项
|
||
lock4j:
|
||
acquire-timeout: 3000 # 获取分布式锁超时时间,默认为 3000 毫秒
|
||
expire: 30000 # 分布式锁的超时时间,默认为 30 毫秒
|
||
|
||
# Actuator 监控端点的配置项
|
||
management:
|
||
endpoints:
|
||
web:
|
||
base-path: /actuator # Actuator 提供的 API 接口的根目录。默认为 /actuator
|
||
exposure:
|
||
include: '*' # 需要开放的端点。默认值只打开 health 和 info 两个端点。通过设置 * ,可以开放所有端点。
|
||
|
||
# 日志文件配置
|
||
logging:
|
||
level:
|
||
# 配置自己写的 MyBatis Mapper 打印日志
|
||
com.zt.plat.module.databus.dal.mysql: debug
|
||
org.springframework.context.support.PostProcessorRegistrationDelegate: ERROR
|
||
|
||
mybatis-plus:
|
||
configuration:
|
||
log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
|
||
|
||
|
||
# RocketMQ 配置项
|
||
rocketmq:
|
||
name-server: ${ROCKETMQ_NAME_SERVER:172.16.46.63:30876} # RocketMQ Namesrv,使用环境变量
|
||
producer:
|
||
group: databus-server-producer-group # 生产者组名
|
||
send-message-timeout: 10000 # 发送消息超时时间,单位:毫秒
|
||
|
||
# ZT配置项,设置当前项目所有自定义的配置
|
||
zt:
|
||
env: # 多环境的配置项
|
||
tag: ${HOSTNAME}
|
||
security:
|
||
mock-enable: true
|
||
access-log: # 访问日志的配置项
|
||
enable: true
|
||
|