hystrix 熔断

README.md

@@ -5,12 +5,37 @@ spring5_demo
 
 spring5 -> webflux ->spring gateway
 
-# 版本
+## 版本
 * 2.2.* -> Hoxton
 * 2.1.* -> Greenwich
 * 2.0.* -> Finchley
 
-# 路由配置参考
+## 路由配置参考
 1. https://www.jianshu.com/p/86660b8b24c4
 2. https://www.jdon.com/51642
 3. 
+
+## gateway filter
+1. AddRequestHeader 添加header给下流接口
+2. AddRequestParameter 
+3. AddResponseHeader 
+4. DedupeResponseHeader 剔除重复的响应头
+5. Hystrix 未来，Hystrix会被Spring Cloud移除掉，取而代之的是Alibaba Sentinel/Resilience4J
+6. PrefixPath 为匹配的路由添加前缀
+7. PreserveHostHeader
+8. RequestRateLimiter
+9. RedirectTo
+10. RemoveRequestHeader
+11. RemoveResponseHeader
+12. RewritePath
+13. RewriteResponseHeader
+14. SaveSession 
+15. RequestSize 为后端服务设置收到的最大请求包大小
+16. ...
+
+
+
+
+
+
+

pom.xml

@@ -50,10 +50,17 @@
             <artifactId>spring-cloud-starter</artifactId>
        </dependency>
        
-       <dependency>
-            <groupId>org.springframework.cloud</groupId>
-            <artifactId>spring-cloud-starter-gateway</artifactId>
-        </dependency>
+       <!-- 网关 -->
+		<dependency>
+			<groupId>org.springframework.cloud</groupId>
+			<artifactId>spring-cloud-starter-gateway</artifactId>
+		</dependency>
+	
+		<!-- hystrix -->
+		<dependency>
+			<groupId>org.springframework.cloud</groupId>
+			<artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
+		</dependency>
         
 		<!-- Spring Boot Web Flux 依赖 -->
 		<dependency>

src/main/java/com/yaozhitech/spring5/config/RouterConfig.java

@@ -25,6 +25,12 @@ public class RouterConfig {
 						.filters(f -> f.rewritePath("city_list",  // rewritePath方法会使用内建的过滤器重写路径
 								"city_list.do"))
 						.uri("https://api.bbztx.com"))
+				.route("hystrix_fallback_route", r -> r.path("/slow_query.do")
+						.filters(f -> f
+										.rewritePath("_query.do", "")
+										.hystrix(c -> c.setName("slowcmd").setFallbackUri("forward:/hystrixfallback"))
+							    )
+						.uri("http://127.0.0.1:8080"))
 //				.route("hystrix_route", r -> r.host("*.hystrix.org")
 //						.filters(f -> f.hystrix(c -> c.setName("slowcmd")))
 //								.uri("http://httpbin.org"))

src/main/java/com/yaozhitech/spring5/controller/HystrixfallbackController.java

@@ -0,0 +1,29 @@
+package com.yaozhitech.spring5.controller;
+
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import lombok.extern.slf4j.Slf4j;
+import reactor.core.publisher.Mono;
+
+@RestController
+@Slf4j
+public class HystrixfallbackController {
+
+	@GetMapping(value = "/hystrixfallback")
+	public Mono<String> hystrixfallback() {
+		return Mono.create(monoSink -> monoSink.success("hystrixfallback"));
+	}
+	
+	@GetMapping(value = "/slow")
+	public Mono<String> slow() {
+		log.info("slow ing");
+		try {
+			Thread.sleep(4700);
+		} catch (InterruptedException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+		return Mono.create(monoSink -> monoSink.success("slow"));
+	}
+}

src/main/resources/application.properties

@@ -8,4 +8,6 @@ spring.redis.password=bbztx123456
 # 连接超时时间（毫秒）
 spring.redis.timeout=5000
 #日志
-logging.level.org.springframework.cloud=debug
+logging.level.org.springframework.cloud=debug
+#hystrix
+hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds: 4000