判断是否重复上传

health-video-server/pom.xml

@@ -151,7 +151,10 @@
             <version>3.16.0</version>
         </dependency>
 
-
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-redis</artifactId>
+        </dependency>
 
     </dependencies>
 

health-video-server/src/main/java/com/health/video/server/service/impl/VideoServiceImpl.java

@@ -30,6 +30,7 @@ import org.springframework.amqp.core.MessageDeliveryMode;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import com.health.video.server.utils.DogeUtil;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.multipart.MultipartFile;
@@ -58,6 +59,8 @@ public class VideoServiceImpl implements VideoService {
     private RedissonClient redissonClient;
     @Autowired
     private RemoteWalletService remoteWalletService;
+    @Autowired
+    private RedisTemplate<String,String> redisTemplate;
 
     /**
      * 查询视频类型列表
@@ -253,6 +256,11 @@ public class VideoServiceImpl implements VideoService {
             File localFile = new File(filePath);
             // 计算文件的 SHA-256 哈希值（比MD5加密更安全）
             String fileMD5 = calculateFileSHA256(localFile);
+            // 把文件存入redis记录30秒 30秒内不能重复上传视频
+            redisTemplate.opsForValue().set(fileMD5, String.valueOf(localFile),30,TimeUnit.SECONDS);
+            if(redisTemplate.hasKey(fileMD5)){
+                throw new RuntimeException("请不要重复上传视频！");
+            }
             System.out.println("SHA-256加密内容为："+fileMD5);
             // 检查目录是否存在，如果不存在则创建
             File localDirectory = localFile.getParentFile();