如何實現高并發(fā)下的中Hystrix請求合并

   <!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-netflix-hystrix -->
    <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
      <version>2.1.6.RELEASE</version>
    </dependency>

  <parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.1.12.RELEASE</version>
    <relativePath/>
  </parent>

@SpringBootApplication
@EnableScheduling
@EnableSwagger2
@EnableCaching
@EnableAsync
@ServletComponentScan
@EnableMqHandlerScan(packages = {"com.sxgw.pcops.im.client.mq.handler"})
//使用hystrix必須增加
@EnableCircuitBreaker
public class ClientApplication {

  public static void main(String[] args) {
    SpringApplication.run(ClientApplication.class, args);
  }
}

@Api(value = "測試")
@RestController
@RequestMapping("/test")
@Slf4j
public class TestController {
  @Autowired
  private UserBatchServiceImpl userBatchServiceImpl;
  @ApiOperation("測試請求合并")
  @PostMapping(value = "/userbyMerge/{id}")
  public String userbyMerge(@PathVariable Long id)  {
    String ids = "";
   try {
     Future<String> userFu = this.userBatchServiceImpl.getUserById(id);
      ids = userFu.get();
   }catch (Exception e){
     e.printStackTrace();
   }
    return ids;
  }

}

/**
 *
 * @author  
 *
 */
@Component
public class UserBatchServiceImpl {

    @HystrixCollapser(batchMethod = "getUserBatchById",scope= com.netflix.hystrix.HystrixCollapser.Scope.GLOBAL,
            collapserProperties = {@HystrixProperty(name ="timerDelayInMilliseconds",value = "5000")})
    public Future<String> getUserById(Long id) {
        throw new RuntimeException("This method body should not be executed");
    }

    @HystrixCommand
    public List<String> getUserBatchById(List<Long> ids) {
        System.out.println("進入批量處理方法"+ids);
        List<String> ps = new ArrayList<String>();
        for (Long id : ids) {

            ps.add(id+"");
        }
        return ps;
    }
}