导航：首页 > 服务器 >

如何实现高并发下的中Hystrix请求合并

发表于：2025-01-23 作者：千家信息网编辑

千家信息网最后更新 2025年01月23日，如何实现高并发下的中Hystrix请求合并，很多新手对此不是很清楚，为了帮助大家解决这个难题，下面小编将为大家详细讲解，有这方面需求的人可以来学习下，希望你能有所收获。实现高并发下的SpringClo

千家信息网最后更新 2025年01月23日如何实现高并发下的中Hystrix请求合并

如何实现高并发下的中Hystrix请求合并，很多新手对此不是很清楚，为了帮助大家解决这个难题，下面小编将为大家详细讲解，有这方面需求的人可以来学习下，希望你能有所收获。

实现高并发下的SpringCloud中Hystrix请求合并
1、在pom.xml中引入maven包

   
    
      org.springframework.cloud
      spring-cloud-starter-netflix-hystrix
      2.1.6.RELEASE

spring Boot 包引入，版本必须一致，否则启动报错。

  
    org.springframework.boot
    spring-boot-starter-parent
    2.1.12.RELEASE

2、添加启动注解
@EnableCircuitBreaker该注解启动hystrix，否则不生效。

@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);
  }
}

3、请求接口Controller

@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 userFu = this.userBatchServiceImpl.getUserById(id);
      ids = userFu.get();
   }catch (Exception e){
     e.printStackTrace();
   }
    return ids;
  }

}

4、编写请求合并逻辑
timerDelayInMilliseconds 该参数设置的是线程池中间间隔时间，如间隔5000ms则是一个线程池等待5s后执行

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

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

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

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