Skip to content

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

文件值:自定义配置中心的全类名