当前位置：首页 > news >正文

Spring Cache 多租户缓存隔离解决方案实践

news 2025/9/10 6:35:22

Spring Boot 多租户缓存解决方案实践

在构建多租户 SaaS 应用时，确保不同租户数据隔离是至关重要的。Spring Cache 作为常用的缓存框架，在多租户场景下需要特殊处理以避免数据泄露和缓存污染。本文将分享一种通用的多租户缓存解决方案。

问题背景

在多租户系统中，所有租户共享同一套应用实例，但数据必须严格隔离。使用 Spring Cache 时，如果不做特殊处理，可能会出现以下问题：

不同租户的数据缓存到同一个 key 下，导致数据混乱
租户 A 查询的数据被租户 B 获取到，造成数据泄露
缓存失效时影响所有租户，而非仅影响特定租户

解决方案：自定义 CacheResolver

核心思路

通过自定义 CacheResolver，动态生成包含租户标识的缓存名称，从而实现租户间缓存的完全隔离。

实现代码

@Component("tenantCacheResolver")
public class GenericTenantCacheResolver implements CacheResolver {@Autowiredprivate CacheManager cacheManager;@Overridepublic Collection<? extends Cache> resolveCaches(CacheOperationInvocationContext<?> context) {// 从方法注解中获取缓存名称模板String cacheNameTemplate = getCacheNameTemplate(context);// 获取当前租户IDString tenantId = getCurrentTenantId();String finalCacheName = cacheNameTemplate.replace("{tenant}", tenantId != null ? tenantId : "default");Cache cache = cacheManager.getCache(finalCacheName);return Collections.singletonList(cache);}private String getCacheNameTemplate(CacheOperationInvocationContext<?> context) {Cacheable cacheable = context.getMethod().getAnnotation(Cacheable.class);if (cacheable != null && cacheable.value().length > 0) {return cacheable.value()[0];}return "default";}private String getCurrentTenantId() {// 根据实际项目情况获取租户ID// 可能是从 SecurityContext、ThreadLocal 或其他上下文获取return TenantContext.getCurrentTenantId();}
}

使用示例

@Service
public class BudgetItemsService {@Cacheable(cacheResolver = "tenantCacheResolver", value = "budgetItems:list:{tenant}", key = "#itemName ?: 'default'", unless = "#result.isEmpty()")public List<BudgetItems> getList(String itemName) {// 业务逻辑return budgetItemsMapper.selectList(wrapper);}@Cacheable(cacheResolver = "tenantCacheResolver", value = "user:info:{tenant}", key = "#userId", unless = "#result == null")public User getUserInfo(Long userId) {// 业务逻辑return userMapper.selectById(userId);}
}

高级版本：支持多个缓存

@Component("tenantCacheResolver")
public class AdvancedTenantCacheResolver implements CacheResolver {@Autowiredprivate CacheManager cacheManager;@Overridepublic Collection<? extends Cache> resolveCaches(CacheOperationInvocationContext<?> context) {String tenantId = getCurrentTenantId();String tenantSuffix = tenantId != null ? tenantId : "default";List<Cache> caches = new ArrayList<>();String[] cacheNames = getCacheNames(context);for (String cacheName : cacheNames) {String finalCacheName = cacheName.replace("{tenant}", tenantSuffix);Cache cache = cacheManager.getCache(finalCacheName);if (cache != null) {caches.add(cache);}}return caches;}private String[] getCacheNames(CacheOperationInvocationContext<?> context) {Cacheable cacheable = context.getMethod().getAnnotation(Cacheable.class);if (cacheable != null) {return cacheable.value();}return new String[]{"default"};}private String getCurrentTenantId() {// 实际实现根据项目情况而定return SecurityUtils.getTenantId();}
}