一.断路器简介
aservicefailureinthelowerlevelofservicescancausecascadingfailureallthewayuptotheuser.whencallstoaparticularserviceisgreater andfailuepercentageisgreaterthancircuitbreaker.errorthresholdpercentage (default :50 % ) )。 inarollingwindowdefinedbymetrics.rolling stats.timeinmilliseconds (default :10 seconds )、thecircuitopensandthecalllisnosonds
官方网站的意思是，进行远程呼叫时，如果发生网络问题或服务器宕机等情况，可以滚动到本地方法，或者重定向到其他地方，呼叫方也没有响应。触发条件默认失败5秒20次看下图，我们可能会用一种方法调用多个服务。 假设服务a瘫痪，断路器会打开故障，打开一个固定的方法。
二、一起实践操作吧
(本章中，大致内容：启动两个服务提供者、一个消费者，关闭其中一个服务提供者，查看断路器是否有效的hystrix控制面板)
1、首先，让我们重用上一篇文章中的三种服务。 它们是eureka-server、eureka-provider和eureka-consumer-feign。 模仿上图的操作吧。 用一种方法调用多个服务。
2、eureka-server不执行任何操作。 eureka-provider复制两个项目，分别命名为eureka-provider-service1、eureka-provider-service2，同时命名为一个eureka-provider-service2
3、首先改造eureka-provider-service1、eureka-provider-service2，将application.properties的实例名称分别更改
eureka-provider-service1、eureka-provider-service2 controller层为了区分这两种服务，对代码进行了以下更改
package com.example.eureka provider.controller； importorg.spring framework.web.bind.annotation.get mapping； importorg.spring framework.web.bind.annotation.rest controller；/* * @ author : mrwang * @ date :2018/9/6 */@ restcontrollerpublicclassstudentcontroller { @ get mapping (/aclice sudent.setid('1)； sudent.setname(Mrwang )； student.setSex (男)； sudent.setport(8003； return student； } class Account{ private String id； 私有字符串名称； 私有字符串sex； 私有整合端口； 省略getset方法} package com.example.eureka provider.controller； importorg.spring framework.web.bind.annotation.get mapping； importorg.spring framework.web.bind.annotation.rest controller；/* * @ author : mrwang * @ date :2018/9/6 */@ restcontrollerpublicclassordercontroller { @ get
Mapping("/order") public Object student(){ Order order = new Order(); order.setOrderName("订单名称"); order.setOrderNumber("订单号"); order.setOrderQuantity("2"); return order; } class Order{ private String orderName; private String orderNumber; private String orderQuantity; //省略getset方法 }}这里分了区分服务，我们创建了一个账户服务和订单服务，接下来我们来改进服务提供者
首先是接口层，我们把服务提供者的两个bean对象在这边冗余一遍，
package com.example.eurekaconsumer.service;import com.example.eurekaconsumer.bean.Account;import com.example.eurekaconsumer.bean.Order;import com.example.eurekaconsumer.service.impl.AccountServiceImpl;import org.springframework.cloud.netflix.feign.FeignClient;import org.springframework.web.bind.annotation.GetMapping;/** * @author: MrWang * @date: 2018/9/6 */@FeignClient(value = "eureka-provider",fallback = AccountServiceImpl.class)//配置服务提供者实例名称public interface AccountService { @GetMapping("/account")//服务提供者路由 Account account(); }我们在FeignClient注解后边直接加上fallback指定对应的类就可以，Feign默认是关闭断路器的，我们要在配置文件上开启
feign.hystrix.enabled=true看一下我们的实现类
package com.example.eurekaconsumer.service.impl;import com.example.eurekaconsumer.bean.Account;import com.example.eurekaconsumer.bean.Order;import com.example.eurekaconsumer.service.AccountService;import org.springframework.stereotype.Component;/** * @author: MrWang * @date: 2018/9/10 */@Componentpublic class AccountServiceImpl implements AccountService { @Override public Account account() { Account account = new Account(); account.setId("我是断路器的id"); account.setName("我是断路器的名称"); account.setPort(10101); account.setSex("断路器性别"); return account; } }order服务和实现层和上边一样，此处省略
我们在这模拟了一些数据，用来测试断路后的效果。
下边是controller
package com.example.eurekaconsumer.controller;import com.example.eurekaconsumer.bean.Account;import com.example.eurekaconsumer.bean.Order;import com.example.eurekaconsumer.service.AccountService;import com.example.eurekaconsumer.service.OrderService;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.RestController;import java.util.HashMap;import java.util.Map;/** * @author: MrWang * @date: 2018/9/10 */@RestControllerpublic class DataController { @Autowired private AccountService accountService; @Autowired private OrderService orderService; @GetMapping("/get") public Map<String,Object> get(){ Account account = accountService.account(); Order order = orderService.order(); Map record = new HashMap(); record.put("order",order); record.put("account",account); return record; }}好，代码写到这里我们来捋一捋我们的初心
提供两个不同的服务，一个消费者调用这两个服务，关闭其中一个服务，查看断路器的效果。
老样子，我们把改造完的项目打包。
好，依次启动他们
已经启动成功，这里想做负载均衡的小伙伴可以复制出项目出来，实例名称不变，端口号改一下就可以了。这里就不演示了。
我们打开浏览器访问消费者127.0.0.1:8101/get
可以看到我们的数据都是从消费者里取出来的
接下来，我们停掉用户服务，刷新页面
可以看到，我们用户的数据已经接入的是断路器里的数据了，那我们继续停掉订单服务继续看。
不出所料，订单也进入断路器了。
那我们重启这两个服务呢，试试看，
嗯，所有数据又正常显示了。这就是断路器，当调用的远程接口因为不可抗力原因不能访问的情况断路器开启。
三、Hystrix仪表盘
操作了这么多，我们来看看它自带的控制面板吧。
还是在eureka-consumer-feign-hystrix这个项目上操作
1、首先在pom.xml文件添加相关依赖
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-actuator</artifactId></dependency><dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-hystrix-dashboard</artifactId></dependency>2、在应用主类上开启监控@EnableHystrixDashboard
package com.example.eurekaconsumer;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.client.discovery.EnableDiscoveryClient;import org.springframework.cloud.netflix.feign.EnableFeignClients;import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;@EnableFeignClients@EnableDiscoveryClient@EnableHystrixDashboard@SpringBootApplicationpublic class EurekaConsumerApplication { public static void main(String[] args) { SpringApplication.run(EurekaConsumerApplication.class, args); }}3、注册Bean
注册HystrixMetricsStreamServlet @Bean public ServletRegistrationBean getServlet() { HystrixMetricsStreamServlet streamServlet = new HystrixMetricsStreamServlet(); ServletRegistrationBean registrationBean = new ServletRegistrationBean(streamServlet); registrationBean.setLoadOnStartup(1); registrationBean.addUrlMappings("/hystrix.stream"); registrationBean.setName("HystrixMetricsStreamServlet"); return registrationBean; }4、访问http://localhost:8101/hystrix
在输入框内输入http://localhost:8101/hystrix.stream
点击Monitor Stream进入监控
我们现在访问htpp://127.0.0.1:8101/get
我请求了三次这个方法，可见三次通过。
我现在停止掉account服务再次请求。
看到有什么不同了没
本次的SpringCloudHystrix断路器就介绍到这儿，有什么不会的问题欢迎一起讨论！
代码我已经上传到GitHub和码云上来了，欢迎fork
GitHub:https://github.com/chuanzige/Spring-Cloud-Hystrix/
码云:https://gitee.com/rdsp/Spring-Cloud-Hystrix