Spring-Cloud服务容错保护之Hystrix初探_JAVA_编程开发_程序员俱乐部

中国优秀的程序员网站程序员频道CXYCLUB技术地图
最新资讯 | 百度新闻 | GOOGLE地图 | RSS订阅 | 更多
热搜：
更多>>
 
您所在的位置： 程序员俱乐部 > 编程开发 > JAVA > Spring-Cloud服务容错保护之Hystrix初探

Spring-Cloud服务容错保护之Hystrix初探

 2018/4/28 18:56:45  就是我leonardc  程序员俱乐部  我要评论(0)
  • 摘要：在微服务架构中，存在着多个服务单元，若一个单元出现故障，就很容易因依赖关系而出现故障的蔓延，最终导致整个系统的瘫痪，这样的架构相较传统的架构更加不稳定，为了解决这样的问题，产生了断路器等一系列的服务保护机制。"断路器"本身是一种开关装置，用于在电路上保护线路过载，当线路中有电器发生短路，"断路器"能够及时切断故障电路，防止发生过载、发热甚至起火等严重后果。分布式架构中，断路器模式的作用也是类似的，当某个服务单元发生故障（类似于用电器发生短路）之后，通过断路器的故障监控（l类似熔断器保险丝）
  • 标签：Spring 服务

class="article-title" style="">在微服务架构中，存在着多个服务单元，若一个单元出现故障，就很容易因依赖关系而出现故障的蔓延，最终导致整个系统的瘫痪，这样的架构相较传统的架构更加不稳定，为了解决这样的问题，产生了断路器等一系列的服务保护机制。

"断路器"本身是一种开关装置，用于在电路上保护线路过载，当线路中有电器发生短路，"断路器"能够及时切断故障电路，防止发生过载、发热甚至起火等严重后果。

分布式架构中，断路器模式的作用也是类似的，当某个服务单元发生故障（类似于用电器发生短路）之后，通过断路器的故障监控（l类似熔断器保险丝），向调用方返回一个错误响应，而不是长时间的等待。这样就不会使得线程因调用故障服务被长时间占用不释放，避免了故障在分布式系统的蔓延。

针对上述问题，SpringCloudHystrix实现了断路器、线程隔离等一系列服务保护功能。它也是基于Netflix的开源框架Hystrix实现的，该框架的目标在于通过控制那些访问远程系统、服务和第三方库的节点，从而对延迟和故障提供强大的容错能力。Hystrix具备服务降级、服务熔断、线程和信号隔离、请求缓存合并以及服务监控等强大的功能。 -----来自《SpringCloud微服务实战》

Spring-Cloud服务容错保护之Hystrix初探

上图为正常的微服务调用

Spring-Cloud服务容错保护之Hystrix初探

当某个服务出现故障Hystrix回退防止级联故障，较低级别的服务中的服务故障可能导致用户级联故障。当对特定服务的检测达到一定阈值时（Hystrix中的默认值为5秒内的20次故障），电路打开，不进行响应。在错误和开路的情况下，开发人员可以提供后备（即服务降级）。

演示未加入熔断器

启动高可用注册中心

启动服务提供者（port=8081,port=8082）

启动消费者(通过Robbin负载均衡访问)

之前的博客已经演示过了，在两个服务提供者都正常使用的情况，停用端口8082的服务提供者，当消费者负载均衡轮训访问到8082端口的时候就会报如下错误：

Spring-Cloud服务容错保护之Hystrix初探

加入熔断器

1.pom.xml中引入依赖hystrix依赖

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">

<modelVersion>4.0.0</modelVersion>

<groupId>6.spring-cloud-hystrix-consumer</groupId>

<artifactId>hystrix-consumer</artifactId>

<packaging>jar</packaging>

<version>0.0.1-SNAPSHOT</version>

<name>spring-cloud Maven Webapp</name>

<url>http://maven.apache.org</url>

<!--springboot采用1.5.x 对应springcloud版本为 Dalston -->

<parent>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-parent</artifactId>

<version>1.5.2.RELEASE</version>

<relativePath />

</parent>

<properties>

<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>

<java.version>1.8</java.version>

<spring-cloud.version>Dalston.RELEASE</spring-cloud.version>

</properties>

<dependencies>

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-web</artifactId>

</dependency>

<dependency>

<groupId>org.springframework.cloud</groupId>

<artifactId>spring-cloud-starter</artifactId>

</dependency>

<dependency>

<groupId>org.springframework.cloud</groupId>

<artifactId>spring-cloud-starter-eureka</artifactId>

</dependency>

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-test</artifactId>

<scope>test</scope>

</dependency>

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-actuator</artifactId>

</dependency>

<!--引入ribbon 负载均衡 -->

<dependency>

<groupId>org.springframework.cloud</groupId>

<artifactId>spring-cloud-starter-ribbon</artifactId>

<!-- 搞了好久踩的坑，就是在复制上面代码的时候 顺手把scope test复制了，其意思为紧参与junit类似的测试工作，所以一直报找不到服务或者或者拒绝连接 -->

<!-- <scope>test</scope> -->

</dependency>

