Hystrix--學(xué)習(xí)筆記（4）

目錄

一、參考SpringCloud的官方文檔
--1、斷路器：Hystrix客戶端
--2、如何加入Hystrix
--3灾挨、如何包含Hystrix儀表板
二、實操
--1竹宋、代碼準備
--2劳澄、ribbon-demo具體配置
--3、運行結(jié)果
三蜈七、在feign中加入hystrix
--1浴骂、代碼準備
--2、feign-demo的具體配置
--3宪潮、運行結(jié)果

一溯警、參考SpringCloud的官方文檔

1、斷路器：Hystrix客戶端

Hystrix簡介.PNG

在微服務(wù)架構(gòu)中狡相，通常有多層服務(wù)調(diào)用梯轻。

微服務(wù)圖.PNG

較低級別的服務(wù)中的服務(wù)故障可能導(dǎo)致用戶級聯(lián)故障。當對特定服務(wù)的呼叫達到一定閾值時（Hystrix中的默認值為5秒內(nèi)的20次故障）尽棕，電路打開喳挑，不進行通話。在錯誤和開路的情況下，開發(fā)人員可以提供后備伊诵。

Hystrix回退防止級聯(lián)故障.PNG

2版扩、如何加入Hystrix

pom.xml

<dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
</dependency>

example

@SpringBootApplication
@EnableCircuitBreaker
public class Application {

    public static void main(String[] args) {
        new SpringApplicationBuilder(Application.class).web(true).run(args);
    }

}

@Component
public class StoreIntegration {

    @HystrixCommand(fallbackMethod = "defaultStores")
    public Object getStores(Map<String, Object> parameters) {
        //do stuff that might fail
    }

    public Object defaultStores(Map<String, Object> parameters) {
        return /* something useful */;
    }
}

3废离、如何包含Hystrix儀表板

要在項目中包含Hystrix儀表板，請使用組org.springframework.cloud和工件ID spring-cloud-starter-hystrix-dashboard的啟動器礁芦。

要運行Hystrix儀表板使用@EnableHystrixDashboard注釋您的Spring Boot主類蜻韭。然后訪問/hystrix，并將儀表板指向Hystrix客戶端應(yīng)用程序中的單個實例/hystrix.stream端點柿扣。

二湘捎、實操

1、代碼準備

• 注冊中心euraka-demo-server(參考Eureka--學(xué)習(xí)筆記（1）)
• 在原先的ribbon-demo基礎(chǔ)上修改(參考Ribbon--學(xué)習(xí)筆記（2）)

2窄刘、ribbon-demo具體配置

啟動類

@EnableCircuitBreaker
@EnableHystrixDashboard
@SpringBootApplication
public class RibbonDemoApplication {

    @Bean
    @LoadBalanced   //負載均衡
    public RestTemplate restTemplate(){
        return new RestTemplate();
    }

    public static void main(String[] args) {
        SpringApplication.run(RibbonDemoApplication.class, args);
    }
}

降級服務(wù)配置

@RestController
@RequestMapping("/call")
public class CallController {

    @Autowired
    private RestTemplate restTemplate;

    @GetMapping("/hello")
    @HystrixCommand(fallbackMethod = "hasError")
    public String hello(){
        return restTemplate.getForObject("http://EUREKA-DEMO-CLIENT-1/",String.class);
    }

    @GetMapping("/hi/{name}")
    public String hi(@PathVariable("name") String name){
        return restTemplate.getForObject("http://EUREKA-DEMO-CLIENT-1/test/say/hello/" + name,String.class);
    }

    public String hasError(){
        return "哎呀！出錯了舷胜！";
    }
}

pom.xml

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>

HystrixConfig.java

@Configuration
public class HystrixConfig {
    @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;
    }
}

3娩践、運行結(jié)果

ui的監(jiān)控界面

監(jiān)控.PNG

在瀏覽器中輸入localhost:8082/call/hello

result1.PNG

在瀏覽器中輸入localhost:8082/hystrix,之后再輸入http://localhost:8082/hystrix.stream

result2.PNG

按下網(wǎng)頁按鈕Monitor Stream,之后回到哎呀！出錯了的網(wǎng)頁刷新4次烹骨，再切換回本網(wǎng)頁

result3.PNG

三翻伺、在feign中加入hystrix

1、代碼準備

• 注冊中心euraka-demo-server(參考Eureka--學(xué)習(xí)筆記（1）)
• 在原先的feign-demo基礎(chǔ)上修改(參考Feign--學(xué)習(xí)筆記（3）)

2沮焕、feign-demo的具體配置

pom.xml

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
        </dependency>

application.yml

eureka:
  client:
    serviceUrl:
      defaultZone: http://localhost:8761/eureka/

server:
  port: 8083

spring:
  application:
    name: feign-demo-consumer

feign:
  hystrix:
    enabled: true

降級配置

@Component
public class HystrixClientFallback implements HelloClient {
    @Override
    public String sayHello() {
        return "哎呀吨岭！出錯了！Ｂ褪鳌辣辫！";
    }
}

設(shè)置回調(diào)

@FeignClient(name = "eureka-demo-client-1",fallback = HystrixClientFallback.class)
public interface HelloClient {
    @GetMapping("/")
    String sayHello();
}

3、運行結(jié)果

ui界面的監(jiān)控

監(jiān)控.PNG

在瀏覽器中輸入http://localhosst:8083/hello

result.PNG