Redis 应用接入
maven 依赖
<dependency>
<groupId>io.github.cnzhangxy51</groupId>
<artifactId>dynamic-thread-pool-core</artifactId>
<version>1.0.0</version>
</dependency>
配置文件
yml 格式
yml
dynamic:
thread:
pool:
config:
# 动态更新相关
refresher:
enabled: true
channel:
platform: redis
# redis 相关
redis:
enabled: true
host: ${REDIS_IP}
port: ${REDIS_PORT}
password: ${REDIS_PASSWORD}
⚠️注:将 ${REDIS_IP},${REDIS_PORT},${REDIS_PASSWORD}
换成自己的
SPI 配置
resources/META-INF/services 下配置 java spi 实现
文件名:cn.xyfv.middleware.dynamic.thread.pool.sdk.refresher.IRefresher
文件值:cn.xyfv.middleware.dynamic.thread.pool.sdk.refresher.impl.RedisRefresher
自定义配置中心接入
如果你有内部自研的配置中心,接入也很简单,只需要自定义一个 Refresher 即可,创建继承自 AbstractRefresher 的自研配置中心类,实现监听特定的配置刷新事件,AbstractRefresher 提供了一种 refresh 方法,调用即可实现动态刷新功能:
java
void refresh(ThreadPoolConfigEntity threadPoolConfigEntity);
maven 依赖
<dependency>
<groupId>io.github.cnzhangxy51</groupId>
<artifactId>dynamic-thread-pool-core</artifactId>
<version>1.0.0</version>
</dependency>
配置文件
yml 格式
yml
dynamic:
thread:
pool:
config:
# 动态更新相关
refresher:
enabled: true
channel:
platform: # 填写自己的
SPI 配置
resources/META-INF/services 下配置 java spi 实现
文件名:cn.xyfv.middleware.dynamic.thread.pool.sdk.refresher.IRefresher
文件值:自定义配置中心的全类名