etcd 应用接入
etcd 应用接入dynamictp大约 3 分钟
提示
动态线程池配置文件，建议单独开一个文件放到配置中心 etcd
如果配置中心支持 yml 格式，建议最好使用 yml 文件配置，可读性、可操作性更友好
给出的是全配置项，使用不到的项或者使用默认值的项都可以删除，减少配置量
集成失败 90% 以上情况都是使用姿势有误 / 版本兼容问题，有版本兼容性问题可以提 Issues 或加群反馈
警告
- 下述配置项的值都是随便填写的，请不要直接使用该值，根据自己项目做调整
maven 依赖
SpringBoot1x、2x 用此依赖
<dependency>
<groupId>org.dromara.dynamictp</groupId>
<artifactId>dynamic-tp-spring-boot-starter-etcd</artifactId>
<version>1.1.7</version>
</dependency>
SpringBoot3x 用此依赖
<dependency>
<groupId>org.dromara.dynamictp</groupId>
<artifactId>dynamic-tp-spring-boot-starter-etcd</artifactId>
<version>1.1.7-3.x</version>
</dependency>
线程池配置文件
properties 格式
config/user-center/spring.dynamic.tp.enabled=true
config/user-center/spring.dynamic.tp.enabledCollect=true
config/user-center/spring.dynamic.tp.collectorTypes=micrometer,logging
config/user-center/spring.dynamic.tp.logPath=/home/logs/dynamictp/user-center/
config/user-center/spring.dynamic.tp.monitorInterval=5
config/user-center/spring.dynamic.tp.platforms[0].platform=wechat
config/user-center/spring.dynamic.tp.platforms[0].platformId=1
config/user-center/spring.dynamic.tp.platforms[0].urlKey=3a700-127-4bd-a798-c53d8b69c
config/user-center/spring.dynamic.tp.platforms[0].receivers=test1,test2
config/user-center/spring.dynamic.tp.platforms[1].platform=ding
config/user-center/spring.dynamic.tp.platforms[1].platformId=2
config/user-center/spring.dynamic.tp.platforms[1].urlKey=f80dad441fcd655438f4a08dcd6a
config/user-center/spring.dynamic.tp.platforms[1].secret=SECb5441fa6f375d5b9d21
config/user-center/spring.dynamic.tp.platforms[1].receivers=18888888888
config/user-center/spring.dynamic.tp.platforms[2].platform=lark
config/user-center/spring.dynamic.tp.platforms[2].platformId=3
config/user-center/spring.dynamic.tp.platforms[2].urlKey=0d944ae7-b24a-40
config/user-center/spring.dynamic.tp.platforms[2].secret=3a750012874bdac5c3d8b69c
config/user-center/spring.dynamic.tp.platforms[2].receivers=test1,test2
config/user-center/spring.dynamic.tp.platforms[3].platform=email
config/user-center/spring.dynamic.tp.platforms[3].platformId=4
config/user-center/spring.dynamic.tp.platforms[3].receivers=123456@qq.com,789789@qq.com
config/user-center/spring.dynamic.tp.executors[0].threadPoolName=dtpExecutor1
config/user-center/spring.dynamic.tp.executors[0].threadPoolAliasName=测试线程池
config/user-center/spring.dynamic.tp.executors[0].executorType=common
config/user-center/spring.dynamic.tp.executors[0].corePoolSize=6
config/user-center/spring.dynamic.tp.executors[0].maximumPoolSize=8
config/user-center/spring.dynamic.tp.executors[0].queueCapacity=2000
config/user-center/spring.dynamic.tp.executors[0].queueType=VariableLinkedBlockingQueue
config/user-center/spring.dynamic.tp.executors[0].rejectedHandlerType=CallerRunsPolicy
config/user-center/spring.dynamic.tp.executors[0].keepAliveTime=60
config/user-center/spring.dynamic.tp.executors[0].threadNamePrefix=test
config/user-center/spring.dynamic.tp.executors[0].allowCoreThreadTimeOut=false
config/user-center/spring.dynamic.tp.executors[0].waitForTasksToCompleteOnShutdown=true
config/user-center/spring.dynamic.tp.executors[0].awaitTerminationSeconds=5
config/user-center/spring.dynamic.tp.executors[0].preStartAllCoreThreads=false
config/user-center/spring.dynamic.tp.executors[0].runTimeout=200
config/user-center/spring.dynamic.tp.executors[0].queueTimeout=100
config/user-center/spring.dynamic.tp.executors[0].taskWrapperNames[0]=ttl
config/user-center/spring.dynamic.tp.executors[0].taskWrapperNames[1]=mdc
config/user-center/spring.dynamic.tp.executors[0].notifyEnabled=true
config/user-center/spring.dynamic.tp.executors[0].platformIds[0]=1
config/user-center/spring.dynamic.tp.executors[0].platformIds[1]=2
config/user-center/spring.dynamic.tp.executors[0].notifyItems[0].type=change
config/user-center/spring.dynamic.tp.executors[0].notifyItems[0].enabled=true
config/user-center/spring.dynamic.tp.executors[0].notifyItems[1].type=capacity
config/user-center/spring.dynamic.tp.executors[0].notifyItems[1].enabled=true
config/user-center/spring.dynamic.tp.executors[0].notifyItems[1].threshold=80
config/user-center/spring.dynamic.tp.executors[0].notifyItems[1].platformIds[0]=2
config/user-center/spring.dynamic.tp.executors[0].notifyItems[1].interval=120
config/user-center/spring.dynamic.tp.executors[0].notifyItems[2].type=liveness
config/user-center/spring.dynamic.tp.executors[0].notifyItems[2].enabled=true
config/user-center/spring.dynamic.tp.executors[0].notifyItems[2].threshold=80
config/user-center/spring.dynamic.tp.executors[0].notifyItems[3].type=reject
config/user-center/spring.dynamic.tp.executors[0].notifyItems[3].enabled=true
config/user-center/spring.dynamic.tp.executors[0].notifyItems[3].threshold=100
config/user-center/spring.dynamic.tp.executors[0].notifyItems[4].type=run_timeout
config/user-center/spring.dynamic.tp.executors[0].notifyItems[4].enabled=true
config/user-center/spring.dynamic.tp.executors[0].notifyItems[4].threshold=100
config/user-center/spring.dynamic.tp.executors[0].notifyItems[5].type=queue_timeout
config/user-center/spring.dynamic.tp.executors[0].notifyItems[5].enabled=true
config/user-center/spring.dynamic.tp.executors[0].notifyItems[5].threshold=100
json 格式
{
"spring": {
"dynamic": {
"tp": {
"enabled": true,
"enabledCollect": true,
"collectorTypes": "micrometer,logging",
"logPath": "/home/logs/dynamictp/user-center/",
"monitorInterval": 5,
"platforms": [
{
"platform": "wechat",
"platformId": 1,
"urlKey": "3a700-127-4bd-a798-c53d8b69c",
"receivers": "test1,test2"
},
{
"platform": "ding",
"platformId": 2,
"urlKey": "f80dad441fcd655438f4a08dcd6a",
"secret": "SECb5441fa6f375d5b9d21",
"receivers": "18888888888"
},
{
"platform": "lark",
"platformId": 3,
"urlKey": "0d944ae7-b24a-40",
"secret": "3a750012874bdac5c3d8b69c",
"receivers": "test1,test2"
},
{
"platform": "email",
"platformId": 4,
"receivers": "123456@qq.com,789789@qq.com"
}
],
"executors": [
{
"threadPoolName": "dtpExecutor1",
"threadPoolAliasName": "测试线程池",
"executorType": "common",
"corePoolSize": 6,
"maximumPoolSize": 8,
"queueCapacity": 2000,
"queueType": "VariableLinkedBlockingQueue",
"rejectedHandlerType": "CallerRunsPolicy",
"keepAliveTime": 60,
"threadNamePrefix": "test",
"allowCoreThreadTimeOut": false,
"waitForTasksToCompleteOnShutdown": true,
"awaitTerminationSeconds": 5,
"preStartAllCoreThreads": false,
"runTimeout": 200,
"queueTimeout": 100,
"taskWrapperNames": ["ttl", "mdc"],
"notifyEnabled": true,
"platformIds": [1, 2],
"notifyItems": [
{
"type": "change",
"enabled": true
},
{
"type": "capacity",
"enabled": true,
"threshold": 80,
"platformIds": [2],
"interval": 120
},
{
"type": "liveness",
"enabled": true,
"threshold": 80
},
{
"type": "reject",
"enabled": true,
"threshold": 100
},
{
"type": "run_timeout",
"enabled": true,
"threshold": 100
},
{
"type": "queue_timeout",
"enabled": true,
"threshold": 100
}
]
}
]
}
}
}
}
application.yml 配置
spring:
dynamic:
tp:
config-type: properties
etcd:
endpoints: http://127.0.0.1:2379
auth-enable: false
key: /config/user-center-dtp
application:
name: user-center