zianxin/pigx
1
0 Fork 0
mirror of http://git.pig4cloud.com/pig/pigx.git synced 2026-11-08 12:39:05 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor(sensitive): 增加 common-sensitive

Browse Source
This commit is contained in:
冷冷 committed 2024-08-22 15:10:28 +08:00
1 parent 0e8858a338
commit d72fade7b0
1 file changed
+10 -7
Download Patch File Download Diff File Expand all files Collapse all files
pigx-common/pigx-common-sensitive/src/main/java/com/pig4cloud/pigx/common/sensitive/SensitiveAutoConfiguration.java
+10 -7
View File
@@ -24,6 +24,7 @@ import org.springframework.security.core.GrantedAuthority;
import org.springframework.security.core.context.SecurityContextHolder;
import java.util.Objects;
import java.util.Optional;
/**
* 脱敏配置类
@@ -38,7 +39,7 @@ import java.util.Objects;
@EnableConfigurationProperties(SensitiveWordsProperties.class)
public class SensitiveAutoConfiguration implements InitializingBean {
private final RedisMessageListenerContainer redisMessageListenerContainer;
private final Optional<RedisMessageListenerContainer> redisMessageListenerContainerOptional;
/**
* 注入默认的脱敏权限判断
@@ -113,11 +114,13 @@ public class SensitiveAutoConfiguration implements InitializingBean {
@Override
public void afterPropertiesSet() throws Exception {
redisMessageListenerContainer.addMessageListener((message, bytes) -> {
log.info("开始重新加载敏感词库");
SpringContextHolder.getBean(SensitiveWordBs.class).init();
log.info("敏感词库加载完成");
},
new ChannelTopic(CacheConstants.SENSITIVE_REDIS_RELOAD_TOPIC));
redisMessageListenerContainerOptional.ifPresent(redisMessageListenerContainer -> {
redisMessageListenerContainer.addMessageListener((message, bytes) -> {
log.info("开始重新加载敏感词库");
SpringContextHolder.getBean(SensitiveWordBs.class).init();
log.info("敏感词库加载完成");
},
new ChannelTopic(CacheConstants.SENSITIVE_REDIS_RELOAD_TOPIC));
});
}
}