feat(master):Hystrix 2

Hystrix 完结

dev-protocol-springcloud/dev-protocol-springcloud-hystrix-dashboard/README.md

@@ -0,0 +1,3 @@
+## hystrix-dashboard
+
+- hystrix 监控面板

dev-protocol-springcloud/dev-protocol-springcloud-hystrix-dashboard/pom.xml

@@ -0,0 +1,69 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<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/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>org.example</groupId>
+        <artifactId>dev-protocol</artifactId>
+        <version>1.0-SNAPSHOT</version>
+        <relativePath>../../pom.xml</relativePath>
+    </parent>
+
+    <artifactId>dev-protocol-springcloud-hystrix-dashboard</artifactId>
+    <version>1.0-SNAPSHOT</version>
+    <packaging>jar</packaging>
+
+    <!-- 模块名及描述信息 -->
+    <name>dev-protocol-springcloud-hystrix-dashboard</name>
+    <description>Hystrix Dashboard</description>
+
+
+    <properties>
+        <maven.compiler.source>8</maven.compiler.source>
+        <maven.compiler.target>8</maven.compiler.target>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    </properties>
+
+    <dependencies>
+        <!-- spring cloud alibaba nacos discovery 依赖 -->
+        <dependency>
+            <groupId>com.alibaba.cloud</groupId>
+            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+        <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>
+    </dependencies>
+
+    <!--
+        SpringBoot的Maven插件, 能够以Maven的方式为应用提供SpringBoot的支持，可以将
+        SpringBoot应用打包为可执行的jar或war文件, 然后以通常的方式运行SpringBoot应用
+     -->
+    <build>
+        <finalName>${artifactId}</finalName>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+                <executions>
+                    <execution>
+                        <goals>
+                            <goal>repackage</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>

dev-protocol-springcloud/dev-protocol-springcloud-hystrix-dashboard/src/main/java/org/example/HystrixDashboardApplication.java

@@ -0,0 +1,21 @@
+package org.example;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
+import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;
+
+/**
+ * <h1>hystrix dashboard 入口</h1>
+ * 控制台页面 http://127.0.0.1:9999/dev-protocol-springcloud-hystrix-dashboard/hystrix/
+ * 需要监控的服务 stream 拼接: http://127.0.0.1:8111/dev-protocol-springcloud-hystrix/actuator/hystrix.stream
+ * */
+@EnableDiscoveryClient
+@SpringBootApplication
+@EnableHystrixDashboard     // 开启 Hystrix Dashboard
+public class HystrixDashboardApplication {
+    public static void main(String[] args) {
+
+        SpringApplication.run(HystrixDashboardApplication.class, args);
+    }
+}

dev-protocol-springcloud/dev-protocol-springcloud-hystrix-dashboard/src/main/resources/bootstrap.yml

@@ -0,0 +1,33 @@
+server:
+  port: 9999
+  servlet:
+    context-path: /dev-protocol-springcloud-hystrix-dashboard
+
+spring:
+  application:
+    name: dev-protocol-springcloud-hystrix-dashboard
+  cloud:
+    nacos:
+      # 服务注册发现
+      discovery:
+        enabled: true # 如果不想使用 Nacos 进行服务注册和发现, 设置为 false 即可
+        server-addr: 127.0.0.1:8848
+        #        server-addr: 127.0.0.1:8848,127.0.0.1:8849,127.0.0.1:8850 # Nacos 服务器地址
+        namespace: 1ccc74ae-9398-4dbe-b9d7-4f9addf9f40c
+        metadata:
+          management:
+            context-path: ${server.servlet.context-path}/actuator
+
+hystrix:
+  dashboard:
+    proxy-stream-allow-list: "127.0.0.1"
+
+# 暴露端点
+management:
+  endpoints:
+    web:
+      exposure:
+        include: '*'
+  endpoint:
+    health:
+      show-details: always

dev-protocol-springcloud/dev-protocol-springcloud-hystrix-dashboard/src/main/resources/http/dashboard.http

