Преглед на файлове

添加并修改 redis 中的缓存 key

reghao преди 2 години
родител
ревизия
eac8404845

+ 7 - 0
dfs-store/src/main/java/cn/reghao/dfs/store/db/repository/MediaRepository.java

@@ -8,6 +8,8 @@ import cn.reghao.dfs.store.model.po.AudioFile;
 import cn.reghao.dfs.store.model.po.ImageFile;
 import cn.reghao.dfs.store.model.po.VideoFile;
 import cn.reghao.dfs.store.model.po.VideoUrl;
+import cn.reghao.oss.api.dto.VideoUrlDto;
+import org.springframework.cache.annotation.Cacheable;
 import org.springframework.stereotype.Repository;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -54,6 +56,11 @@ public class MediaRepository {
         return videoUrlMapper.findHighestQuality(videoFileId);
     }
 
+    @Cacheable(cacheNames = "oss:store:videoUrls", key = "#videoFileId", unless = "#result.empty")
+    public List<VideoUrlDto> findVideoUrls(String videoFileId) {
+        return videoUrlMapper.findVideoUrls(videoFileId);
+    }
+
     public ImageFile findImageFile(String imageFileId) {
         return imageFileMapper.findByImageFileId(imageFileId);
     }

+ 1 - 1
dfs-store/src/main/java/cn/reghao/dfs/store/db/repository/ObjectRepository.java

@@ -62,7 +62,7 @@ public class ObjectRepository {
         return fileMetaMapper.findBySha256sum(sha256sum);
     }
 
-    @Cacheable(cacheNames = "dfs-store:objectMeta", key = "#objectName", unless = "#result == null")
+    @Cacheable(cacheNames = "oss:store:objectMeta", key = "#objectName", unless = "#result == null")
     public ObjectMeta getObjectMeta(String objectName) {
         log.info("查找 db");
         ObjectMeta objectMeta = fileMetaMapper.findObjectMeta(objectName);

+ 0 - 2
dfs-store/src/main/java/cn/reghao/dfs/store/rpc/MediaServiceImpl.java

@@ -2,8 +2,6 @@ package cn.reghao.dfs.store.rpc;
 
 import cn.reghao.dfs.store.db.mapper.ImageFileMapper;
 import cn.reghao.dfs.store.db.mapper.VideoFileMapper;
-import cn.reghao.dfs.store.model.po.ImageFile;
-import cn.reghao.dfs.store.model.po.VideoFile;
 import cn.reghao.oss.api.dto.VideoInfo;
 import cn.reghao.oss.api.iface.MediaService;
 import org.apache.dubbo.config.annotation.DubboService;

+ 1 - 1
dfs-store/src/main/java/cn/reghao/dfs/store/rpc/MediaUrlServiceImpl.java

@@ -37,7 +37,7 @@ public class MediaUrlServiceImpl implements MediaUrlService {
 
     @Override
     public List<VideoUrlDto> getVideoUrls(String videoFileId) {
-        return videoUrlMapper.findVideoUrls(videoFileId);
+        return mediaRepository.findVideoUrls(videoFileId);
     }
 
     @Override

+ 0 - 1
dfs-store/src/main/java/cn/reghao/dfs/store/service/PutObjectService.java

@@ -7,7 +7,6 @@ import cn.reghao.dfs.store.model.vo.ObjectProp;
 import cn.reghao.dfs.store.model.vo.ObjectResult;
 import cn.reghao.dfs.store.util.FileType;
 import cn.reghao.jutil.jdk.security.DigestUtil;
-import cn.reghao.oss.api.constant.ObjectType;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.io.FileUtils;
 import org.springframework.stereotype.Service;