java大视频分片上传

实现原理，前端控制每次上传1mb，后端接受1mb，并记录该分片下标，返回给前端还未上传的下标，直到所有的都上传完成
controller

1. @ApiOperation(value = "上传视频", notes = "上传视频", httpMethod = "POST", response = WebResult.class)
2. @PostMapping(value = "/uploadVideo", consumes = MediaType.MULTIPART_FORM_DATA_VALUE)//
3. public AjaxResult uploadVideo(@RequestParam(name = "file") MultipartFile file,
4.                               @RequestParam(name = "chunkIndex") Integer chunkIndex,
5.                               @RequestParam(name = "md5") String md5,
6.                               @RequestParam(name = "totalFileSize") Long totalFileSize,
7.                               @RequestParam(name = "fileName") String fileName,
8.                               @RequestParam(name = "userName") String userName,
9.                               HttpServletRequest request) throws Exception {
10.     if (null == file || file.isEmpty()) {
11.         return AjaxResult.error("文件内容不能为空！");
12.     }
14.     return fileSystemService.uploadVideo(file, chunkIndex, md5, fileName, userName);
15.     }

复制代码

service

1. public AjaxResult uploadVideo(MultipartFile file, Integer chunkIndex, String md5, String fileName, String userName) throws IOException {
2.         //创建存放文件夹
3.         String date = DateTime.now().toString("yyyyMMdd");
4.         String dirPath = ConstantUtils.FILE_VIDEO_PATH + userName + "/" + date + "/" + md5 + "/";
5.         File dirFile = new File(dirPath);
6.         if (!dirFile.exists()){
7.             dirFile.mkdirs();
8.         }
9.         //分区文件
10.         String relativeFilePath = dirPath + fileName;
11.         File tempFile = new File(relativeFilePath);
12.         RandomAccessFile rw = new RandomAccessFile(tempFile, "rw");
13.         //定位到分片的偏移量
14.         rw.seek(Long.parseLong(ConstantUtils.FILE_VIDEO_CHUNK_SIZE) * chunkIndex);
15.         //写入分片数据
16.         rw.write(file.getBytes());
17.         //关闭流
18.         rw.close();
19.         //读取已经分片的集合
20.         Set<Object> hasChunkList = new HashSet<>();
21.         String hasChunkKey = ConstantUtils.CHUNK_PREFIX + md5;
22.         if (redisHelper.hasKey(hasChunkKey)){
23.             Object o = redisHelper.get(hasChunkKey);
24.             JSONArray array = JSONUtil.parseArray(o);
25.             hasChunkList.addAll(array);
26.         }
27.         hasChunkList.add(chunkIndex);
28.         //最新分片下标跟新到redis
29.         redisHelper.set(hasChunkKey,hasChunkList);
31.         HashMap<String, Object> map = new HashMap<>();
32.         map.put("url",userName + "/" + date + "/" + md5 + "/" + fileName);
33.         map.put("hasList",hasChunkList);
34.         return AjaxResult.success(map);
35.     }

复制代码

ConstantUtils

1. package com.ruoyi.file.utils;
3. import org.springframework.beans.factory.InitializingBean;
4. import org.springframework.beans.factory.annotation.Value;
5. import org.springframework.stereotype.Component;
8. /**
9. * @author csb
10. * @description: 获取配置文件常量数据
11. * @date 2023/9/20
12. */
14. // spring初始化bean的时候，如果bean实现了InitializingBean接口，
15. // 会自动调用afterPropertiesSet方法
16. @Component
17. public class ConstantUtils implements InitializingBean {
19.     @Value("${file.video.videoPath}")
20.     String videoPath;
22.     @Value("${file.video.chunkSize}")
23.     String videoChunkSize;
26.     public static String FILE_VIDEO_PATH;
28.     public static String FILE_VIDEO_CHUNK_SIZE;
30.     public static String CHUNK_PREFIX = "FILE_VIDEO";
32.     @Override
33.     public void afterPropertiesSet() throws Exception {
34.         FILE_VIDEO_PATH = videoPath;
35.         FILE_VIDEO_CHUNK_SIZE = videoChunkSize;
36.     }
37. }

