13518219792
这篇文章主要介绍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
此时的结果：
左窗口是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]
左窗口是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.
左窗口是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)
左窗口是B服务方，右窗口是A调用方。此时的结果和案例二的情况一样，调用135次，成功10次左右，其余线程全部抛异常。报错跟案例二一样
下面来看一看正确的配置案例
案例一：将核心线程数调低，最大队列数和队列拒绝阈值的值都设置大一点）：
hystrix: threadpool: default: coreSize: 10 maxQueueSize: 1500 queueSizeRejectionThreshold: 1000
此时的结果：
左窗口是B服务方，右窗口是A调用方。此时的结果就完全正常了，并发请求了135次，全部成功！
以上是“Spring Cloud中Hystrix线程池队列配置的示例分析”这篇文章的所有内容，感谢各位的阅读！希望分享的内容对大家有帮助，更多相关知识，欢迎关注创新互联行业资讯频道！
