springcloud：3.7测试线程池服务隔离

服务提供者【test-provider8001】

Openfeign远程调用服务提供者搭建

文章地址http://t.csdnimg.cn/06iz8

服务消费者【test-consumer-resilience4j8004】

Openfeign远程调用消费者搭建

文章地址http://t.csdnimg.cn/06iz8

依赖

 <!-- resilience4j隔离依赖  --><dependency><groupId>io.github.resilience4j</groupId><artifactId>resilience4j-bulkhead</artifactId><version>1.7.0</version></dependency><!-- resilience4j  --><dependency><groupId>io.github.resilience4j</groupId><artifactId>resilience4j-spring-cloud2</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-circuitbreaker-resilience4j</artifactId></dependency>

application.yml

resilience4j:        #线程池隔离thread-pool-bulkhead:instances:# 实例名称：自己定义的名称，对应@Bulkhead的namebackendA:# 最大线程池大小maxThreadPoolSize: 4# 核心线程池大小coreThreadPoolSize: 2#  队列容量queueCapacity: 2

OrderController【控制层】

/*** 测试线程池服务隔离** @return*/@GetMapping("/thread")@Bulkhead(name = "backendA", type = Bulkhead.Type.THREADPOOL)//name：对应的配置名，type：隔离类型-信号量/线程public CompletableFuture future() {log.info("********** 进入方法 *******");try {TimeUnit.SECONDS.sleep(5);} catch (InterruptedException e) {e.printStackTrace();}log.info("********** 离开方法 *******");//需要异步调用return CompletableFuture.supplyAsync(() -> "线程池隔离信息......");}