diff --git a/starters/cache-spring-boot-starter/src/main/java/com/schbrain/framework/autoconfigure/cache/provider/CacheProviderDelegate.java b/starters/cache-spring-boot-starter/src/main/java/com/schbrain/framework/autoconfigure/cache/provider/CacheProviderDelegate.java index 64c25adc2355d78a12f4b4b05634ec15d07444b8..79b7bf8ae739f0b4a0b324cc682a3821441c1264 100644 --- a/starters/cache-spring-boot-starter/src/main/java/com/schbrain/framework/autoconfigure/cache/provider/CacheProviderDelegate.java +++ b/starters/cache-spring-boot-starter/src/main/java/com/schbrain/framework/autoconfigure/cache/provider/CacheProviderDelegate.java @@ -13,6 +13,7 @@ import org.springframework.core.env.Environment; import java.time.Duration; import java.util.*; import java.util.Map.Entry; +import java.util.stream.Collectors; /** * @author liaozan @@ -64,7 +65,13 @@ public class CacheProviderDelegate implements CacheProvider { @Override public Set keys(String pattern) { - return getCacheProvider().keys(withKeyPrefix(pattern)); + Set keys = getCacheProvider().keys(withKeyPrefix(pattern)); + return keys.stream().map(e->{ + if(StringUtils.isBlank(prefixWithDelimiter)){ + return e; + } + return e.replaceFirst(prefixWithDelimiter,""); + }).collect(Collectors.toSet()); } @Override