From d36384ca9501e863d8b8f0477c14f67de7a92525 Mon Sep 17 00:00:00 2001 From: Wenchao Gong Date: Mon, 13 Sep 2021 16:38:37 +0800 Subject: [PATCH] =?UTF-8?q?=E7=BD=91=E5=85=B3=E6=97=A5=E5=BF=97=E4=BF=A1?= =?UTF-8?q?=E6=81=AF=E8=AE=B0=E5=BD=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../config/provider/RedisRouteDefinitionRepository.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/ruoyi-extend/ruoyi-isc-gateway/src/main/java/com/ruoyi/gateway/config/provider/RedisRouteDefinitionRepository.java b/ruoyi-extend/ruoyi-isc-gateway/src/main/java/com/ruoyi/gateway/config/provider/RedisRouteDefinitionRepository.java index e1f1a0726..b7b713b8c 100644 --- a/ruoyi-extend/ruoyi-isc-gateway/src/main/java/com/ruoyi/gateway/config/provider/RedisRouteDefinitionRepository.java +++ b/ruoyi-extend/ruoyi-isc-gateway/src/main/java/com/ruoyi/gateway/config/provider/RedisRouteDefinitionRepository.java @@ -1,5 +1,6 @@ package com.ruoyi.gateway.config.provider; +import lombok.extern.slf4j.Slf4j; import org.redisson.api.RMap; import org.redisson.api.RedissonClient; import org.springframework.cloud.gateway.route.RouteDefinition; @@ -13,6 +14,7 @@ import reactor.core.publisher.Mono; * @author Wenchao Gong * @date 2021-09-11 */ +@Slf4j public class RedisRouteDefinitionRepository implements RouteDefinitionRepository { public static final String KEY_ROUTES = "ROUTES::"; @@ -27,6 +29,7 @@ public class RedisRouteDefinitionRepository implements RouteDefinitionRepository public Flux getRouteDefinitions() { RMap map = redissonClient.getMap(KEY_ROUTES); + log.debug("Routes from redis size:[{}]!", map.size()); return Flux.fromIterable(map.values()); } @@ -36,6 +39,7 @@ public class RedisRouteDefinitionRepository implements RouteDefinitionRepository return route.flatMap(definition -> { RMap map = redissonClient.getMap(KEY_ROUTES); map.put(definition.getId(), definition); + log.debug("Saving route to redis id:[{}]!", definition.getId()); return Mono.empty(); }); } @@ -46,6 +50,7 @@ public class RedisRouteDefinitionRepository implements RouteDefinitionRepository return routeId.flatMap(id -> { RMap map = redissonClient.getMap(KEY_ROUTES); map.remove(id); + log.debug("Remove route from redis id:[{}]!", id); return Mono.empty(); }); }