springcloud?nacos動(dòng)態(tài)線程池Dynamic?tp配置接入實(shí)戰(zhàn)詳解

更新時(shí)間：2022年12月19日 09:44:10 作者：刨紅薯的小羊竿爾

這篇文章主要為大家介紹了springcloud?nacos動(dòng)態(tài)線程池Dynamic?tp配置接入實(shí)戰(zhàn)詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪

一、接入步驟

最近業(yè)務(wù)上需要把項(xiàng)目組幾個(gè)微服務(wù)接入動(dòng)態(tài)線程池框架Dynamic-tp監(jiān)控，同時(shí)支持webhook機(jī)器人接受變更通知、容量報(bào)警、活性報(bào)警、拒絕報(bào)警、任務(wù)超時(shí)報(bào)警等通知，方便項(xiàng)目組同事企業(yè)微信群實(shí)時(shí)監(jiān)控線程池狀態(tài)，動(dòng)態(tài)調(diào)整線程參數(shù)。

接手開始上手，一看網(wǎng)上教程和demo很多啊，心中竊喜，一頓ctrl+c+v大發(fā)，卻發(fā)現(xiàn)告警不通知，配置線程池不生效，數(shù)著承諾的交付時(shí)間，開始發(fā)慌；幾經(jīng)周折，才定，斯文于記。

1、引入POM文件

spring-cloud場景下的nacos應(yīng)用接入用此依賴：

<dependency>
    <groupId>cn.dynamictp</groupId>
    <artifactId>dynamic-tp-spring-cloud-starter-nacos</artifactId>
    <version>1.0.8</version>
</dependency>

非spring-cloud 場景下的nacos應(yīng)用接入用此依賴：

<dependency>
    <groupId>cn.dynamictp</groupId>
    <artifactId>dynamic-tp-spring-boot-starter-nacos</artifactId>
    <version>1.0.8</version>
</dependency>

2、啟動(dòng)類加 @EnableDynamicTp 注解

3、配置中心配置線程池yml實(shí)例

spring:
  dynamic:
    tp:
      enabled: true
      enabledBanner: true           # 是否開啟banner打印，默認(rèn)true
      enabledCollect: true          # 是否開啟監(jiān)控指標(biāo)采集，默認(rèn)false
      collectorTypes: micrometer,logging     # 監(jiān)控?cái)?shù)據(jù)采集器類型（logging | micrometer | internal_logging），默認(rèn)micrometer
      logPath: /home/logs           # 監(jiān)控日志數(shù)據(jù)路徑，默認(rèn) ${user.home}/logs，采集類型非logging不用配置
      monitorInterval: 5            # 監(jiān)控時(shí)間間隔（報(bào)警判斷、指標(biāo)采集），默認(rèn)5s
      nacos:                        # nacos配置，不配置有默認(rèn)值（規(guī)則appname-dev.yml這樣），cloud應(yīng)用不需要配置
        dataId: dynamic-tp-demo-dev.yml
        group: DEFAULT_GROUP
      apollo:                       # apollo配置，不配置默認(rèn)拿apollo配置第一個(gè)namespace
        namespace: dynamic-tp-demo-dev.yml
      configType: yml               # 配置文件類型，非cloud nacos 和 apollo需配置，其他不用配
      platforms:                    # 通知報(bào)警平臺(tái)配置
        - platform: wechat
          urlKey: 3a700-127-4bd-a798-c53d8b69c     # 替換
          receivers: test1,test2                   # 接受人企微名稱
        - platform: ding
          urlKey: f80dad441fcd655438f4a08dcd6a     # 替換
          secret: SECb5441fa6f375d5b9d21           # 替換，非sign模式可以沒有此值
          receivers: 18888888888                   # 釘釘賬號(hào)手機(jī)號(hào)
        - platform: lark
          urlKey: 0d944ae7-b24a-40                 # 替換
          receivers: test1,test2                   # 接受人飛書名稱/openid
      tomcatTp:                                    # tomcat webserver線程池配置
        corePoolSize: 100
        maximumPoolSize: 200
        keepAliveTime: 60
      jettyTp:                                     # jetty weberver線程池配置
        corePoolSize: 100
        maximumPoolSize: 200
      undertowTp:                                  # undertow webserver線程池配置
        corePoolSize: 100
        maximumPoolSize: 200
        keepAliveTime: 60
      hystrixTp:                                   # hystrix 線程池配置
        - threadPoolName: hystrix1
          corePoolSize: 100
          maximumPoolSize: 200
          keepAliveTime: 60
      dubboTp:                                     # dubbo 線程池配置
        - threadPoolName: dubboTp#20880            # 名稱規(guī)則：dubboTp + "#" + 協(xié)議端口
          threadPoolAliasName: 測試線程池            # dubbo線程池
          corePoolSize: 100
          maximumPoolSize: 200
          keepAliveTime: 60
          notifyItems:      # 報(bào)警項(xiàng)，不配置自動(dòng)會(huì)按默認(rèn)值配置（變更通知、容量報(bào)警、活性報(bào)警）
            - type: capacity                # 報(bào)警項(xiàng)類型，查看源碼 NotifyTypeEnum枚舉類
              enabled: true
              threshold: 80                        # 報(bào)警閾值
              platforms: [ding,wechat]             # 可選配置，不配置默認(rèn)拿上層platforms配置
              interval: 120                        # 報(bào)警間隔（單位：s）
      rocketMqTp:                                  # rocketmq 線程池配置
        - threadPoolName: group1#topic1            # 名稱規(guī)則：group + "#" + topic
          corePoolSize: 200
          maximumPoolSize: 200
          keepAliveTime: 60
      executors:                                   # 動(dòng)態(tài)線程池配置
        - threadPoolName: dtpExecutor1
          threadPoolAliasName: 測試線程池           # 線程池別名
          executorType: common                     # 線程池類型common、eager：適用于io密集型
          corePoolSize: 6
          maximumPoolSize: 8
          queueCapacity: 200
          queueType: VariableLinkedBlockingQueue   # 任務(wù)隊(duì)列，查看源碼QueueTypeEnum枚舉類
          rejectedHandlerType: CallerRunsPolicy    # 拒絕策略，查看RejectedTypeEnum枚舉類
          keepAliveTime: 50
          allowCoreThreadTimeOut: false                  # 是否允許核心線程池超時(shí)
          threadNamePrefix: test                         # 線程名前綴
          waitForTasksToCompleteOnShutdown: false      # 參考spring線程池設(shè)計(jì)，優(yōu)雅關(guān)閉線程池
          awaitTerminationSeconds: 5                     # 單位（s）
          preStartAllCoreThreads: false                  # 是否預(yù)熱所有核心線程，默認(rèn)false
          runTimeout: 200               # 任務(wù)執(zhí)行超時(shí)閾值，目前只做告警用，單位（ms）
          queueTimeout: 100              # 任務(wù)在隊(duì)列等待超時(shí)閾值，目前只做告警用，單位（ms）
          taskWrapperNames: ["ttl"]        # 任務(wù)包裝器名稱，集成TaskWrapper接口
          notifyItems:                     # 報(bào)警項(xiàng)，不配置自動(dòng)會(huì)按默認(rèn)值配置（變更通知、容量報(bào)警、活性報(bào)警、拒絕報(bào)警、任務(wù)超時(shí)報(bào)警）
            - type: capacity               # 報(bào)警項(xiàng)類型，查看源碼 NotifyTypeEnum枚舉類
              enabled: true
              threshold: 80                # 報(bào)警閾值
              platforms: [ding,wechat]    # 可選配置，不配置默認(rèn)拿上層platforms配置的所以平臺(tái)
              interval: 120                # 報(bào)警間隔（單位：s）
            - type: change
              enabled: true
            - type: liveness
              enabled: true
              threshold: 80
            - type: reject
              enabled: true
              threshold: 1
            - type: run_timeout
              enabled: true
              threshold: 1
            - type: queue_timeout
              enabled: true
              threshold: 1

