diff --git a/README.md b/README.md index c855886..9a54781 100644 --- a/README.md +++ b/README.md @@ -66,18 +66,18 @@ spring-cloud：Finchley.SR2 ## 3. spring-cloud samples -| samples | 描述 | 官方文档 | -| ------------------------------------------------------------ | ---------------------------------- | ------------------------------------------------------------ | -| spring-cloud | 微服务简介与用例说明 | | -| [spring-cloud-Eureka](https://github.com/heibaiying/spring-samples-for-all/tree/master/spring-cloud/spring-cloud-eureka) | 服务的注册和发现 | [Service Discovery: Eureka Clients](https://cloud.spring.io/spring-cloud-static/spring-cloud-netflix/2.1.0.RC3/single/spring-cloud-netflix.html#_service_discovery_eureka_clients) | -| [spring-cloud-Eureka-cluster](https://github.com/heibaiying/spring-samples-for-all/tree/master/spring-cloud/spring-cloud-eureka-cluster) | eureka 高可用集群搭建 | | -| spring-cloud-Ribbon | RestTemplate的使用、客户端负载均衡 | [ribbon](http://cloud.spring.io/spring-cloud-netflix/multi/multi_spring-cloud-ribbon.html) | -| spring-cloud-OpenFeign | 声明式服务调用 | [Spring Cloud OpenFeign 官方文档](https://spring.io/projects/spring-cloud-openfeign#learn) | -| spring-cloud-Hystrix | 熔断器 | | -| spring-cloud-zuul | 网关服务 | [Router and Filter: Zuul](http://projects.spring.io/spring-cloud/spring-cloud.html#_router_and_filter_zuul) | -| spring-cloud-sleuth-Zipkin | 分布式系统服务追踪 | [Spring Cloud Sleuth](https://spring.io/projects/spring-cloud-sleuth#learn) | -| spring-cloud-config-bus | 配置中心 + 消息总线实现配置热更新 | [Spring Cloud Config](https://spring.io/projects/spring-cloud-config#learn) | -| spring-cloud-stream | spring cloud 对消息服务的抽象整合 | [spring-cloud-stream官方文档](https://cloud.spring.io/spring-cloud-stream/) | +| samples | 描述 | 官方文档 | +| ------------------------------------------------------------ | ----------------------------------------- | ------------------------------------------------------------ | +| spring-cloud | 微服务简介与用例说明 | | +| [spring-cloud-Eureka](https://github.com/heibaiying/spring-samples-for-all/tree/master/spring-cloud/spring-cloud-eureka) | 服务的注册和发现 | [Service Discovery: Eureka Clients](https://cloud.spring.io/spring-cloud-static/spring-cloud-netflix/2.1.0.RC3/single/spring-cloud-netflix.html#_service_discovery_eureka_clients) | +| [spring-cloud-Eureka-cluster](https://github.com/heibaiying/spring-samples-for-all/tree/master/spring-cloud/spring-cloud-eureka-cluster) | eureka 高可用集群搭建 | | +| spring-cloud-Ribbon | RestTemplate的使用、客户端负载均衡 | [ribbon](http://cloud.spring.io/spring-cloud-netflix/multi/multi_spring-cloud-ribbon.html) | +| spring-cloud-OpenFeign | 声明式服务调用 | [Spring Cloud OpenFeign 官方文档](https://spring.io/projects/spring-cloud-openfeign#learn) | +| spring-cloud-Hystrix | 熔断器的实现、熔断器监控、turbine聚合监控 | | +| spring-cloud-zuul | 网关服务 | [Router and Filter: Zuul](http://projects.spring.io/spring-cloud/spring-cloud.html#_router_and_filter_zuul) | +| spring-cloud-sleuth-Zipkin | 分布式系统服务追踪 | [Spring Cloud Sleuth](https://spring.io/projects/spring-cloud-sleuth#learn) | +| spring-cloud-config-bus | 配置中心 + 消息总线实现配置热更新 | [Spring Cloud Config](https://spring.io/projects/spring-cloud-config#learn) | +| spring-cloud-stream | spring cloud 对消息服务的抽象整合 | [spring-cloud-stream官方文档](https://cloud.spring.io/spring-cloud-stream/) |
diff --git a/pictures/circuitbreaker.png b/pictures/circuitbreaker.png new file mode 100644 index 0000000..9268afe Binary files /dev/null and b/pictures/circuitbreaker.png differ diff --git a/pictures/common-feign.png b/pictures/common-feign.png new file mode 100644 index 0000000..98f2c69 Binary files /dev/null and b/pictures/common-feign.png differ diff --git a/pictures/dashboard-direct-vs-turbine-640.png b/pictures/dashboard-direct-vs-turbine-640.png new file mode 100644 index 0000000..d7f4df3 Binary files /dev/null and b/pictures/dashboard-direct-vs-turbine-640.png differ diff --git a/pictures/dashboard.png b/pictures/dashboard.png new file mode 100644 index 0000000..9509cfe Binary files /dev/null and b/pictures/dashboard.png differ diff --git a/pictures/feign-8040.png b/pictures/feign-8040.png new file mode 100644 index 0000000..28fc096 Binary files /dev/null and b/pictures/feign-8040.png differ diff --git a/pictures/feign-consumer.png b/pictures/feign-consumer.png new file mode 100644 index 0000000..c9ddf01 Binary files /dev/null and b/pictures/feign-consumer.png differ diff --git a/pictures/feign-hystrix-maven.png b/pictures/feign-hystrix-maven.png new file mode 100644 index 0000000..53196ec Binary files /dev/null and b/pictures/feign-hystrix-maven.png differ diff --git a/pictures/feign-producer.png b/pictures/feign-producer.png new file mode 100644 index 0000000..49f676b Binary files /dev/null and b/pictures/feign-producer.png differ diff --git a/pictures/hystrix-8030-login.png b/pictures/hystrix-8030-login.png new file mode 100644 index 0000000..2798906 Binary files /dev/null and b/pictures/hystrix-8030-login.png differ diff --git a/pictures/hystrix-8030.png b/pictures/hystrix-8030.png new file mode 100644 index 0000000..011df85 Binary files /dev/null and b/pictures/hystrix-8030.png differ diff --git a/pictures/hystrix-c.png b/pictures/hystrix-c.png new file mode 100644 index 0000000..1e5be39 Binary files /dev/null and b/pictures/hystrix-c.png differ diff --git a/pictures/hystrix-single-login.png b/pictures/hystrix-single-login.png index a0b3403..5785437 100644 Binary files a/pictures/hystrix-single-login.png and b/pictures/hystrix-single-login.png differ diff --git a/pictures/openfeign.png b/pictures/openfeign.png new file mode 100644 index 0000000..d309f1e Binary files /dev/null and b/pictures/openfeign.png differ diff --git a/pictures/spring-cloud-feign.png b/pictures/spring-cloud-feign.png new file mode 100644 index 0000000..f04cde0 Binary files /dev/null and b/pictures/spring-cloud-feign.png differ diff --git a/pictures/spring-cloud-hystrix.png b/pictures/spring-cloud-hystrix.png new file mode 100644 index 0000000..f0d1bd7 Binary files /dev/null and b/pictures/spring-cloud-hystrix.png differ diff --git a/spring-cloud/spring-cloud-hystrix/README.md b/spring-cloud/spring-cloud-hystrix/README.md index 342e81d..3ffcfae 100644 --- a/spring-cloud/spring-cloud-hystrix/README.md +++ b/spring-cloud/spring-cloud-hystrix/README.md @@ -1,3 +1,325 @@ -http://localhost:8040/turbine.stream +# spring-cloud-hystrix-turbine -http://localhost:8020/actuator/hystrix.stream \ No newline at end of file +## 一、hystrix 简介 + +#### 1.1 熔断器 + +在分布式系统中，由于服务之间相互的依赖调用，如果一个服务单元发生了故障就有可能导致故障蔓延至整个系统，从而衍生出一系列的保护机制，断路器就是其中之一。 + +断路器可以在服务单元发生故障的时候，及时切断与服务单元的连接，避免资源被长时间占用。spring cloud hystrix组件实现了断路器、线程隔离等一系列基本功能，并具有服务降级、服务熔断、请求缓存、请求合并以及服务监控等配套功能。 + + + +#### 1.2 hystrix 工作机制 + +- 当一个服务的处理请求的失败次数低于阈值时候，熔断器处于关闭状态，服务正常； +- 当一个服务的处理请求的失败次数大于阈值时候，熔断器开启，这时候所有的请求都会执行快速失败，是不会去调用实际的服务的； +- 当熔断器处于打开状态的一段时间后，熔断器处于半打开状态，这时候一定数量的请求回去调用实际的服务，如果调用成功，则代表服务可用了，熔断器关闭；如果还是失败，则代表服务还是不可用，熔断器继续关闭。 + +![circuitbreaker](D:\spring-samples-for-all\pictures\circuitbreaker.png) + +## 二、项目结构 + +[spring-cloud-ribbon](https://github.com/heibaiying/spring-samples-for-all/tree/master/spring-cloud/spring-cloud-ribbon)用例已经实现通过ribbon+restTemplate实现服务间的调用，本用例在其基础上进行hystrix 的整合。 + ++ common: 公共的接口和实体类； ++ consumer: 服务的消费者，采用RestTemplate调用产品服务； ++ producer：服务的提供者； ++ eureka: 注册中心； ++ turbine:多个熔断器的聚合监控。 + +![spring-cloud-hystrix](D:\spring-samples-for-all\pictures\spring-cloud-hystrix.png) + + + +## 三、整合 hystrix （以consumer模块为例） + +#### 3.1 引入依赖 + +hystrix的仪表盘功能实际上是从[端点](https://github.com/heibaiying/spring-samples-for-all/tree/master/spring-boot/spring-boot-actuator)获取数据，所以需要actuator starter开启端点的相关功能。 + +```xml + + + org.springframework.cloud + spring-cloud-starter-netflix-hystrix + + + + org.springframework.cloud + spring-cloud-starter-netflix-hystrix-dashboard + + + + org.springframework.boot + spring-boot-starter-actuator + +``` + +#### 3.2 暴露端点 + +```java +management: + endpoints: + web: + exposure: + # 需要开启hystrix.stream端点的暴露 这样才能获取到监控信息 * 代表开启所有可监控端点 + include: "*" +``` + +#### 3.3 在启动类上添加注解@EnableHystrix和@EnableHystrixDashboard + +```java +@SpringBootApplication +@EnableDiscoveryClient +@EnableHystrix +@EnableHystrixDashboard +public class ConsumerApplication { + + public static void main(String[] args) { + SpringApplication.run(ConsumerApplication.class, args); + } +} +``` + +#### 3.4 使用 @HystrixCommand 定义失败回退的方法 + +```java +@HystrixCommand(fallbackMethod = "queryProductsFail") +public List queryAllProducts() { + ResponseEntity responseEntity = restTemplate.getForEntity("http://producer/products", List.class); + List productList = responseEntity.getBody(); + return productList; +} + +// 如果发送熔断返回空集合，在前端判断处理 +public List queryProductsFail() { + return new ArrayList<>(); +} +``` + +```html + + + + 产品列表 + + +

