189 8069 5689
如何实现高并发下的中Hystrix请求合并，很多新手对此不是很清楚，为了帮助大家解决这个难题，下面小编将为大家详细讲解，有这方面需求的人可以来学习下，希望你能有所收获。
创新互联凭借专业的设计团队扎实的技术支持、优质高效的服务意识和丰厚的资源优势，提供专业的网站策划、成都网站建设、成都网站制作、网站优化、软件开发、网站改版等服务，在成都10余年的网站建设设计经验，为成都上千中小型企业策划设计了网站。
实现高并发下的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;
}
}
5、测试时通过jmeter测试工具测试可以查看到效果。
看完上述内容是否对您有帮助呢？如果还想对相关知识有进一步的了解或阅读更多相关文章，请关注创新互联行业资讯频道，感谢您对创新互联的支持。