重庆分公司,新征程启航

为企业提供网站建设、域名注册、服务器等服务

SpringCloud中Hystrix线程池队列配置的示例分析

这篇文章主要介绍Spring Cloud中Hystrix线程池队列配置的示例分析,文中介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们一定要看完!

成都创新互联专业为企业提供平安网站建设、平安做网站、平安网站设计、平安网站制作等企业网站建设、网页设计与制作、平安企业网站模板建站服务,十载平安做网站经验,不只是建网站,更提供有价值的思路和整体网络服务。

先看一下正确的Hystrix配置姿势。

application.yml:

hystrix:
 threadpool:
  default:
   coreSize: 200 #并发执行的最大线程数,默认10
   maxQueueSize: 1000 #BlockingQueue的最大队列数,默认值-1
   queueSizeRejectionThreshold: 800 #即使maxQueueSize没有达到,达到queueSizeRejectionThreshold该值后,请求也会被拒绝,默认值5

接下来编写一个测试类,来验证几种错误配置,看看会出现什么情况。

测试类代码(A调用方):

/**
 * @Author: XiongFeng
 * @Description:
 * @Date: Created in 11:12 2018/6/11
 */
public class RepaymentHelperTest extends FundApplicationTests {

  @Autowired
  RepaymentHelper repaymentHelper;
  @Autowired
  private RouterFeign routerFeign;

  @Test
  public void hystrixTest() throws InterruptedException {

    for (int i = 0; i < 135; i++) {
      new Thread(new Runnable() {
        @Override
        public void run() {
          job();
        }
      }).start();
    }

    Thread.currentThread().join();
  }

  public void job() {
    String repaymentNo = "xf1002";
    String transNo = "T4324324234";
    String reqNo = "xf1002";
    String begintime = "20180831130030";
    String endtime = "20180831130050";

    TransRecQueryReqDto transRecQueryReqDto = new TransRecQueryReqDto();
    transRecQueryReqDto.setTransNo(transNo);
    transRecQueryReqDto.setBeginTime(begintime);
    transRecQueryReqDto.setEndTime(endtime);
    transRecQueryReqDto.setReqNo(reqNo);

    Resp> queryTransRecListResp = routerFeign.queryTransRec(new Req<>(repaymentNo, "2018080200000002", null, null, transRecQueryReqDto));

    System.out.println(String.format("获取结果为:【%s】", JsonUtil.toJson(queryTransRecListResp)));
  }
}

这个测试类的作用就是创建135个线程,通过RouterFeign类并发请求B服务方,看看请求结果是否出现异常。

Feign调用代码:

@FeignClient(value = "${core.name}", fallbackFactory = RouterFeignBackFactory.class, path = "/router")
public interface RouterFeign {

  /**
   * 代扣结果查询
   * @param transRecQueryReqDtoReq
   * @return
   */
  @PostMapping("/queryTransRec")
  Resp> queryTransRec(@RequestBody Req transRecQueryReqDtoReq);

}

这个类,就是通过Feign方式去调用B服务方的客户端

服务提供方代码(B服务方):

/**
 * @Author: XiongFeng
 * @Description:
 * @Date: Created in 16:04 2018/5/24
 */
@Api("还款服务")
@RefreshScope
@RestController
@RequestMapping("/router")
public class TestController {

  private static Logger logger = LoggerFactory.getLogger(TestController.class);

  // 计数器
  private static AtomicInteger count = new AtomicInteger(1);

  @ApiOperation(value = "代扣结果查询")
  @PostMapping("/queryTransRec")
  Resp> queryTransRec(@RequestBody Req transRecQueryReqDtoReq) throws InterruptedException {
    System.out.println(String.format("查询支付结果......计数: %s", count.getAndAdd(1)));
    Thread.sleep(500);
    return Resp.success(RespStatus.SUCCESS.getDesc(), null);
  }

这个类的作用,就是一个服务提供方,计数并返回结果。

下面我们看一下几种错误的配置。

案例一(将核心线程数调低,最大队列数调大一点,但是队列拒绝阈值设置小一点):

hystrix:
 threadpool:
  default:
   coreSize: 10
   maxQueueSize: 1000
   queueSizeRejectionThreshold: 20

此时的结果:

Spring Cloud中Hystrix线程池队列配置的示例分析

左窗口是B服务方,右窗口是A调用方。从结果可以看出,调用135次,成功32次左右,其余线程全部抛异常。

案例二(将核心线程数调低,最大队列数调小一点,但是队列拒绝阈值设置大一点):

hystrix:
 threadpool:
  default:
   coreSize: 10
   maxQueueSize: 15
   queueSizeRejectionThreshold: 2000

此时的结果:

java.util.concurrent.RejectedExecutionException: Task java.util.concurrent.FutureTask@7d6d472b rejected from java.util.concurrent.ThreadPoolExecutor@17f8bcb7[Running, pool size = 3, active threads = 3, queued tasks = 15, completed tasks = 0]

Spring Cloud中Hystrix线程池队列配置的示例分析

左窗口是B服务方,右窗口是A调用方。从结果可以看出,调用135次,成功25次左右,其余线程全部抛异常。。

案例三(将核心线程数调低,最大队列数调大一点,但是队列拒绝阈值不设置值):

hystrix:
 threadpool:
  default:
   coreSize: 10
   maxQueueSize: 1500

此时的结果:

java.util.concurrent.RejectedExecutionException: Rejected command because thread-pool queueSize is at rejection threshold.

Spring Cloud中Hystrix线程池队列配置的示例分析

左窗口是B服务方,右窗口是A调用方。此时的结果和案例一的情况一样,调用135次,成功47次左右,其余线程全部抛异常。报错跟案例一一样

案例四(将核心线程数调低,最大队列数不设值,但是队列拒绝阈值设置的比较大):

hystrix:
 threadpool:
  default:
   coreSize: 10
   queueSizeRejectionThreshold: 1000

此时的结果:

java.util.concurrent.RejectedExecutionException: Task java.util.concurrent.FutureTask@23d268ea rejected from java.util.concurrent.ThreadPoolExecutor@66d0e2f4[Running, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0]
at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2063)
at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:830)
at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1379)
at java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:112)

Spring Cloud中Hystrix线程池队列配置的示例分析

左窗口是B服务方,右窗口是A调用方。此时的结果和案例二的情况一样,调用135次,成功10次左右,其余线程全部抛异常。报错跟案例二一样

下面来看一看正确的配置案例

案例一:将核心线程数调低,最大队列数和队列拒绝阈值的值都设置大一点):

hystrix:
 threadpool:
  default:
   coreSize: 10
   maxQueueSize: 1500
   queueSizeRejectionThreshold: 1000

此时的结果:

Spring Cloud中Hystrix线程池队列配置的示例分析

左窗口是B服务方,右窗口是A调用方。此时的结果就完全正常了,并发请求了135次,全部成功!

以上是“Spring Cloud中Hystrix线程池队列配置的示例分析”这篇文章的所有内容,感谢各位的阅读!希望分享的内容对大家有帮助,更多相关知识,欢迎关注创新互联行业资讯频道!


本文标题:SpringCloud中Hystrix线程池队列配置的示例分析
文章起源:http://cqcxhl.cn/article/jehooe.html

其他资讯

在线咨询
服务热线
服务热线:028-86922220
TOP