opensource/RuoYi-Vue-Plus
2
0
Fork 1
mirror of https://gitee.com/dromara/RuoYi-Vue-Plus.git synced 2026-09-20 02:08:15 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

网关日志信息记录

Browse Source
This commit is contained in:
Wenchao Gong 2021-09-13 16:38:37 +08:00
parent 71a58178eb
commit d36384ca95
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
ruoyi-extend/ruoyi-isc-gateway/src/main/java/com/ruoyi/gateway/config/provider/RedisRouteDefinitionRepository.java
View File

@ -1,5 +1,6 @@
package com.ruoyi.gateway.config.provider; package com.ruoyi.gateway.config.provider;
import lombok.extern.slf4j.Slf4j;
import org.redisson.api.RMap; import org.redisson.api.RMap;
import org.redisson.api.RedissonClient; import org.redisson.api.RedissonClient;
import org.springframework.cloud.gateway.route.RouteDefinition; import org.springframework.cloud.gateway.route.RouteDefinition;
@ -13,6 +14,7 @@ import reactor.core.publisher.Mono;
* @author Wenchao Gong * @author Wenchao Gong
* @date 2021-09-11 * @date 2021-09-11
*/ */
@Slf4j
public class RedisRouteDefinitionRepository implements RouteDefinitionRepository public class RedisRouteDefinitionRepository implements RouteDefinitionRepository
{ {
public static final String KEY_ROUTES = "ROUTES::"; public static final String KEY_ROUTES = "ROUTES::";
@ -27,6 +29,7 @@ public class RedisRouteDefinitionRepository implements RouteDefinitionRepository
public Flux<RouteDefinition> getRouteDefinitions() public Flux<RouteDefinition> getRouteDefinitions()
{ {
RMap<String, RouteDefinition> map = redissonClient.getMap(KEY_ROUTES); RMap<String, RouteDefinition> map = redissonClient.getMap(KEY_ROUTES);
log.debug("Routes from redis size:[{}]!", map.size());
return Flux.fromIterable(map.values()); return Flux.fromIterable(map.values());
} }
@ -36,6 +39,7 @@ public class RedisRouteDefinitionRepository implements RouteDefinitionRepository
return route.flatMap(definition -> { return route.flatMap(definition -> {
RMap<String, RouteDefinition> map = redissonClient.getMap(KEY_ROUTES); RMap<String, RouteDefinition> map = redissonClient.getMap(KEY_ROUTES);
map.put(definition.getId(), definition); map.put(definition.getId(), definition);
log.debug("Saving route to redis id:[{}]!", definition.getId());
return Mono.empty(); return Mono.empty();
}); });
} }
@ -46,6 +50,7 @@ public class RedisRouteDefinitionRepository implements RouteDefinitionRepository
return routeId.flatMap(id -> { return routeId.flatMap(id -> {
RMap<String, RouteDefinition> map = redissonClient.getMap(KEY_ROUTES); RMap<String, RouteDefinition> map = redissonClient.getMap(KEY_ROUTES);
map.remove(id); map.remove(id);
log.debug("Remove route from redis id:[{}]!", id);
return Mono.empty(); return Mono.empty();
}); });
} }