@@ -0,0 +1,31 @@
+### 获取 Token
+POST http://127.0.0.1:9001/dev-protocol-springcloud-gateway/dev-protocol-springcloud-hystrix/communication/token-by-feign
+Content-Type: application/json
+e-commerce-user: eyJhbGciOiJSUzI1NiJ9.eyJlLWNvbW1lcmNlLXVzZXIiOiJ7XCJpZFwiOjEwLFwidXNlcm5hbWVcIjpcIlFpbnlpQGltb29jLmNvbVwifSIsImp0aSI6IjJlMTgwYzA2LWIwZGQtNDJjYy1iNzk5LTZiNGI4N2Q3NTM3NCIsImV4cCI6MTYyNTQxNDQwMH0.P8gKWcwiibEmq80idCl9QzUaqJnQ7FVQ5yxzlMLfRNcG3nWMYh0o1kBO2vKvDGG8BofQ4__xn210R2P7zjH-uEn7hic0jbBt97vLkzvATnFegxaDSjUp9At9BIGl9Ecu7RPCwSQJFdw6NBMBz02Uom8yvHpUJEfv8_jZRurBp94tzES6IAACKC6NFq-3_mQfT4o_zA51U4hBbIBw6qNXvMSqK-VtaqkTNFfJsP_8Y0nmQck0jxmgdtLfRVfZCCp3rhcLNDBX37THQI6U7lvNFETceAKyJ5NFaA8p68lw_3D2IiZER1jEU3M2QIMQGeU0pmQ6IPwGDdA0MP5IKKzj8A
+token: imooc
+
+{
+  "username": "Qinyi@imooc.com",
+  "password": "25d55ad283aa400af464c76d713c07ad"
+}
+
+
+### 根据提供的 serviceId 获取实例信息
+GET http://127.0.0.1:9001/dev-protocol-springcloud-gateway/ecommerce-nacos-client/hystrix/hystrix-command-annotation?serviceId=e-commerce-nacos-client
+Content-Type: application/json
+e-commerce-user: eyJhbGciOiJSUzI1NiJ9.eyJlLWNvbW1lcmNlLXVzZXIiOiJ7XCJpZFwiOjEwLFwidXNlcm5hbWVcIjpcIlFpbnlpQGltb29jLmNvbVwifSIsImp0aSI6IjJlMTgwYzA2LWIwZGQtNDJjYy1iNzk5LTZiNGI4N2Q3NTM3NCIsImV4cCI6MTYyNTQxNDQwMH0.P8gKWcwiibEmq80idCl9QzUaqJnQ7FVQ5yxzlMLfRNcG3nWMYh0o1kBO2vKvDGG8BofQ4__xn210R2P7zjH-uEn7hic0jbBt97vLkzvATnFegxaDSjUp9At9BIGl9Ecu7RPCwSQJFdw6NBMBz02Uom8yvHpUJEfv8_jZRurBp94tzES6IAACKC6NFq-3_mQfT4o_zA51U4hBbIBw6qNXvMSqK-VtaqkTNFfJsP_8Y0nmQck0jxmgdtLfRVfZCCp3rhcLNDBX37THQI6U7lvNFETceAKyJ5NFaA8p68lw_3D2IiZER1jEU3M2QIMQGeU0pmQ6IPwGDdA0MP5IKKzj8A
+token: imooc
+
+
+### 根据提供的 serviceId 获取实例信息
+GET http://127.0.0.1:9001/dev-protocol-springcloud-gateway/ecommerce-nacos-client/hystrix/simple-hystrix-command?serviceId=e-commerce-nacos-client
+Content-Type: application/json
+e-commerce-user: eyJhbGciOiJSUzI1NiJ9.eyJlLWNvbW1lcmNlLXVzZXIiOiJ7XCJpZFwiOjEwLFwidXNlcm5hbWVcIjpcIlFpbnlpQGltb29jLmNvbVwifSIsImp0aSI6IjJlMTgwYzA2LWIwZGQtNDJjYy1iNzk5LTZiNGI4N2Q3NTM3NCIsImV4cCI6MTYyNTQxNDQwMH0.P8gKWcwiibEmq80idCl9QzUaqJnQ7FVQ5yxzlMLfRNcG3nWMYh0o1kBO2vKvDGG8BofQ4__xn210R2P7zjH-uEn7hic0jbBt97vLkzvATnFegxaDSjUp9At9BIGl9Ecu7RPCwSQJFdw6NBMBz02Uom8yvHpUJEfv8_jZRurBp94tzES6IAACKC6NFq-3_mQfT4o_zA51U4hBbIBw6qNXvMSqK-VtaqkTNFfJsP_8Y0nmQck0jxmgdtLfRVfZCCp3rhcLNDBX37THQI6U7lvNFETceAKyJ5NFaA8p68lw_3D2IiZER1jEU3M2QIMQGeU0pmQ6IPwGDdA0MP5IKKzj8A
+token: imooc
+
+
+### 根据提供的 serviceId 获取实例信息
+GET http://127.0.0.1:9001/dev-protocol-springcloud-gateway/ecommerce-nacos-client/hystrix/hystrix-observable-command?serviceId=e-commerce-nacos-client
+Content-Type: application/json
+e-commerce-user: eyJhbGciOiJSUzI1NiJ9.eyJlLWNvbW1lcmNlLXVzZXIiOiJ7XCJpZFwiOjEwLFwidXNlcm5hbWVcIjpcIlFpbnlpQGltb29jLmNvbVwifSIsImp0aSI6IjJlMTgwYzA2LWIwZGQtNDJjYy1iNzk5LTZiNGI4N2Q3NTM3NCIsImV4cCI6MTYyNTQxNDQwMH0.P8gKWcwiibEmq80idCl9QzUaqJnQ7FVQ5yxzlMLfRNcG3nWMYh0o1kBO2vKvDGG8BofQ4__xn210R2P7zjH-uEn7hic0jbBt97vLkzvATnFegxaDSjUp9At9BIGl9Ecu7RPCwSQJFdw6NBMBz02Uom8yvHpUJEfv8_jZRurBp94tzES6IAACKC6NFq-3_mQfT4o_zA51U4hBbIBw6qNXvMSqK-VtaqkTNFfJsP_8Y0nmQck0jxmgdtLfRVfZCCp3rhcLNDBX37THQI6U7lvNFETceAKyJ5NFaA8p68lw_3D2IiZER1jEU3M2QIMQGeU0pmQ6IPwGDdA0MP5IKKzj8A
+token: imooc

