| | |
| | | import com.ruoyi.common.constant.CacheNames; |
| | | import com.ruoyi.common.utils.JsonUtils; |
| | | import com.ruoyi.common.utils.StringUtils; |
| | | import com.ruoyi.common.utils.cache.CacheUtils; |
| | | import com.ruoyi.common.utils.redis.CacheUtils; |
| | | import com.ruoyi.common.utils.redis.RedisUtils; |
| | | import com.ruoyi.oss.constant.OssConstant; |
| | | import com.ruoyi.oss.core.OssClient; |
| | |
| | | */ |
| | | public static void init() { |
| | | log.info("初始化OSS工厂"); |
| | | RedisUtils.subscribe(OssConstant.CACHE_CONFIG_KEY, String.class, configKey -> { |
| | | RedisUtils.subscribe(OssConstant.DEFAULT_CONFIG_KEY, String.class, configKey -> { |
| | | OssClient client = getClient(configKey); |
| | | // 未初始化不处理 |
| | | if (client != null) { |
| | |
| | | */ |
| | | public static OssClient instance() { |
| | | // 获取redis 默认类型 |
| | | String configKey = (String) CacheUtils.get(CacheNames.SYS_OSS_CONFIG, OssConstant.OSS_CONFIG_KEY); |
| | | String configKey = RedisUtils.getCacheObject(OssConstant.DEFAULT_CONFIG_KEY); |
| | | if (StringUtils.isEmpty(configKey)) { |
| | | throw new OssException("文件存储服务类型无法找到!"); |
| | | } |
| | |
| | | } |
| | | |
| | | private static void refresh(String configKey) { |
| | | Object json = CacheUtils.get(CacheNames.SYS_OSS_CONFIG, configKey); |
| | | OssProperties properties = JsonUtils.parseObject(json.toString(), OssProperties.class); |
| | | if (properties == null) { |
| | | String json = CacheUtils.get(CacheNames.SYS_OSS_CONFIG, configKey); |
| | | if (json == null) { |
| | | throw new OssException("系统异常, '" + configKey + "'配置信息不存在!"); |
| | | } |
| | | OssProperties properties = JsonUtils.parseObject(json, OssProperties.class); |
| | | CLIENT_CACHE.put(configKey, new OssClient(configKey, properties)); |
| | | } |
| | | |