spring cloud：三、断路器（hystrix）

凡夫贩夫

3877人浏览 · 2018-03-07 18:05:48

凡夫贩夫 · 2018-03-07 18:05:48 发布

在分布式系统中，根据业务来拆分成一个个的微服务，服务与服务之间可以相互调用（RPC），在spring cloud 中可以用RestTemplate+ribbon和feign来调用。为了保证其高可用，单个服务有时候会集群部署，由于网络或程序自躾的原因，服务并不能保证百分百可靠可用，如果单个服务出现问题，调用这个服务就出现线程阻塞，此时若有大量的请求涌入，servlet容器的线程资源就会被消耗完毕导致服务瘫痪。服务与服务之间的依赖性，故障会传播，会对整个微服务系统造成不可估量的严重后果，这就是常说的服务故障的“雪崩效应”。为了解决这个问题，有人就提出了一种解决问题的思路，断路器模型。就是每一个调用服务的接口处加一个断路器，默认是关闭的，当对服务调用时，不可用的次数达到一个阀值时，断路器就会打开，通过回调方法迅速返回一个值结束调用，避免出现连锁故障。

一、改造上一篇文章的zhangsanService（ribbon+restTemplate方式），在pom.xml中加入hystrix的依赖

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

改造启动类ZhangsanServiceApplication.java:

package com.gaox.zhangsanService;

import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.netflix.hystrix.EnableHystrix;
import org.springframework.context.annotation.Bean;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

@SpringBootApplication
@EnableEurekaClient
@EnableHystrix
@RestController
public class ZhangsanServiceApplication {

   public static void main(String[] args) {
      SpringApplication.run(ZhangsanServiceApplication.class, args);
   }
   @Bean
   @LoadBalanced
   public RestTemplate restTemplate(){
      return new RestTemplate();
   }

   @Autowired
   private RestTemplate restTemplate;

   @RequestMapping("/hello")
   @HystrixCommand(fallbackMethod = "helloError")
   public String hello(String name){
      String result=restTemplate.getForObject("http://HELLOSERVICE/hello?name="+name,String.class);
      return result;

   }
   public String helloError(String name){
      return "hello  ,"+name+"!  sorry ,error !";
   }
}

依次启动，serviceCenter,helloService:8762,helloService:8763,zhangsanService,在浏览器中访问http://localhost:8764/hello?name=zhangsan

浏览器依次会显示

你好，zhangsan。我是helloService,端口是8762

你好，zhangsan。我是helloService,端口是8763

此时关闭helloService:8763, http://localhost:8764/hello?name=zhangsan

浏览器依次会显示

你好，zhangsan。我是helloService,端口是8762

hello ,zhangsan! sorry ,error !

这说明当zhangsanService调用的服务helloService:8763不可用时，会执行快速失败，直接返回一个字符串，而不是等待响应超时，这就很好的控制了当大量请求涌入的时候线程不会阻塞

二、feign是自带断路器的，spring cloud的有些版本中，默认是关闭的，需要在配置文件中打开它，下面上一篇文章中的lisiService为基础来改造一下

Application.properties:

server.port=8765
spring.application.name=lisiService
eureka.client.service-url.defaultZone=http://localhost:8761/eureka/
feign.hystrix.enabled=true

LisiServiceApplication.java:

package com.gaox.lisiService;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.netflix.feign.EnableFeignClients;
import org.springframework.cloud.netflix.feign.FeignClient;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

@SpringBootApplication
@EnableEurekaClient
@EnableFeignClients
@RestController
public class LisiServiceApplication {

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


    @FeignClient(value = "helloService" ,fallback = HelloError.class)
    public interface HelloService {
        @RequestMapping(value = "/hello", method = RequestMethod.GET)
         String hello(@RequestParam("name") String name);
    }
    @Component
    public class HelloError implements HelloService {
        @Override
        public String hello(String name){
            return "hello  ,"+name+"!  sorry ,error !";
        }
    }
    @Autowired
   private HelloService helloService;

    @RequestMapping("/hello")
    public String hello(@RequestParam("name")String name){
    return helloService.hello(name);
    }
}

依次启动serviceCenter,helloService:8762,helloService:8763,lisiService，然后在浏览器输入http://localhost:8765/hello?name=lisi，浏览器会交替显示

你好，lisi。我是helloService,端口是8762

你好，lisi。我是helloService,端口是8763

此时关闭helloService:8763, http://localhost:8764/hello?name=zhangsan

