Resilience4J 断路器

README.md

@@ -31,7 +31,8 @@ spring5 -> webflux ->spring gateway
 13. RewriteResponseHeader
 14. SaveSession 
 15. RequestSize 为后端服务设置收到的最大请求包大小
-16. ...
+16. CircuitBreaker
+17. ...
 
 
 

pom.xml

@@ -57,10 +57,16 @@
 		</dependency>
 	
 		<!-- hystrix -->
-		<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</artifactId> -->
+<!-- 		</dependency> -->
+		
+		<!-- 最新推荐的断路器 -->
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-circuitbreaker-reactor-resilience4j</artifactId>
+        </dependency>
         
 		<!-- Spring Boot Web Flux 依赖 -->
 		<dependency>

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

@@ -0,0 +1,50 @@
+package com.yaozhitech.spring5.config;
+
+import java.time.Duration;
+
+import org.springframework.beans.factory.ObjectProvider;
+import org.springframework.cloud.circuitbreaker.resilience4j.ReactiveResilience4JCircuitBreakerFactory;
+import org.springframework.cloud.circuitbreaker.resilience4j.Resilience4JConfigBuilder;
+import org.springframework.cloud.client.circuitbreaker.Customizer;
+import org.springframework.cloud.client.circuitbreaker.ReactiveCircuitBreakerFactory;
+import org.springframework.cloud.gateway.filter.factory.SpringCloudCircuitBreakerFilterFactory;
+import org.springframework.cloud.gateway.filter.factory.SpringCloudCircuitBreakerResilience4JFilterFactory;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.web.reactive.DispatcherHandler;
+
+import io.github.resilience4j.circuitbreaker.CircuitBreakerConfig;
+import io.github.resilience4j.timelimiter.TimeLimiterConfig;
+
+@Configuration
+public class Resilience4JConfiguration {
+
+	public Customizer<ReactiveResilience4JCircuitBreakerFactory> defaultCustomizer() {
+	    return factory -> factory.configureDefault(id -> new Resilience4JConfigBuilder(id)
+                .circuitBreakerConfig(CircuitBreakerConfig.custom().slowCallDurationThreshold(Duration.ofSeconds(4L)).build())
+	            .timeLimiterConfig(TimeLimiterConfig.custom().timeoutDuration(Duration.ofSeconds(2)).build()).build());
+	}
+
+	public Customizer<ReactiveResilience4JCircuitBreakerFactory> slowCustomizer() {
+	    return factory -> {
+	        factory.configure(builder -> builder
+	                .timeLimiterConfig(TimeLimiterConfig.custom().timeoutDuration(Duration.ofSeconds(4)).build())
+	                .circuitBreakerConfig(CircuitBreakerConfig.ofDefaults()), "slow");
+	    };
+	}
+	
+	@Bean
+    public SpringCloudCircuitBreakerFilterFactory resilience4JCircuitBreakerFactory(
+            ReactiveCircuitBreakerFactory reactiveCircuitBreakerFactory,
+            ObjectProvider<DispatcherHandler> dispatcherHandlers) {
+		
+		// 参考自 ReactiveResilience4JCustomizerConfiguration
+		defaultCustomizer().customize((ReactiveResilience4JCircuitBreakerFactory) reactiveCircuitBreakerFactory);
+		slowCustomizer().customize((ReactiveResilience4JCircuitBreakerFactory) reactiveCircuitBreakerFactory);
+		
+//		reactiveCircuitBreakerFactory.configureDefault(id -> new Resilience4JConfigBuilder((String) id)
+//				.timeLimiterConfig(TimeLimiterConfig.custom().timeoutDuration(Duration.ofSeconds(12)).build()).build());
+        return new SpringCloudCircuitBreakerResilience4JFilterFactory(reactiveCircuitBreakerFactory, 
+        		dispatcherHandlers);
+    }
+}

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

@@ -11,7 +11,7 @@ import reactor.core.publisher.Mono;
 
 @Configuration
 public class RouterConfig {
-
+	
 	@Bean
 	public RouteLocator customRouteLocator(RouteLocatorBuilder builder) {
 		//@formatter:off
@@ -25,18 +25,19 @@ 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"))
-//				.route("hystrix_fallback_route", r -> r.host("*.hystrixfallback.org")
-//						.filters(f -> f.hystrix(c -> c.setName("slowcmd").setFallbackUri("forward:/hystrixfallback")))
-//								.uri("http://httpbin.org"))
+//				.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("circuitbreaker_route", r -> r.path("/slow1_query.do")
+			            .filters(f -> f
+			            		.rewritePath("_query.do", "")
+			            		.circuitBreaker(c -> c.setName("slow").setFallbackUri("forward:/hystrixfallback"))
+			                )
+			            .uri("http://127.0.0.1:8080"))
+
 //				.route("websocket_route", r -> r.path("/echo")
 //					.uri("ws://localhost:9000"))
 				.build();
@@ -62,4 +63,5 @@ public class RouterConfig {
 	KeyResolver ipKeyResolver() {
 	    return exchange -> Mono.just(exchange.getRequest().getRemoteAddress().getHostString());
 	}
+	
 }

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

@@ -26,4 +26,16 @@ public class HystrixfallbackController {
 		}
 		return Mono.create(monoSink -> monoSink.success("slow"));
 	}
+	
+	@GetMapping(value = "/slow1")
+	public Mono<String> slow1() {
+		log.info("slow1 ing");
+		try {
+			Thread.sleep(4700);
+		} catch (InterruptedException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+		return Mono.create(monoSink -> monoSink.success("slow1"));
+	}
 }

src/main/resources/application.properties

@@ -10,4 +10,5 @@ spring.redis.timeout=5000
 #日志
 logging.level.org.springframework.cloud=debug
 #hystrix
-hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds: 4000
+hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds: 4000
+# hystrix.command.apiTimeOut.execution.isolation.thread.timeoutInMilliseconds: 2000