dev-protocol-springcloud/dev-protocol-springcloud-hystrix/NetflixHystrix.md

@@ -21,25 +21,72 @@
   - 请求依赖项失败后，可以选择出错或者是兜底回退
 
 ### 使用注解方式实现服务的容错、降级
-
+---
+- SpringCloud Netflix Hystrix 的三种模式
+  - Hystrix 的断路器模式和后备策略模式
+    - 断路器模式:设置超时或者失败等熔断策略
+    - 后备策略模式:断路器模式触发之后，如果存在后备策略，则执行后备
+    - Hystrix 的舱壁模式：Hystrix 舱壁模式的启发:货船为了进行防止漏水和火灾的扩散，会将货仓分隔为多个当发生灾害时，将所在货仓进行隔离就可以降低整艘船的风险
+      - 舱壁模式功能就是:我们可以通过为各个服务分别指定线程池
+      - 每一个远程资源调用都被放置在自己的线程池中，每一个线程池只有一定数量的线程来处理远程调用
+      - 一个性能低下的服务，只会影响到同一个线程池中的其他服务调用。所以降低了会产生的负面影响
 
 ### 使用编程方式实现服务的容错、降级
 - [NacosClientHystrixCommand.java] - [NacosClientHystrixObservableCommand.java]
 
 ### 编程方式开启 Hystrix 请求缓存
-
+- Hystrix 的结果缓存指的是在一次 Hystrix 的请求上下文中
+- Hystrix 请求缓存的两种实现方式
+  - 编程(继承 HystrixCommand)方式，重写 getCacheKey 方法即可
+  - 注解方式
+    - @CacheResult：该注解用来标记请求命令返回的结果应该被缓存，它必须与@HystrixCommand注解结合使用, 属性: cacheKeyMethod
+    - @CacheRemove: 该注解用来让请求命令的缓存失效，失效的缓存根据commandKey进行查找。属性: commandKey,cacheKeyMethod
+    - @CacheKey: 该注解用来在请求命令的参数上标记，使其作为cacheKey，如果没有使用此注解则会使用所有参数列表中的参数作为cacheKey, 属性: value
 
 ### 注解方式开启 Hystrix 请求缓存
-
-
-### 编程方式应用 Hystrix 请求合并
 -
-
+### 编程方式应用 Hystrix 请求合并
+- 默认情况下，每一个请求都会占用一个线程和一次网络请求，高并发场景下效率不高\
+- 使用 Hystrix 的请求合并，将多个请求 merge 为一个，提高服务的并发能力
+---
+- 请求合并的适用场景与注意事项
+  - 适用场景:单个对象的查询并发数很高，服务提供方负载较高，就可以考虑使用请求合并
+  - 注意事项
+    - 请求在代码中人为的设置了延迟时间，会降低请求的响应速度
+    - 可能会提高服务提供方的负载，因为返回 List 结果数据量偏大
+    - 实现请求合并比较复杂
 ### 注解方式应用 Hystrix 请求合并
 - 使用注解的方式比较多
 ### OpenFeign 集成 Hystrix 开启后备模式