浏览器依次会显示

你好，lisi。我是helloService,端口是8762

hello , lisi! sorry ,error !

这说明断路器起作用了，当lisiService调用的服务helloService:8763不可用时，会执行快速失败，直接返回一个字符串，而不是等待响应超时，这就很好的控制了当大量请求涌入的时候线程不会阻塞

三、在feign中使用hystrix dashboard(仪表盘)功能

Pom.xml添加以下内容：

<dependency>
   <groupId>org.springframework.cloud</groupId>
   <artifactId>spring-cloud-starter-hystrix</artifactId>
</dependency>
<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>

LisiServiceApplication.java启动类上加两个注解@EnableHystrixDashboard
和@EnableCircuitBreaker

package com.gaox.lisiService;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.netflix.feign.EnableFeignClients;
import org.springframework.cloud.netflix.feign.FeignClient;
import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

@SpringBootApplication
@EnableEurekaClient
@EnableFeignClients
@RestController
@EnableHystrixDashboard
@EnableCircuitBreaker
publicclass LisiServiceApplication {

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

    @FeignClient(value = "helloService",fallback = HelloError.class)
    public interface HelloService{
        @RequestMapping(value = "/hello", method =RequestMethod.GET)
         String hello(@RequestParam("name") Stringname);
    }
    @Component
    public class HelloError implements HelloService{
        @Override
        public String hello(Stringname){
            return "hello ,"+name+"! sorry ,error !";
        }
    }
    @Autowired
   private HelloService helloService;

    @RequestMapping("/hello")
    public String hello(@RequestParam("name")Stringname){
    return helloService.hello(name);
    }
}

打开浏览器：访问http://localhost:8765/hystrix,界面如下：

第一个输入框：http://localhost:8765/hystrix.stream

Delay：默认不变即可

Title:（这个可以随便输入）

然后点击按钮进入，如图

四、在ribbon中使用hystrix dashboard(仪表盘)功能

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>

LisiServiceApplication.java启动类上加个注解@EnableHystrixDashboard
package com.gaox.zhangsanService;

import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.netflix.hystrix.EnableHystrix;
import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;
import org.springframework.context.annotation.Bean;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

@SpringBootApplication
@EnableEurekaClient
@EnableHystrix
@EnableHystrixDashboard
@RestController
public class ZhangsanServiceApplication {

   public static void main(String[] args) {
      SpringApplication.run(ZhangsanServiceApplication.class, args);
   }
   @Bean
   @LoadBalanced
   public RestTemplate restTemplate(){
      return new RestTemplate();
   }

   @Autowired
   private RestTemplate restTemplate;

   @RequestMapping("/hello")
   @HystrixCommand(fallbackMethod = "helloError")
   public String hello(String name){
      String result=restTemplate.getForObject("http://HELLOSERVICE/hello?name="+name,String.class);
      return result;

   }
   public String helloError(String name){
      return "hello  ,"+name+"!  sorry ,error !";
   }
}

然后打开浏览器之后的操作和上面feign方法的一样。

向您推荐>>Eolink开发者社区

权威｜前沿｜技术｜干货｜国内首个API全生命周期开发者社区

更多推荐

深入理解 Mocha 测试框架：从零实现一个 Mocha

前言什么是自动化测试自动化测试在很多团队中都是Devops环节中很难执行起来的一个环节，主要原因在于测试代码的编写工作很难抽象，99%的场景都需要和业务强绑定，而且写测试代码的编写工作量往往比编写实际业务代码的工作量更多。在一些很多业务场景中投入产出比很低，适合写自动化测试的应该是那些中长期业务以及一些诸如组件一样的基础库。自动化测试是个比较大的概念，其中分类也比较多，比如单元测试，端对端测试，集

云原生

ELK实现containerd的容器日志采集展示【基于logging的全栈监测】

企业级ELK Stack构建介绍

云原生

(20200916 Solved)docker-compose up创建容器自动退出

问题描述如题，创建容器后自动退出了。并且docker start container无效解决方案原因是缺失了控制终端的配置，需要在docker-compose.yml中增加tty:true ，有时候这样也不行，需要再增加一个command:/bin/bash，命令不一定是这个，需要是一个不会退出的命令，然后用-d后台启动容器。Referencesdocker-compose启动容器后自动退出...

云原生

所有评论(0)

查看更多评论

凡夫贩夫

@fox9916

已为社区贡献1条内容