getExecutor()
创建一个线程池供下面的调用
receiveConfigInfo()
每次当前的dataId只要改变，就会调用这个方法
```package com.laoyang.dtp;
import com.alibaba.nacos.api.annotation.NacosInjected;
import com.alibaba.nacos.api.config.ConfigService;
import com.alibaba.nacos.api.config.listener.Listener;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.config.YamlPropertiesFactoryBean;
import org.springframework.core.io.ByteArrayResource;
import java.util.Properties;
import java.util.concurrent.Executor;
import java.util.concurrent.Executors;
/**
- @author:Kevin
- @create: 2023-10-24 19:56
- @Description: nacos自带监听器
*/
public class NacosLinsenter implements Listener, InitializingBean {
@NacosInjected
private ConfigService configService;
@Autowired
private DtpExecutor executor;
//nacos的dataId的名称
private static final String DATA_ID = "dtp.yaml";
private static final String GROUP = "DEFAULT_GROUP";
//最大核心数
private static final String CORE_POOL_SIZE = "dtp.core-pool-size";
//最大线程数
private static final String MAXIMUM_POOL_SIZE = "dtp.maximum-pool-size";
//创建一个线程池供下面的调用
@Override
public Executor getExecutor() {
return Executors.newFixedThreadPool(1);
}
//每次当前的dataId只要改变，就会调用这个方法
//但是调用这个方法的线程需要上面的方法创建一个线程池
@Override
public void receiveConfigInfo(String s) {
//首先需要将字符串yml格式转化为map的格式
YamlPropertiesFactoryBean factoryBean = new YamlPropertiesFactoryBean();
factoryBean.setResources(new ByteArrayResource(s.getBytes()));
//使用springboot内置工具类转换为Properties类似于map的格式
Properties object = factoryBean.getObject();
//获取更新后的数据
String corePoolSize = object.getProperty(CORE_POOL_SIZE);
String maximumPoolSize = object.getProperty(MAXIMUM_POOL_SIZE);
//直接更新数据
executor.setCorePoolSize(Integer.parseInt(corePoolSize));
executor.setMaximumPoolSize(Integer.parseInt(maximumPoolSize));
}
@Override
public void afterPropertiesSet() throws Exception {
//将这个NacosLinsenter与当前的dataId一一绑定
configService.addListener(DATA_ID,GROUP,this);
}
}
##3. 开始在user模块使用 dtp-spring-boot-starter模块
创建启动Springboot配置类
```package com.laoyang;
import com.alibaba.nacos.spring.context.annotation.config.NacosPropertySource;
import com.alibaba.nacos.spring.context.annotation.discovery.EnableNacosDiscovery;
import com.laoyang.dtp.DtpExecutor;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
import org.springframework.core.env.Environment;
/**
* @author:Kevin
* @create: 2023-10-24 17:04
* @Description:
*/
@SpringBootApplication
@NacosPropertySource(dataId = "dtp.yaml", autoRefreshed = true)
public class UserApplication {
public static void main(String[] args) {
SpringApplication.run(UserApplication.class, args);
}
}
创建Controller注入动态线程池对象来使用
```package com.laoyang.Controller;
import com.laoyang.dtp.DtpExecutor;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.GetMapping;
import java.util.concurrent.ThreadPoolExecutor;
/**
- @author:Kevin
- @create: 2023-10-24 17:05
@Description: 视图层
*/
@Controller
public class UserController {@Autowired
private DtpExecutor executor;@GetMapping
public Integer test(){executor.execute(() -> dotest()); return 1;}
public void dotest(){
System.out.println("dotest");}
}
```
