mirrors/youlai-mall
1
0
Fork 0
mirror of https://gitee.com/youlaitech/youlai-mall.git synced 2024-12-23 05:00:25 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

feat(RedisGatewayConfig.java): 用户本地缓存设计

Browse Source 
1、添加用户缓存到本地
2、添加用户修改之后清除本地缓存
3、发布Redis消息到其他集群节点，清除本地缓存
4、添加环境变量开关（使用之前的demo）

Closes I3W2A款
This commit is contained in:
DaniR 2021-07-05 20:57:29 +08:00
parent 2b72ab3b51
commit fd72b5de64
1 changed files with 11 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
youlai-gateway/src/main/java/com/youlai/gateway/security/ResourceServerManager.java
View File

@ -8,6 +8,7 @@ import com.youlai.common.constant.GlobalConstants;
import com.youlai.gateway.component.AdminRoleLocalCache;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.http.HttpMethod;
import org.springframework.http.server.reactive.ServerHttpRequest;
@ -39,6 +40,10 @@ public class ResourceServerManager implements ReactiveAuthorizationManager<Autho
private RedisTemplate redisTemplate;
private AdminRoleLocalCache adminRoleLocalCache;
// 是否演示环境
@Value("${demo}")
private Boolean isDemoEnv;
@Override
public Mono<AuthorizationDecision> check(Mono<Authentication> mono, AuthorizationContext authorizationContext) {
ServerHttpRequest request = authorizationContext.getExchange().getRequest();
@ -64,12 +69,13 @@ public class ResourceServerManager implements ReactiveAuthorizationManager<Autho
// Restful接口权限设计 @link https://www.cnblogs.com/haoxianrui/p/14396990.html
String restfulPath = request.getMethodValue() + ":" + path;
log.info("请求方法:RESTFul请求路径：{}", restfulPath);
// 缓存取【URL权限标识->角色集合】权限规则
Map<String, Object> permRolesRules = (Map<String, Object>) adminRoleLocalCache.getCache(GlobalConstants.URL_PERM_ROLES_KEY);
if(null==permRolesRules){
permRolesRules = redisTemplate.opsForHash().entries(GlobalConstants.URL_PERM_ROLES_KEY);
adminRoleLocalCache.setLocalCache(GlobalConstants.URL_PERM_ROLES_KEY,permRolesRules);
if (isDemoEnv){
// 缓存取【URL权限标识->角色集合】权限规则
if(null==permRolesRules){
permRolesRules = redisTemplate.opsForHash().entries(GlobalConstants.URL_PERM_ROLES_KEY);
adminRoleLocalCache.setLocalCache(GlobalConstants.URL_PERM_ROLES_KEY,permRolesRules);
}
}
// 根据 “请求路径” 和 权限规则中的“URL权限标识”进行Ant匹配，得出拥有权限的角色集合