Explorar el Código

创建新的 UploadChannel 时, 需要把它添加到 StoreLocalCache 中的 channel 缓存里面

reghao hace 2 años
padre
commit
f5d892b9aa

+ 1 - 0
oss-store/src/main/java/cn/reghao/oss/store/rpc/StoreServiceImpl.java

@@ -42,6 +42,7 @@ public class StoreServiceImpl implements StoreService {
         UserContext userContext = new UserContext(userId);
         String objectName = channel.getPrefix();
         objectNameService.createParentDirs(objectName, ObjectScope.PUBLIC.getCode());
+        storeLocalCache.addObjectChannel(channel);
     }
 
     @Override

+ 7 - 0
oss-store/src/main/java/cn/reghao/oss/store/service/StoreLocalCache.java

@@ -42,6 +42,13 @@ public class StoreLocalCache {
         this.storeProperties = storeProperties;
     }
 
+    public void addObjectChannel(ObjectChannel channel) {
+        String prefix = channel.getPrefix();
+        Integer channelId = channel.getChannelId();
+        prefixMap.put(prefix, channel);
+        channelIdMap.put(channelId, channel);
+    }
+
     public String getHost() {
         return springProperties.getHost();
     }