From d72fade7b071fd7130ff6c3378177e9e33afa5d3 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=86=B7=E5=86=B7?= <2270033969@qq.com> Date: Thu, 22 Aug 2024 14:01:05 +0800 Subject: [PATCH] =?UTF-8?q?refactor(sensitive):=20=E5=A2=9E=E5=8A=A0=20com?= =?UTF-8?q?mon-sensitive?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../sensitive/SensitiveAutoConfiguration.java | 17 ++++++++++------- 1 file changed, 10 insertions(+), 7 deletions(-) diff --git a/pigx-common/pigx-common-sensitive/src/main/java/com/pig4cloud/pigx/common/sensitive/SensitiveAutoConfiguration.java b/pigx-common/pigx-common-sensitive/src/main/java/com/pig4cloud/pigx/common/sensitive/SensitiveAutoConfiguration.java index dc94d3a36..ff82785cd 100644 --- a/pigx-common/pigx-common-sensitive/src/main/java/com/pig4cloud/pigx/common/sensitive/SensitiveAutoConfiguration.java +++ b/pigx-common/pigx-common-sensitive/src/main/java/com/pig4cloud/pigx/common/sensitive/SensitiveAutoConfiguration.java @@ -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 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)); + }); } }