Hystrix：HystrixCollapser请求合并

偶尔在spring4all，看到DiDi关于hystrix请求合并的一篇文章 Spring Cloud Hystrix的请求合并，查阅资料又整理了一下。

具体业务概念，什么是请求合并？请求合并优缺点？可以参考DiDi的文章，然后我把我使用过程中的问题及解决方法写出来

代码

合并请求服务实现

1 @HystrixCollapser(batchMethod = "testAll", collapserProperties = {
2        @HystrixProperty(name = "timerDelayInMilliseconds", value = "3000")
3})
4public Future<Demo> test(String param) {
5    return null;
6}
7
8@HystrixCommand
9public List<Demo> testAll(List<String> params) {
10    logger.info("合并操作线程 --> {} --> params --> {}", Thread.currentThread().getName(), params);
11    return restTemplate.getForObject("http://DEMO-SERVICE/demo?params={1}", List.class, StringUtils.join(params, ","));;
12}

对外请求接口定义：

1@RequestMapping("/test")
2public SysDict test() throws ExecutionException, InterruptedException {
3    //开启上下文TheardLocal
4    HystrixRequestContext context = HystrixRequestContext.initializeContext();
5    Future<Demo> demo1 = testService.test(RandomUtil.randomNumbers(5));
6    Future<Demo> demo2 = testService.test(RandomUtil.randomNumbers(5));
7    System.out.println(demo1.get());
8    System.out.println(demo2.get());
9    context.close();
10    return null;
11}

效果如下：

• 如图两次调用Service.test()被合并成一次服务调用。

如果我请求两次接口也就是会调用四次Service.test(),那么会合并成几次服务调用呢？

• 如图，两次请求还是被合并成了两次服务调用。

怎么实现两次请求，合并成一次服务调用？

1@HystrixCollapser scope属性
2//所有线程的请求中的多次服务请求进行合并。
3Scope.GLOBAL;
4//默认，对一次请求的多次服务调用合并
5Scope.REQUEST; 

改造后代码：

1 @HystrixCollapser(batchMethod = "testAll", scope = Scope.GLOBAL, collapserProperties = {
2    @HystrixProperty(name = "timerDelayInMilliseconds", value = "3000")
3})
4public Future<Demo> test(String param) {
5    return null;
6}

改造后效果：

总结

1. 这里单个请求的service 返回的 Future 包装的对象，如果使用原对象，则是同步请求，不会合并。
2. HystrixRequestContext 接口访问需要开启上下文对象，其实就是使用TheardLoacl 初始化一个上下文对象。
3. 暂时还不支持 feign 整合
4. @HystrixCollapser Scope.REQUEST Scope.GLOBAL 合并作用域的区别
5. 源码可以参考：https://gitee.com/log4j/pig