产品列表:点击查看详情

+
+ + +
+
    + <#if (products?size>0) > + <#list products as product> +
  • + ${product.name} +
    • + + <#else> +

    当前排队人数过多，请之后再购买！

    + +
+ + +``` + +#### 3.5 模拟熔断 + +这里被调用方采用线程休眠的方式模拟服务超时，Hystrix默认超时时间为2s,调用远程服务时候超过这个时间，会触发熔断。 + +```java +public List queryAllProducts() { + // hystrix 默认超时是2秒 + int i = new Random().nextInt(2500); + try { + Thread.sleep(i); + } catch (InterruptedException e) { + e.printStackTrace(); + } + return productList; +} +``` + +3.5 启动服务，访问http://localhost:8030/sell/products ，多次刷新查看熔断情况 + +![hystrix-8030](D:\spring-samples-for-all\pictures\hystrix-8030.png) + +#### 3.5 启动服务，访问 localhost:8030/hystrix + +依次输出http://localhost:8030/actuator/hystrix.stream（监控地址） ，2000（延迟时间），title可以任意填写，进入监控台。 + +需要注意的是在spring cloud Finchley.SR2，监控地址中都是有/actuator的，因为在spring boot 2.x 的所有端点（包括自定义端点）都是暴露在这个路径下，在启动时候的控制台输出的日志可以查看到所有暴露端点的映射。 + +**登录页面**： + +![hystrix-single-login](D:\spring-samples-for-all\pictures\hystrix-single-login.png) + +**监控页面**： + +![hystrix-single](D:\spring-samples-for-all\pictures\hystrix-8030-login.png) + +**关于各个参数的说明参见[官方wiki](https://github.com/Netflix-Skunkworks/hystrix-dashboard/wiki)提供的图**： + +![dashboard](D:\spring-samples-for-all\pictures\dashboard.png) + + + + + +## 四、使用turbine 实现聚合监控 + +单体监控和聚合监控： + +![dashboard-direct-vs-turbine-640](D:\spring-samples-for-all\pictures\dashboard-direct-vs-turbine-640.png) + + + +#### 4.1 创建turbine模块，导入依赖 + +```xml + + + 4.0.0 + + + com.heibaiying.hystrix + spring-cloud-hystrx + 0.0.1-SNAPSHOT + + + turbine + + + + org.springframework.cloud + spring-cloud-starter-netflix-eureka-client + + + org.springframework.boot + spring-boot-starter-actuator + + + org.springframework.cloud + spring-cloud-starter-netflix-hystrix + + + org.springframework.cloud + spring-cloud-starter-netflix-hystrix-dashboard + + + org.springframework.cloud + spring-cloud-starter-netflix-turbine + + + + + + + + org.springframework.boot + spring-boot-maven-plugin + + + + + + +``` + + + +#### 4.2 指定注册中心地址和聚合的项目，这里我们监控 consumer,producer 两个项目 + +```java +server: + port: 8040 +# 指定服务命名 +spring: + application: + name: turbine +# 指定注册中心地址 +eureka: + client: + serviceUrl: + defaultZone: http://localhost:8010/eureka/ +# 指定聚合的项目 +turbine: + aggregator: + cluster-config: default + combine-host-port: true + app-config: consumer,producer + clusterNameExpression: "'default'" +``` + + + +#### 4.3 在启动类上添加注解 + +```java +@SpringBootApplication +@EnableDiscoveryClient +@EnableHystrix +@EnableHystrixDashboard +@EnableTurbine +public class TurbineApplication { + + public static void main(String[] args) { + SpringApplication.run(TurbineApplication.class, args); + } + +} +``` + + + +#### 4.4 依次启动eureka、producer、consumer、turbine四个项目 + +在 localhost:8030/hystrix或者localhost:8030/hystrix（consumer和producer都集成了hystrix） 页面输入http://localhost:8040/turbine.stream，查看断路器聚合信息 + +![hystrix-cluster-login](D:\spring-samples-for-all\pictures\hystrix-cluster-login.png) + +**显示了不同服务单元（consumer,producer）的多个断路器信息：** + +![hystrix-cluster](D:\spring-samples-for-all\pictures\hystrix-cluster.png) + +## 五、整合过程中可能出现的问题 + +#### 5.1 无法访问监控页面 + +1. 一般是端点链接输入不对，在F版本的spring cloud 中，输入监控的端点链接是 http://localhost:8030/actuator/hystrix.stream，中间是有/actuator/（之前版本的没有/actuator/） + +2. 没有暴露端点链接，暴露端点链接有两种方式，一种是我们在上文中提到的基于配置的方式 + + ```yaml + management: + endpoints: + web: + exposure: + # 需要开启hystrix.stream端点的暴露 这样才能获取到监控信息 * 代表开启所有可监控端点 + include: "*" + ``` + + 第二种方式是基于代码的方式，如下： + + ```java + @Bean + public ServletRegistrationBean getServlet() { + HystrixMetricsStreamServlet streamServlet = new HystrixMetricsStreamServlet(); + ServletRegistrationBean registrationBean = new ServletRegistrationBean(streamServlet); + registrationBean.setLoadOnStartup(1); + registrationBean.addUrlMappings("/actuator/hystrix.stream"); + registrationBean.setName("HystrixMetricsStreamServlet"); + return registrationBean; + } + ``` + + 这两种方式二选一即可，就算是采用代码的方式，还是建议将地址设置为/actuator/hystrix.stream，而不是原来的hystrix.stream，因为turbine默认也是从/actuator/hystrix.stream去获取信息。 + +#### 5.2 页面一直loading 或者访问端点页面一直出现ping + +这种情况是熔断器所在的方法没有被调用，不是整合问题，这时候调用一下熔断器所在方法即可。 + +![hystrix-loading](D:\spring-samples-for-all\pictures\hystrix-loading.png) \ No newline at end of file diff --git a/spring-cloud/spring-cloud-hystrix/consumer/pom.xml b/spring-cloud/spring-cloud-hystrix/consumer/pom.xml index 85c007f..77734bd 100644 --- a/spring-cloud/spring-cloud-hystrix/consumer/pom.xml +++ b/spring-cloud/spring-cloud-hystrix/consumer/pom.xml @@ -34,7 +34,7 @@ org.springframework.cloud spring-cloud-starter-netflix-hystrix - + org.springframework.cloud spring-cloud-starter-netflix-hystrix-dashboard diff --git a/spring-cloud/spring-cloud-hystrix/consumer/src/main/resources/application.yml b/spring-cloud/spring-cloud-hystrix/consumer/src/main/resources/application.yml index 87261f0..463e428 100644 --- a/spring-cloud/spring-cloud-hystrix/consumer/src/main/resources/application.yml +++ b/spring-cloud/spring-cloud-hystrix/consumer/src/main/resources/application.yml @@ -13,6 +13,6 @@ management: endpoints: web: exposure: - # 需要开启hystrix.stream端点的暴露 这样才能获取到监控信息 * 代表开启可监控端点 + # 需要开启hystrix.stream端点的暴露 这样才能获取到监控信息 * 代表开启所有可监控端点 include: "*"