服務(wù)啟動(dòng)時(shí)會(huì)根據(jù)配置中心的配置[dtpExecutor1]動(dòng)態(tài)注冊到Spring容器中。

4、配置線程池使用

@Resource或@Autowired進(jìn)行依賴注入，或通過 DtpRegistry.getDtpExecutor("name")獲取。

    @Resource
    private ThreadPoolExecutor dtpExecutor1;

   DtpExecutor dtpExecutor = DtpRegistry.getDtpExecutor("dtpExecutor1");
   dtpExecutor.execute(() -> System.out.println("test"));

以上4步，順利話可以接入使用了：

|  __ \                            (_) |__   __|
| |  | |_   _ _ __   __ _ _ __ ___  _  ___| |_ __
| |  | | | | | '_ \ / _` | '_ ` _ | |/ __| | '_ \
| |__| | |_| | | | | (_| | | | | | | | (__| | |_) |
|_____/ __, |_| |_|__,_|_| |_| |_|_|___|_| .__/
         __/ |                              | |
        |___/                               |_|
 :: Dynamic Thread Pool ::

DynamicTp register dtpExecutor, source: beanPostProcessor, executor: DtpMainPropWrapper(dtpName=dynamic-tp-test-1, corePoolSize=6, maxPoolSize=8, keepAliveTime=50, queueType=VariableLinkedBlockingQueue, queueCapacity=200, rejectType=RejectedCountableCallerRunsPolicy, allowCoreThreadTimeOut=false)

DtpRegistry initialization end, remote dtpExecutors: [dtpExecutor1, dtpExecutor2], local dtpExecutors: [ioIntensiveExecutor], local commonExecutors: [commonExecutor]

啟動(dòng)日志出現(xiàn)， remote dtpExecutors便是配置注冊的線程池了，那么恭喜。

當(dāng)然我們也可以在程序中定義線程池代替配置文件，但是官方不推薦，官方推薦的配置文件配置。普通 JUC線程池想要被監(jiān)控，可以@Bean定義時(shí)加 @DynamicTp 注解。

* 1、 (ThreadPoolExecutor) Executors.newFixedThreadPool(1)加@DynamicTp("commonExecutor")
* 2、ThreadPoolCreator.createDynamicFast("dynamic-tp-test-1");
* 3、ThreadPoolBuilder.newBuilder()

二、避坑指南

1、yaml配置單獨(dú)文件，不同的nacos配置可能會(huì)有差異，以nacos 2.0.2為例：配置文件添加后綴.yml或者.yaml

2、阻塞隊(duì)列只有VariableLinkedBlockingQueue類型可以修改capacity，該類型功能和 LinkedBlockingQueue相似，只是capacity不是final類型，可以修改。

3、配置企微機(jī)器人地址KEY

platform: wechat
urlKey: 3a700-127-4bd-a798-c53d8b69c     # 機(jī)器人地址后的key
receivers: test1                         # 指定接收人企微名稱，默認(rèn)@所有人

機(jī)器人配置參考企微webhook

4、重要類DtpBeanDefinitionRegistrar配置轉(zhuǎn)換

以上就是springcloud nacos動(dòng)態(tài)線程池Dynamic tp配置接入實(shí)戰(zhàn)詳解的詳細(xì)內(nèi)容，更多關(guān)于springcloud nacos配置接入Dynamic tp的資料請關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: