从redis自动加载路由

pom.xml

@@ -15,7 +15,7 @@
 	<parent>
         <groupId>org.springframework.boot</groupId>
         <artifactId>spring-boot-starter-parent</artifactId>
-        <version>2.2.1.RELEASE</version>
+        <version>2.1.4.RELEASE</version>
         <relativePath />
     </parent>
 
@@ -23,7 +23,7 @@
 		<maven.compiler.source>1.8</maven.compiler.source>
 		<maven.compiler.target>1.8</maven.compiler.target>
 		<maven-jar-plugin.version>3.1.1</maven-jar-plugin.version>
-		<spring-cloud.version>2.2.0.RELEASE</spring-cloud.version>
+		<spring-cloud.version>2.1.4.RELEASE</spring-cloud.version>
 	</properties>
 	
 	<dependencyManagement>
@@ -31,7 +31,7 @@
             <dependency>
                 <groupId>org.springframework.cloud</groupId>
                 <artifactId>spring-cloud-dependencies</artifactId>
-                <version>Hoxton.RELEASE</version>
+                <version>Greenwich.RELEASE</version>
                 <type>pom</type>
                 <scope>import</scope>
             </dependency>
@@ -57,16 +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>
+<!--         <dependency> -->
+<!--             <groupId>org.springframework.cloud</groupId> -->
+<!--             <artifactId>spring-cloud-starter-circuitbreaker-reactor-resilience4j</artifactId> -->
+<!--         </dependency> -->
         
 		<!-- Spring Boot Web Flux 依赖 -->
 		<dependency>
@@ -80,6 +80,18 @@
 			<artifactId>spring-boot-starter-data-redis-reactive</artifactId>
 		</dependency>
 		
+		<dependency>
+            <groupId>com.alicp.jetcache</groupId>
+            <artifactId>jetcache-starter-redis</artifactId>
+            <version>2.6.0.M3</version>
+        </dependency>
+
+		<dependency>
+			<groupId>com.alicp.jetcache</groupId>
+			<artifactId>jetcache-redis-lettuce</artifactId>
+			<version>2.6.0.M3</version>
+		</dependency>
+			
 		<!-- Spring test 依赖 -->
         <dependency>
             <groupId>org.springframework.boot</groupId>

src/main/java/com/yaozhitech/spring5/App.java

@@ -4,9 +4,13 @@ import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.boot.context.properties.EnableConfigurationProperties;
 
+import com.alicp.jetcache.anno.config.EnableCreateCacheAnnotation;
+import com.alicp.jetcache.anno.config.EnableMethodCache;
 import com.yaozhitech.spring5.config.UriConfiguration;
 
 
+@EnableMethodCache(basePackages = "com.yaozhitech.spring5")
+@EnableCreateCacheAnnotation
 @EnableConfigurationProperties(UriConfiguration.class)
 @SpringBootApplication
 public class App {

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

@@ -2,7 +2,6 @@ package com.yaozhitech.spring5.config;
 
 
 import org.springframework.cache.annotation.CachingConfigurerSupport;
-import org.springframework.cache.annotation.EnableCaching;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.data.redis.connection.ReactiveRedisConnectionFactory;
@@ -20,8 +19,8 @@ import org.springframework.data.redis.serializer.StringRedisSerializer;
  * @author yinzy
  */
 @Configuration
-@EnableCaching
 public class RedisConfig extends CachingConfigurerSupport {
+	
 	public static String cachePrefix = "bbc:";
 	
     @Bean

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

@@ -0,0 +1,41 @@
+package com.yaozhitech.spring5.config;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.cloud.gateway.route.RouteDefinition;
+import org.springframework.cloud.gateway.route.RouteDefinitionRepository;
+import org.springframework.stereotype.Component;
+
+import com.yaozhitech.spring5.service.RouteService;
+
+import lombok.extern.slf4j.Slf4j;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+@Component
+@Slf4j
+public class RedisRouteDefinitionRepository implements RouteDefinitionRepository {
+
+    @Autowired
+    private RouteService routeService;
+
+    @Override
+    public Flux<RouteDefinition> getRouteDefinitions() {
+        return Flux.fromIterable(routeService.getRouteDefinitions());
+    }
+
+    @Override
+    public Mono<Void> save(Mono<RouteDefinition> route) {
+        return route.flatMap(routeDefinition -> {
+            routeService.save(routeDefinition);
+            return Mono.empty();
+        });
+    }
+
+    @Override
+    public Mono<Void> delete(Mono<String> routeId) {
+        return routeId.flatMap(id -> {
+            routeService.delete(id);
+            return Mono.empty();
+        });
+    }
+}

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

@@ -1,50 +1,37 @@
 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);
-    }
+//	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

@@ -28,18 +28,18 @@ public class RouterConfig {
 						.filters(f -> f.rewritePath("city_list",  // rewritePath方法会使用内建的过滤器重写路径
 								"city_list.do"))
 						.uri(httpUri))