-
-
+- OpenFeign 集成 Hystrix 的步骤
+  - 在配置文件中开启 Hystrix 的熔断功能:feign.hystrix.enabled: true
+  - @FeignClient 注解的 fallback 和 fallbackFactory 属性
+    -  fallback 和 fallbackFactory 都是用于配置响应回退，但是不可以同时使用
+    -  fallbackFactory 能够获取到 OpenFeign 调用抛出的异常
 ### 使用 Hystrix 监控面板监测客户端容错
-
+- Hystrix Dashboard 是一个单独的应用，用来实时的对 Hystrix 的『使用情况』进行实时的监控
 ### SpringCloud Netflix Hystrix 容错组件总结
+- ![Hystrix工作流程图.png](pic/Hystrix工作流程图.png)
+---
+- Hystrix 完整的工作流程
+  - 构造-个 HystrixCommand 或者 HystrixObservableCommand 对象
+    - 表示对一个对依赖项请求的包装
+  - 执行命令获取响应
+    - execute():阻塞，直到收到响应或者抛出异常, 同步执行的, 调用的是 queue().get()
+    - queue():返回一个 Future, 异步执行的, 调用的是 observable.toBlocking().toFuture()
+    - observe():订阅代表响应的 Observable
+    - toObservable():返回一个 Observable,当你订阅它以后，将会执行Hystrix 命令并且推送它的响应
+    - 总结: 最终每一个 HystrixCommand, 都是 Observable 的实现
+  - 响应是否已经被缓存
+    - 如果请求在缓存中的结果是存在的, 该请求在缓存中对应的结果是可用的, 缓存就会立即以一个 Observable 的形式被返回
+  - 断路器是否打开
+    - 缓存不存在的时候, 当你执行命令的时候, Hystrix 检查断路器是否打开, 如果打开, 不会执行任何命令, 执行回退逻辑, 如果是关闭, 检查容量是否可用
+  - 线程池、信号量是否已经使用率 100%
+    - 判断, 线程池和信号量是否已经满了, 如果满了, 不会执行命令, 立马执行回退逻辑
+  - HystrixObservableCommand.construct() or HystrixCommand.run()
+    - 对依赖项的调用请求, 真正的逻辑编写在这里, run 会返回一个响应, 或者抛出一个异常, construct 会返回一个 Observable 对象, 会推送一个响应或者一个 ERROR 通知, 会抛出一个 Timeout 异常
+  - 计算电路健康
+    - Hystrix 报告成功, 失败, 拒绝, 超时给断路器, 断路器会维护一组计算统计的计数器, 断路器会用这些统计数据来决定, 什么时候要跳闸, 后续的所有请求都会被短路, 直到一个恢复周期耗尽以后, 在第一次检查健康检查之后, 才会重新打开电路
+  - 回退或返回成功响应
+    - 一, 当你失败以后, HystrixCommand 会回退一个单一的回退值, HystrixObservableCommand 会返回一个或者多个回退值, 通过 fallback, 当 fallback 有异常也会被进一步抛出, 给调用者发送 ERROR 通知, 命令调用者进行处理
+    - 二, 成功会直接抛出响应给调用者, 返回一个 Observable

dev-protocol-springcloud/dev-protocol-springcloud-hystrix/src/main/java/org/example/service/AuthorityFeignClientHystrixDemo.java

@@ -1,6 +1,7 @@
 package org.example.service;
 
 import org.example.service.hystrix.bak.AuthorityFeignClientFallback;
+import org.example.service.hystrix.bak.AuthorityFeignClientFallbackFactory;
 import org.springframework.cloud.openfeign.FeignClient;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
@@ -12,8 +13,8 @@ import org.springframework.web.bind.annotation.RequestMethod;
 @FeignClient(
         // contextId 是对 FeignClient 的声明, 每一个进行的通信都要进行定义, value 表示需要进行通信的服务id是什么
         contextId = "AuthorityFeignClient", value = "e-commerce-authority-center",
-        fallback = AuthorityFeignClientFallback.class
-//        fallbackFactory = AuthorityFeignClientFallbackFactory.class
+//        fallback = AuthorityFeignClientFallback.class, // fixme fallback 和 fallbackFactory 只能使用一个
+        fallbackFactory = AuthorityFeignClientFallbackFactory.class
 )
 public interface AuthorityFeignClientHystrixDemo {
 

pom.xml

@@ -62,6 +62,7 @@
         <module>dev-protocol-springcloud/dev-protocol-springcloud-project-service-sdk</module>
         <module>dev-protocol-springcloud/dev-protocol-springcloud-project-goods-service</module>
         <module>dev-protocol-springcloud/dev-protocol-springcloud-hystrix</module>
+        <module>dev-protocol-springcloud/dev-protocol-springcloud-hystrix-dashboard</module>
     </modules>
 
     <properties>