秒速快3彩神8app_架构师系列文:通过Spring Cloud组件Hystrix合并请求

  • 时间:
  • 浏览:2
  • 来源:小木博客 - 专注共享七月娱乐网分享

    在前文里,大伙儿儿讲述了通过Hystrix进行容错防止的法律法子,这里大伙儿儿将讲述通过Hystrix合并请求的法律法子

    哪怕有有有一两个URL请求调用的功能再简单,Web应用服务都共要会开启有有有一两个线程运行来提供服务,换句话说,有效降低URL请求数能很大程度上降低系统的负载。通过Hystrix提供的“合并请求”机制,大伙儿儿能有效地降低请求数量。

    在如下的HystrixMergeDemo.java里,大伙儿儿将采集2秒内到达的所有“查询订单”的请求,并把它们合并到有有有一两个对象中传输给后台,后台则是根据多个请求参数统一返回查询结果,你这名 基于合并的做法将比每次只防止有有有一两个请求的法律法子要高效得多,代码比较长,大伙儿儿按类来说明。    

1    //省略必要的package和import的代码
2    class OrderDetail{ //订单业务类,其中包蕴含晒

晒
一两个属性
3      private String orderId;
4      private String orderOwner;
5      //省略针对orderId和orderOwner的get和set法律法子
6          //重写toString法律法子,方便输出
7          public String toString() {        
8            return "orderId: " + orderId + ", orderOwner: " + orderOwner ;
9          }
10    }
11    //合并订单请求的防止器
12    class OrderHystrixCollapser extends        HystrixCollapser<Map<String, OrderDetail>, OrderDetail, String> 
13    {
14        String orderId;
15        //在构造函数里传入请求参数
16        public OrderHystrixCollapser(String orderId) 
17    { this.orderId = orderId;}
18    //指定根据orderId去请求OrderDetail
19        public String getRequestArgument() 
20    { return orderId;    }
21    //创建请求命令
22        protected HystrixCommand<Map<String, OrderDetail>> createCommand(
23            Collection<CollapsedRequest<OrderDetail, String>> requests) 
24    { return new MergerCommand(requests); }
25        //把请求得到的结果和请求关联到一起去
26        protected void mapResponseToRequests(Map<String, OrderDetail> batchResponse,
27            Collection<CollapsedRequest<OrderDetail, String>> requests) {
28            for (CollapsedRequest<OrderDetail, String> request : requests)    
29        {
80                // 请注意这里是得到单个请求的结果
31                OrderDetail oneOrderDetail = batchResponse.get(request.getArgument());
32                // 把结果关联到请求中
33                request.setResponse(oneOrderDetail);
34            }
35        }
36    }

    在第2行,大伙儿儿定义了OrderDetail类,这里,大伙儿儿将合并针对该类对象的请求。

    在第12行,大伙儿儿定义了合并订单的防止器OrderHystrixCollapser类, 它继承(extends)了HystrixCollapser<Map<String, OrderDetail>, OrderDetail, String>类,而HystrixCollapser泛型含晒 晒 了六个参数,其中第有有有一两个参数Map<String, OrderDetail>表示该合并防止器合并请求后返回的结果类型,第六个参数表示是合并OrderDetail类型的对象,第有有有一两个参数则表示是根据String类型的请求参数来合并对象。

    在第19行里,大伙儿儿指定了是根据String类型的OrderId参数来请求OrderDetail对象,在第22行的createCommand法律法子里,大伙儿儿指定了是调用MergerCommand法律法子来请求多个OrderDetail,在第26行的mapResponseToRequests法律法子里,大伙儿儿是用第28行的for循环,依次把batchResponse对象含晒 晒 的多个的查询结果设置到request对象里,原因分析分析着request是参数requests里的元素,一些一些执行完第28行的for循环后,requests对象就能关联到合并后的查询结果。    

37    class MergerCommand extends HystrixCommand<Map<String, OrderDetail>> {
38        //用orderDB模拟数据库中的数据
39        static HashMap<String,String> orderDB = new HashMap<String,String> ();
40        static     {
41            orderDB.put("1","Peter");
42            orderDB.put("2","Tom");
43            orderDB.put("3","Mike");
44        }    
45        Collection<CollapsedRequest<OrderDetail, String>> requests;
46        public MergerCommand(Collection<CollapsedRequest<OrderDetail, String>> requests) {
47            super(Setter.withGroupKey(HystrixCommandGroupKey.Factory
48                    .asKey("mergeDemo")));
49            this.requests = requests;
80        }
51        //在run法律法子里根据请求参数返回结果
52        protected Map<String, OrderDetail> run() throws Exception {
53            List<String> orderIds = new ArrayList<String>();
54            //通过for循环,整合参数
55            for(CollapsedRequest<OrderDetail, String> request : requests)    
56        { orderIds.add(request.getArgument());     }
57            // 调用服务,根据多个订单Id获得多个订单对象
58            Map<String, OrderDetail> ordersHM = getOrdersFromDB(orderIds);
59            return ordersHM;
80        }    
61        //用HashMap模拟数据库,从数据库中获得对象
62        private Map<String, OrderDetail> getOrdersFromDB(List<String> orderIds) {
63            Map<String, OrderDetail> result = new HashMap<String, OrderDetail>();
64            for(String orderId : orderIds) {
65                OrderDetail order = new OrderDetail();
66                //你这名

本该是从数据库里得到,但为了模拟,仅从HashMap里取数据
67                order.setOrderId(orderId);
68                order.setOrderOwner(orderDB.get(orderId) );            
69                result.put(orderId, order);
70            }
71            return result;
72        }
73    }

    在MergerCommand类的第38到44行里,大伙儿儿用了orderDB对象来模拟数据库里存储的订单数据。在第46行的构造函数里,大伙儿儿用传入的requests对象来构建本类里的同名对象,在你这名 传入的requests对象里,原因分析分析着含晒 了合并后的请求。

    在第52行的run法律法子里,大伙儿儿通过第55行的for循环,依次遍历requests对象,并组装含晒 请求参数集合的orderIds对象,时候在第58行里,通过getOrdersFromDB法律法子,根据List类型的orderIds参数,模拟地从数据库里读取数据。        