<!--引入hystrix熔断器 -->

<dependency>

<groupId>org.springframework.cloud</groupId>

<artifactId>spring-cloud-starter-hystrix</artifactId>

</dependency>

</dependencies>

<dependencyManagement>

<dependencies>

<dependency>

<groupId>org.springframework.cloud</groupId>

<artifactId>spring-cloud-dependencies</artifactId>

<version>${spring-cloud.version}</version>

<type>pom</type>

<scope>import</scope>

</dependency>

</dependencies>

</dependencyManagement>

<!-- 这样变成可执行的jar -->

<build>

<plugins>

<plugin>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-maven-plugin</artifactId>

</plugin>

</plugins>

</build>

</project>

2.在springboot启动类中添加开启熔断器的注解

package com.niugang;

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

import org.springframework.cloud.client.loadbalancer.LoadBalanced;

import org.springframework.cloud.netflix.hystrix.EnableHystrix;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.ComponentScan;

import org.springframework.web.client.RestTemplate;

/**

* 负责服务的发现与消费

*

* @author niugang

*

*/

@SpringBootApplication

@EnableDiscoveryClient

@EnableHystrix//这个注解就@EnableCircuitBreaker的代替

/*

* @SpringCloudApplication

* 包含了

* @SpringBootApplication

* @EnableDiscoveryClient

* @EnableCircuitBreaker

* 着三个注解

*/

@ComponentScan

public class Application {

//负载均衡

@LoadBalanced

@Bean

public RestTemplate restTemplate() {

return new RestTemplate();

}

public static void main(String[] args) {

SpringApplication.run(Application.class, args);

}

}

3.controller

package com.niugang.controller;

import org.slf4j.Logger;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestMethod;

import org.springframework.web.bind.annotation.RestController;

import com.niugang.service.HelloService;

@RestController

public class HelloController {

private final Logger logger = org.slf4j.LoggerFactory.getLogger(HelloController.class);

@Resource

private HelloService helloService;

@RequestMapping(value = "/ribbon-consumer", method = RequestMethod.GET)

public String ribbon() {

return helloService.helloService();

}

}

4.service

package com.niugang.service;

import org.slf4j.Logger;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Service;

import org.springframework.web.client.RestTemplate;

import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;

@Service

public class HelloService {

private final Logger logger = org.slf4j.LoggerFactory.getLogger(HelloService.class);

@Autowired

privateRestTemplate restTemplate;

/**

* @HystrixCommand:指定一些方法，这些方法应该是作为hystrix命令的进程

* fallbackMethod:指定回退方法，降级处理，此方法应该和@HystrixCommand在一个类中，用来实现服务降级处理逻辑

*

*/

@HystrixCommand(fallbackMethod="helloBackMethodFirst")

public String helloService() {

logger.info("start invoke service");

//URI需要使用虚拟主机名（即服务名称，而不是主机名)

return restTemplate.getForEntity("http://service-provide/hello", String.class).getBody();

}

/**

* 通用降级函数

* @return

*/

@HystrixCommand(fallbackMethod="helloBackMethodSecond")

public String helloBackMethodFirst(){

//此处可能是另外一个网络请求，所以也可能出现错误

return "error1";

}

/**

* 二次降级

* @return

*/

@HystrixCommand(fallbackMethod="helloBackMethodSecond")

public String helloBackMethodSecond(){

return "error2";

}

}

启动消费者，正常访问返回如下：

Spring-Cloud服务容错保护之Hystrix初探

停用一个服务提供者，当负载均衡讯轮到停用的服务提供者时，返回如下：

Spring-Cloud服务容错保护之Hystrix初探

这样的话熔断器起作用了，进行了服务的降级。

健康指标

连接断路器的状态也暴露在呼叫应用程序的/health端点中。

{

"hystrix": {

"openCircuitBreakers": [

"StoreIntegration::getStoresByLocationLink"

],

"status": "CIRCUIT_OPEN"

},

"status": "UP"

}

Hystrix指标流

要使Hystrix指标流包含对spring-boot-starter-actuator的依赖。这将使/hystrix.stream作为管理端点。

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-actuator</artifactId>

</dependency>

上一篇： [转载]Java开发如何在线打开Word文件 下一篇： 没有下一篇了!
Spring-Cloud服务容错保护之Hystrix初探
使用jMeter构造大量并发HTTP请求进行微服务性能测试
Java进阶必知：从分布式到微服务，深挖Service Mesh
Spring boot: 读取服务端指定位置文件并返回
如何用Nginx搭建一个安全的、快速的微服务架构

发表评论
用户名: 匿名

最新文章
Spring-Cloud服务容错保护之Hystrix初探
Spring-..
使用jMeter构造大量并发HTTP请求进行微服务性能测试
使用jMete..

最新标签
  • 分享
  • 小米
  • 高手
  • 大型网站
  • 天猫
  • 回溯
  • 循环
  • SWT
  • class
  • instance

    • 今日热点

    推荐文章
    unable to find valid certification path to requested target 的简单解决办法
    unable ..
    老三携剑出山，Swing法力无边
    老..