SpringCloudHystrix高并发下实现请求合并

前言

在高并发的场景下，前端会有大量的访问请求。如果一个请求就需要打开一个数据库连接，操作完数据库后再进行关闭，无形中对数据造成很大的开销。请求合并是将多个单个请求合并成一个请求，去调用服务提供者提供的服务接口，再遍历合并的结果为每个合并前的单个请求设置返回结果。Spring Cloud通过Hystrix实现请求合并，减轻高并发时的请求线程消耗、降低请求响应时间的效果。今天就来聊一聊Hystrix请求合并的实现方式。

成都创新互联公司是一家集网站建设,杭州企业网站建设,杭州品牌网站建设,网站定制,杭州网站建设报价,网络营销,网络优化,杭州网站推广为一体的创新建站企业，帮助传统企业提升企业形象加强企业竞争力。可充分满足这一群体相比中小企业更为丰富、高端、多元的互联网需求。同时我们时刻保持专业、时尚、前沿，时刻以成就客户成长自我，坚持不断学习、思考、沉淀、净化自己，让我们为更多的企业打造出实用型网站。

实现方式

由于是高并发场景，因此准备了SpringCloud微服务框架。准备了注册中心、网关、服务提供者、服务消费者等组件。

导入依赖

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

启动类上增加注解

@SpringBootApplication
@EnableHystrix
public class ServiceApplication {
    public static void main(String[] args) {
        SpringApplication.run(ServiceApplication.class, args);
    }
}

实现请求合并，Service中代码如下：

//请求合并的方法  合并5s内的请求
@HystrixCollapser(batchMethod = "mergeGet", scope = com.netflix.hystrix.HystrixCollapser.Scope.GLOBAL, collapserProperties = {@HystrixProperty(name = "timerDelayInMilliseconds", value = "5000")})
public Future get(String id) {
    log.info("======执行了get方法========" + id);
    return null;
}

//合并请求之后调用的方法
@HystrixCommand
public List mergeGet(List ids) {
    log.info("===合并开始===");
    List items = ids.stream().map(
            x -> {
                Item item = new Item();
                item.setId(Integer.valueOf(x));
                item.setName("商品 :" + x);
                return item;
            }

    ).collect(Collectors.toList());
    log.info("===合并结束,合并 {} 条 请求====", ids.size());
    return items;
}

​说明：调用get方法，如果5s内get有多次调用，则合并后mergeGet方法。

controller调用代码如下：

@RequestMapping(value = "/find/{id}")
public Item find(@PathVariable String id) throws InterruptedException, ExecutionException {
    HystrixRequestContext context = HystrixRequestContext.initializeContext();
    Future items = itemService.get(id);
    System.out.println(items.get());
    context.close();
    return items.get();
}

执行

执行127.0.0.1:8080/find/11，同时执行127.0.0.1:8080/find/22，保证两个请求在5s内发出。

返回结果

说明：

• scope = com.netflix.hystrix.HystrixCollapser.Scope.GLOBAL：将所有线程中多次服务调用进行合并
• scope = com.netflix.hystrix.HystrixCollapser.Scope.REQUEST：对一次请求的多次服务调用进行合并

新闻标题：SpringCloudHystrix高并发下实现请求合并
标题路径：http://www.shufengxianlan.com/qtweb/news11/97311.html

网站建设、网络推广公司-创新互联，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 创新互联