74    public class HystrixMergeDemo{
75        public static void main(String[] args){
76            // 采集2秒内所处的请求,合并为有有有一两个命令执行
77            ConfigurationManager.getConfigInstance().setProperty(    "hystrix.collapser.default.timerDelayInMilliseconds", 800);
78            // 初始化请求上下文
79            HystrixRequestContext context = HystrixRequestContext    .initializeContext();
80            // 创建六个请求合并防止器
81            OrderHystrixCollapser collapser1 = new OrderHystrixCollapser("1");
82            OrderHystrixCollapser collapser2 = new OrderHystrixCollapser("2");
83            OrderHystrixCollapser collapser3 = new OrderHystrixCollapser("3");        
84            // 异步执行
85            Future<OrderDetail> future1 = collapser1.queue();
86            Future<OrderDetail> future2 = collapser2.queue();
87            Future<OrderDetail> future3 = collapser3.queue();        
88            try {
89                System.out.println(future1.get());
90                System.out.println(future2.get());
91                System.out.println(future3.get());
92            } catch (InterruptedException e) {
93                e.printStackTrace();
94            } catch (ExecutionException e) {
95                e.printStackTrace();
96            }
97            /关闭请求上下文
98            context.shutdown();
99        }
80    }

    第74行定义的HystrixMergeDemo类里含晒 着main法律法子,在第77行里,大伙儿儿设置了合并请求的窗口时间是2秒,在第81到83行,创建了六个合并防止器对象,从第85到87行,大伙儿儿是通过queue 法律法子,以异步的法律法子启动了有有有一两个防止器,并在第89到91行里,输出了有有有一两个防止器返回的结果。你这名 线程运行的运行结果如下。     

1    orderId: 1, orderOwner: Peter
2    orderId: 2, orderOwner: Tom
3    orderId: 3, orderOwner: Mike

     确着实main法律法子里,大伙儿儿发起了3次调用,但原因分析分析着你这名 调用是所处在2秒内的,一些一些会被合并防止,下面大伙儿儿结合上述针对类和法律法子的说明,归纳下合并防止六个请求的流程。

    步骤一,在代码的81到83行里,大伙儿儿是通过OrderHystrixCollapser类型的collapser1等有有有一两个对象来传入待合并防止的请求,OrderHystrixCollapser类会通过第16行的构造函数,分别接收有有有一两个对象传入的orderId参数,并通过第22行的createCommand法律法子,调用MergerCommand类的法律法子执行“根据订单Id查订单”的业务。

    这里说明下,原因分析分析着在OrderHystrixCollapser内第16行的getRequestArgument法律法子里,大伙儿儿指定了查询参数名是orderId,一些一些createCommand法律法子的requests参数,会用orderId来设置查询请求,一起去,MergerCommand类中的相关法律法子也会用该对象来查询OrderDetail信息。

    步骤二,原因分析分析着在createCommand法律法子里,调用了MergerCommand类的构造函数,一些一些会触发该类第52行的run法律法子,在你这名 法律法子里,通过第55行和第56行的for循环,把request请求含晒 晒 的多个Argument(也可是OrderId)装下 去去到orderIds你这名 List类型的对象中,时候通过第58行的getOrdersFromDB法律法子,根据你这名 orderIds去找对应的OrderDetail对象。

   步骤三,在getORdersFromDB法律法子里,找到对应的多个OrderDetail对象,并组装成Map<String, OrderDetail>类型的result对象返回,时候按调用链的关系,层层返回给OrderHystrixCollapser类。

    步骤四,在OrderHystrixCollapser类的mapResponseToRequests法律法子里,通过for循环,把多次请求的结果组装下 requests对象中。原因分析分析着requests对象是Collection<CollapsedRequest<OrderDetail, String>>类型的,其中用String类型的OrderId关联到了有有有一两个OrderDetail对象,一些一些这里会把合并查询的结果再拆散给3次请求,具体而言,会把六个OrderDetail对象对应地返回给第85行到第87行通过queue调用的六个请求。

    这里请注意,着实通过合并请求的防止法律法子能降低URL请求的数量,但原因分析分析着合并后的URL请求数这麼来越多,会撑爆掉合并防止器(这里是OrderHystrixCollapser类)的缓存。比如在某项 目里,着实只设置了合并5秒内的请求,但正好赶上秒杀活动,在你这名 窗口期内的请求数过万,这麼都有原因分析分析着出难题图片。

    一些一些一般会在上线前,先通过测试选折 合并防止器的缓存容量,时候再预估下平均每秒的原因分析分析着访问数,时候再据此设置合并的窗口时间。

     我所有人时候写的和本文有关的Spring Cloud其它相关文章。

  Hystrix针对不可用服务的保护机制以及引入缓存

 通过案例了解Hystrix的各种基本使用法律法子