复制代码

RedisHelper

1. package com.ruoyi.file.utils;
3. import org.slf4j.Logger;
4. import org.slf4j.LoggerFactory;
5. import org.springframework.data.redis.core.HashOperations;
6. import org.springframework.data.redis.core.ListOperations;
7. import org.springframework.data.redis.core.RedisTemplate;
8. import org.springframework.stereotype.Component;
10. import javax.annotation.Resource;
11. import java.util.ArrayList;
12. import java.util.HashMap;
13. import java.util.List;
14. import java.util.Map;
15. import java.util.concurrent.TimeUnit;
17. @Component
18. public class RedisHelper {
20.     private static final Logger logger = LoggerFactory.getLogger(RedisHelper.class);
22.     public static final int CACHE_TIME_1_YEAR = 60 * 60 * 24 * 365;
25.     @Resource
26.     private RedisTemplate<Object, Object> redisTemplate;
28.     /**
29.      * 读取缓存
30.      *
31.      * @param key
32.      * @return
33.      */
34.     public Object get(final String key) {
35.         return redisTemplate.opsForValue().get(key);
36.     }
38.     /**
39.      * 写入缓存
40.      */
41.     public boolean set(final String key, Object value) {
42.         boolean result = false;
43.         try {
44.             redisTemplate.opsForValue().set(key, value);
45.             result = true;
46.         } catch (Exception e) {
47.             logger.warn("", e);
48.         }
49.         return result;
50.     }
52.     /**
53.      * 写入缓存
54.      */
55.     public boolean set(final String key, Object value, int seconds) {
56.         boolean result = false;
57.         try {
58.             if (seconds > 0) {
59.                 redisTemplate.opsForValue().set(key, value, seconds, TimeUnit.SECONDS);
60.             } else {
61.                 redisTemplate.opsForValue().set(key, value);
62.             }
63.             result = true;
64.         } catch (Exception e) {
65.             logger.warn("", e);
66.         }
67.         return result;
68.     }
70.     public boolean hasKey(String key) {
71.         return redisTemplate.hasKey(key);
72.     }
74.     public boolean exist(final String key) {
75.         return redisTemplate.hasKey(key);
76.     }
78.     /**
79.      * 更新缓存
80.      */
81.     public boolean getAndSet(final String key, Object value) {
82.         boolean result = false;
83.         try {
84.             redisTemplate.opsForValue().getAndSet(key, value);
85.             result = true;
86.         } catch (Exception e) {
87.             logger.warn("", e);
88.         }
89.         return result;
90.     }
92.     /**
93.      * 删除缓存
94.      */
95.     public boolean delete(final String key) {
96.         boolean result = false;
97.         try {
98.             redisTemplate.delete(key);
99.             result = true;
100.         } catch (Exception e) {
101.             logger.warn("", e);
102.         }
103.         return result;
104.     }
106.     /**
107.      * 1.Redis设置多个值
108.      * 命令：HMSET myhash total 15 success 0 time "2019-12-01 11:10:15"
109.      * 2.当一个任务完成之后，把成功的次数加1
110.      * 命令：HINCRBY myhash success 1
111.      * <p>
112.      * 当前有多少个计算（有点过几次计算）
113.      * 1.列表中添加值
114.      * 命令：RPUSH mylist "hello"
115.      * 2.获取列表中所有元素
116.      * 命令：LRANGE mylist 0 -1
117.      */
119.     /**
120.      * 设置hash值，同时设置多个属性
121.      *
122.      * @param key 键
123.      * @param map 多个属性值用map封装
124.      * @return
125.      */
126.     public boolean hmset(final String key, Map<String, Object> map) {
127.         boolean result = false;
128.         try {
129.             HashOperations<Object, Object, Object> opsForHash = redisTemplate.opsForHash();
130.             opsForHash.putAll(key, map);
131.             result = true;
132.         } catch (Exception e) {
133.             logger.warn("", e);
134.         }
135.         return result;
136.     }
138.     /**
139.      * 自增值，给hash值某个属性自增
140.      *
141.      * @param key   键
142.      * @param field 要自增的属性
143.      * @param num   自增值的大小，可以为正数负数
144.      * @return
145.      */
146.     public boolean hincrby(final String key, String field, Integer num) {
147.         boolean result = false;
148.         try {
149.             HashOperations<Object, Object, Object> opsForHash = redisTemplate.opsForHash();
150.             opsForHash.increment(key, field, num);
151.             result = true;
152.         } catch (Exception e) {
153.             logger.warn("", e);
154.         }
155.         return result;
156.     }
158.     /**
159.      * 自增值，给hash值某个属性自增1
160.      *
161.      * @param key   键
162.      * @param field 要自增的属性
163.      * @return
164.      */
165.     public boolean hincrby(final String key, String field) {
166.         boolean result = false;
167.         try {
168.             HashOperations<Object, Object, Object> opsForHash = redisTemplate.opsForHash();
169.             opsForHash.increment(key, field, 1);
170.             result = true;
171.         } catch (Exception e) {
172.             logger.warn("", e);
173.         }
174.         return result;
175.     }
177.     /**
178.      * 获取hash中的所有数据
179.      *
180.      * @param key
181.      * @return
182.      */
183.     public Map<Object, Object> hgetall(final String key) {
184.         Map<Object, Object> entries = new HashMap<>();
185.         try {
186.             HashOperations<Object, Object, Object> opsForHash = redisTemplate.opsForHash();
187.             entries = opsForHash.entries(key);
188.             return entries;
189.         } catch (Exception e) {
190.             logger.warn("", e);
191.         }
192.         return entries;
193.     }
195.     /**
196.      * list操作，队列右侧添加值
197.      *
198.      * @param key
199.      * @param value
200.      * @return
201.      */
202.     public boolean rpush(final String key, Object value) {
203.         boolean result = false;
204.         try {
205.             ListOperations<Object, Object> opsForList = redisTemplate.opsForList();
206.             opsForList.rightPush(key, value);
207.             result = true;
208.         } catch (Exception e) {
209.             logger.warn("", e);
210.         }
211.         return result;
212.     }
214.     /**
215.      * 获取列表中的所有元素
216.      *
217.      * @param key
218.      * @return
219.      */
220.     public List<Object> lrange(final String key) {
221.         List<Object> range = new ArrayList<>();
222.         try {
223.             ListOperations<Object, Object> opsForList = redisTemplate.opsForList();
224.             range = opsForList.range(key, 0, -1);
225.             return range;
226.         } catch (Exception e) {
227.             logger.warn("", e);
228.         }
229.         return range;
230.     }
232.     /**
233.      * 删除list中的值
234.      *
235.      * @param key   list的key
236.      * @param value 要删除的list中的value
237.      * @return
238.      */
239.     public boolean lrem(final String key, Object value) {
240.         boolean result = false;
241.         try {
242.             ListOperations<Object, Object> opsForList = redisTemplate.opsForList();
243.             opsForList.remove(key, 0, value);
244.             result = true;
245.         } catch (Exception e) {
246.             logger.warn("", e);
247.         }
248.         return result;
249.     }
251.     /**
252.      * 设置键的过期时间
253.      * @param key 键
254.      * @param expiredTimeSecond 过期时间（秒）
255.      * @return
256.      */
257.     public boolean setKeyExpiredTime(String key, Long expiredTimeSecond){
258.         return this.redisTemplate.expire(key, expiredTimeSecond,TimeUnit.SECONDS);
259.     }
261. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。