网关

gateway/pom.xml

@@ -22,14 +22,18 @@
             <groupId>org.springframework.cloud</groupId>
             <artifactId>spring-cloud-starter-circuitbreaker-resilience4j</artifactId>
         </dependency>
-        <dependency>
+        <!--<dependency>
             <groupId>org.springframework.cloud</groupId>
             <artifactId>spring-cloud-starter-config</artifactId>
-        </dependency>
+        </dependency>-->
         <dependency>
             <groupId>org.springframework.cloud</groupId>
             <artifactId>spring-cloud-starter-gateway</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
+        </dependency>
 
         <dependency>
             <groupId>org.springframework.boot</groupId>

gateway/src/main/java/com/xhkjedu/gateway/config/CustomizeCircuitBreakerConfig.java

@@ -0,0 +1,49 @@
+package com.xhkjedu.gateway.config;
+
+import io.github.resilience4j.circuitbreaker.CircuitBreakerConfig;
+import io.github.resilience4j.timelimiter.TimeLimiterConfig;
+import org.springframework.cloud.circuitbreaker.resilience4j.ReactiveResilience4JCircuitBreakerFactory;
+import org.springframework.cloud.circuitbreaker.resilience4j.Resilience4JConfigBuilder;
+import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import java.time.Duration;
+
+/**
+ * @ClassName CustomizeCircuitBreakerConfig
+ * Description TODO
+ * Author WN
+ * Date 2022/2/16 10:59
+ **/
+@Configuration
+@EnableEurekaClient
+public class CustomizeCircuitBreakerConfig {
+
+    @Bean
+    public ReactiveResilience4JCircuitBreakerFactory defaultCustomizer(){
+
+        CircuitBreakerConfig circuitBreakerConfig = CircuitBreakerConfig.custom() //
+                .slidingWindowType(CircuitBreakerConfig.SlidingWindowType.TIME_BASED) // 滑动窗口的类型为时间窗口
+                .slidingWindowSize(3) // 时间窗口的大小为2秒
+                .minimumNumberOfCalls(2) // 在单位时间窗口内最少需要1次调用才能开始进行统计计算
+                .failureRateThreshold(50) // 在单位时间窗口内调用失败率达到50%后会启动断路器
+                .enableAutomaticTransitionFromOpenToHalfOpen() // 允许断路器自动由打开状态转换为半开状态
+                .permittedNumberOfCallsInHalfOpenState(5) // 在半开状态下允许进行正常调用的次数
+                .waitDurationInOpenState(Duration.ofSeconds(5)) // 断路器打开状态转换为半开状态需要等待60秒
+                .recordExceptions(Throwable.class) // 所有异常都当作失败来处理
+                .build();
+
+
+        ReactiveResilience4JCircuitBreakerFactory factory = new ReactiveResilience4JCircuitBreakerFactory();
+        factory.configureDefault(id -> new Resilience4JConfigBuilder(id)
+                //超时规则,设置为3s
+                .timeLimiterConfig(TimeLimiterConfig.custom().timeoutDuration(Duration.ofMillis(3000)).build())
+                //设置断路器配置
+                .circuitBreakerConfig(circuitBreakerConfig).build());
+
+        return factory;
+    }
+
+
+}

gateway/src/main/java/com/xhkjedu/gateway/controller/ErrorController.java

@@ -0,0 +1,26 @@
+package com.xhkjedu.gateway.controller;
+
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @ClassName ErrorController
+ * Description TODO
+ * Author WN
+ * Date 2022/2/14 14:22
+ **/
+@RestController
+public class ErrorController {
+
+    @RequestMapping("/fallback")
+    public Object fallback(){
+        Map<String,Object> result = new HashMap<>();
+        result.put("code",1);
+        result.put("msg","服务器繁忙了！");
+        result.put("state",false);
+        return result;
+    }
+}

gateway/src/main/resources/application.properties

@@ -1,3 +1,13 @@
 server.port=8080
 
 spring.application.name=gateway
+
+spring.cloud.gateway.routes[0].id=path_sstudy
+spring.cloud.gateway.routes[0].uri=lb://sstudy
+spring.cloud.gateway.routes[0].predicates[0]=Path=/sstudy/**
+spring.cloud.gateway.routes[0].filters[0]=RewritePath=/sstudy/paper/(?<segment>.*), /sstudy/$\{segment}
+spring.cloud.gateway.routes[0].filters[1].name=CircuitBreaker
+spring.cloud.gateway.routes[0].filters[1].args.name=myCircuitBreaker
+spring.cloud.gateway.routes[0].filters[1].args.fallbackUri=forward:/fallback
+
+eureka.client.service-url.defaultZone=http://localhost:8081/eureka/