SpringCloud/spring-cloud-gateway
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Adds various improvements to RedisRouteDefinitionRepository.

Browse Source
This commit is contained in:
DanielWei
2020-02-13 18:20:47 +08:00
committed by spencergibb
parent 21960d2c7b
commit ea6464af8a
1 changed files with 10 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
spring-cloud-gateway-server/src/main/java/org/springframework/cloud/gateway/route/RedisRouteDefinitionRepository.java
View File

@@ -16,6 +16,8 @@
package org.springframework.cloud.gateway.route; package org.springframework.cloud.gateway.route;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import reactor.core.publisher.Flux; import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono; import reactor.core.publisher.Mono;
@@ -30,6 +32,8 @@ import org.springframework.stereotype.Repository;
@Repository @Repository
public class RedisRouteDefinitionRepository implements RouteDefinitionRepository { public class RedisRouteDefinitionRepository implements RouteDefinitionRepository {
private static final Logger log = LoggerFactory.getLogger(RedisRouteDefinitionRepository.class);
/** /**
* Key prefix for RouteDefinition queries to redis. * Key prefix for RouteDefinition queries to redis.
*/ */
@@ -48,7 +52,12 @@ public class RedisRouteDefinitionRepository implements RouteDefinitionRepository
@Override @Override
public Flux<RouteDefinition> getRouteDefinitions() { public Flux<RouteDefinition> getRouteDefinitions() {
return reactiveRedisTemplate.keys(createKey("*")) return reactiveRedisTemplate.keys(createKey("*"))
.flatMap(key -> reactiveRedisTemplate.opsForValue().get(key)); .flatMap(key -> reactiveRedisTemplate.opsForValue().get(key))
.onErrorContinue((throwable, routeDefinition) -> {
if (log.isErrorEnabled()) {
log.error("get routes from redis error cause : {}", throwable.toString(), throwable);
}
});
} }
@Override @Override