-//				.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("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"))

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

@@ -23,7 +23,7 @@ public class CityWebFluxController {
 
 	@Autowired
 	private RedisTemplate<String, Object> redisTemplate;
-
+	
 	@GetMapping(value = "/{id}")
 	public Mono<City> findCityById(@PathVariable("id") Long id) {
 		String key = "city_" + id;

src/main/java/com/yaozhitech/spring5/service/RouteService.java

@@ -0,0 +1,81 @@
+package com.yaozhitech.spring5.service;
+
+import java.net.URI;
+import java.net.URISyntaxException;
+import java.util.Collection;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Set;
+import java.util.stream.Collectors;
+
+import javax.annotation.PostConstruct;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.cloud.gateway.route.RouteDefinition;
+import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.stereotype.Service;
+import org.springframework.util.CollectionUtils;
+
+import com.alicp.jetcache.Cache;
+import com.alicp.jetcache.anno.CacheType;
+import com.alicp.jetcache.anno.CreateCache;
+
+import lombok.extern.slf4j.Slf4j;
+
+@Service
+@Slf4j
+public class RouteService {
+
+    private static final String GATEWAY_ROUTES = "gateway_routes::";
+
+    @Autowired
+    private StringRedisTemplate stringRedisTemplate;
+
+    @CreateCache(name = GATEWAY_ROUTES, cacheType = CacheType.REMOTE)
+    private Cache<String, RouteDefinition> gatewayRouteCache;
+
+    private Map<String, RouteDefinition> routeDefinitionMaps = new HashMap<>();
+
+    @PostConstruct
+    private void loadRouteDefinition() {
+        log.info("loadRouteDefinition, 开始初使化路由");
+        Set<String> gatewayKeys = stringRedisTemplate.keys(GATEWAY_ROUTES + "*");
+        if (CollectionUtils.isEmpty(gatewayKeys)) {
+            return;
+        }
+        log.info("预计初使化路由, gatewayKeys：{}", gatewayKeys);
+        // 去掉key的前缀
+        Set<String> gatewayKeyIds = gatewayKeys.stream().map(key -> {
+            return key.replace(GATEWAY_ROUTES, "");
+        }).collect(Collectors.toSet());
+        
+        Map<String, RouteDefinition> allRoutes = gatewayRouteCache.getAll(gatewayKeyIds);
+        log.info("gatewayKeys：{}", allRoutes);
+        // 以下代码原因是，jetcache将RouteDefinition返序列化后，uri发生变化，未初使化，导致路由异常，以下代码是重新初使化uri
+        allRoutes.values().forEach(routeDefinition -> {
+            try {
+                routeDefinition.setUri(new URI(routeDefinition.getUri().toASCIIString()));
+            } catch (URISyntaxException e) {
+                log.error("网关加载RouteDefinition异常：", e);
+            }
+        });
+        routeDefinitionMaps.putAll(allRoutes);
+        log.info("共初使化路由信息：{}", routeDefinitionMaps.size());
+    }
+
+    public Collection<RouteDefinition> getRouteDefinitions() {
+        return routeDefinitionMaps.values();
+    }
+
+    public boolean save(RouteDefinition routeDefinition) {
+        routeDefinitionMaps.put(routeDefinition.getId(), routeDefinition);
+        log.info("新增路由1条：{},目前路由共{}条", routeDefinition, routeDefinitionMaps.size());
+        return true;
+    }
+
+    public boolean delete(String routeId) {
+        routeDefinitionMaps.remove(routeId);
+        log.info("删除路由1条：{},目前路由共{}条", routeId, routeDefinitionMaps.size());
+        return true;
+    }
+}

src/main/resources/application.properties

@@ -2,7 +2,7 @@
 ## Redis服务器地址
 spring.redis.host=120.55.124.69
 ## Redis服务器连接端口
-spring.redis.port=6279
+spring.redis.port=6280
 ## Redis服务器连接密码（默认为空）
 spring.redis.password=bbztx123456
 # 连接超时时间（毫秒）
@@ -17,4 +17,18 @@ spring.cloud.gateway.metrics.enabled=true
 # 开启指定端点
 management.endpoints.web.exposure.include=gateway,metrics
 
-        
+# 缓存
+jetcache.statIntervalMinutes: 15
+jetcache.areaInCacheName: false
+jetcache.hidePackages: com.yaozhitech.spring5
+#jetcache.local.default.type: caffeine
+#jetcache.local.default.keyConvertor: fastjson
+jetcache.remote.default.type: redis.lettuce
+jetcache.remote.default.keyConvertor: fastjson
+jetcache.remote.default.valueEncoder: kryo
+jetcache.remote.default.valueDecoder: kryo
+jetcache.remote.default.poolConfig.minIdle: 5
+jetcache.remote.default.poolConfig.maxIdle: 20
+jetcache.remote.default.poolConfig.maxTotal: 50
+jetcache.remote.default.uri: redis://bbztx123456@120.55.124.69:6280
+