package cn.stylefeng.roses.kernel.cache.api.tenant;
|
|
import cn.stylefeng.roses.kernel.cache.api.CacheOperatorApi;
|
|
import java.util.HashMap;
|
import java.util.Map;
|
|
/**
|
* 租户缓存动态代理
|
*
|
* @author fengshuonan
|
* @date 2022/11/8 0:45
|
*/
|
@SuppressWarnings("all")
|
public class TenantCacheProxyFactory {
|
|
/**
|
* 存放所有代理的缓存
|
*/
|
private static final Map<String, CacheOperatorApi<?>> proxyCacheMap = new HashMap<>();
|
|
/**
|
* 创建带租户控制的缓存代理
|
*
|
* @author fengshuonan
|
* @date 2022/11/8 1:18
|
*/
|
public static <T> CacheOperatorApi<T> createTenantCacheProxy(String tenantCode, CacheOperatorApi<?> cacheOperatorApi) {
|
|
// 计算缓存的key
|
String key = tenantCode + cacheOperatorApi.getCommonKeyPrefix();
|
|
// 直接获取缓存中的代理
|
if (proxyCacheMap.containsKey(key)) {
|
return (CacheOperatorApi<T>) proxyCacheMap.get(key);
|
}
|
|
TenantCacheProxy tenantCacheProxy = new TenantCacheProxy();
|
CacheOperatorApi<?> resultCacheOperator = tenantCacheProxy.bindCacheObject(tenantCode, cacheOperatorApi);
|
proxyCacheMap.put(key, resultCacheOperator);
|
return (CacheOperatorApi<T>) resultCacheOperator;
|
}
|
|
}
|
