当前位置: 代码迷 >> 综合 >> Spring Cloud Hystrix(服务容错保护)(1)
  详细解决方案

Spring Cloud Hystrix(服务容错保护)(1)

热度:98   发布时间:2023-11-20 01:36:24.0

在前面的博客中我已经将Eureka与Ribbon的使用展示了出来,但是如果将其中的某一个服务停止(Hello-Service)。你会发现Ribbon任然会去访问那个页面。

这就需要用到断路器的功能。

首先将Ribbon工程的pom文件中加入该jar包:

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

再其主类工程中使用@EnableCircuitBreaker注解开启断路器功能:

@EnableCircuitBreaker
@EnableDiscoveryClient
@SpringBootApplication
public class EurekaRibbonApplication {@Bean@LoadBalancedRestTemplate restTemplate() {return new RestTemplate();}public static void main(String[] args) {SpringApplication.run(EurekaRibbonApplication.class, args);}
}

也可以用@SpringCloudApplication注解来替代:

@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Inherited
@SpringBootApplication
@EnableDiscoveryClient
@EnableCircuitBreaker
public @interface SpringCloudApplication {
}

然后改造其服务的消费方式,新增Service层,注入RestTemplate实例。然后在其方法上添加@HystrixCommand注解来指定回调方法:

@Service
public class HelloService {@AutowiredRestTemplate restTemplate;@HystrixCommand(fallbackMethod = "helloFallback")public String helloService() {ResponseEntity<String> responseEntity = restTemplate.getForEntity("http://hello-service/hello", String.class);String body = responseEntity.getBody();return body;}public String helloFallback() {return "error";}
}

Controller类改成如下:

@RestController
public class ConsumerController {@AutowiredHelloService helloService;@RequestMapping("/ribbon-consumer")public String helloConsumer() {return helloService.helloService();}
}

运行后:

然后中断一个服务

随后可以发现再请求http://localhost:8099/ribbon-consumer它不会再请求已经断开的服务。

除了断开服务实例来模拟节点无法访问的情况之外,我们还能模拟下服务阻塞(长时间未响应)如:

@RestController
public class HelloController {private final Logger logger=Logger.getLogger(getClass());@Autowiredprivate DiscoveryClient client;@RequestMapping("/hello")public String index() throws InterruptedException {int sleepTime=new Random().nextInt(3000);logger.info("sleep:"+sleepTime);Thread.sleep(sleepTime);return "Hello";}}

修改Hello-Service中的服务提供者的代码,用Thread.sleep来进行模拟延时。

因为Hystrix默认的超时时间为1000毫秒,所以这里用0-3000的随机数进行了模拟,为了方便观察断路器的触发,在消费者调用函数也做了时间的记录:

   @HystrixCommand(fallbackMethod = "helloFallback")public String helloService() {long start=System.currentTimeMillis();ResponseEntity<String> responseEntity = restTemplate.getForEntity("http://hello-service/hello", String.class);String body = responseEntity.getBody();long end=System.currentTimeMillis();logger.info("消耗时间:"+(start-end));return body;}

此时可以看到当sleep大于1000的时候它就会返回error,即服务消费者因调用服务超时从而触发熔断请求,并回调逻辑返回结果。

 

  相关解决方案