java后端分片上传接口

文件上传工具--FileUtil

1. package com.youmejava.chun.util;
3. import lombok.Data;
4. import org.apache.tomcat.util.http.fileupload.FileUtils;
6. import java.io.File;
7. import java.io.FileInputStream;
8. import java.io.FileOutputStream;
9. import java.io.IOException;
10. import java.nio.channels.FileChannel;
11. import java.util.ArrayList;
12. import java.util.Arrays;
13. import java.util.Collections;
14. import java.util.List;
16. /**
17. * 文件工具
18. */
20. @Data
21. public class FileUtil {
22.     private List<File> filelist;//文件列表
23.     private String strPath;//路径
25.     public FileUtil() {
26.     }
28.     public FileUtil(List<File> filelist, String strPath) {
29.         this.filelist = filelist;
30.         this.strPath = strPath;
31.         getFileList(this.strPath);
32.     }
34.     /**
35.      * 获取文件列表
36.      * @param strPath
37.      * @return
38.      */
39.     public List<File> getFileList(String strPath) {
40.         File dir = new File(strPath);
41.         File[] files = dir.listFiles(); // 该文件目录下文件全部放入数组
42.         if (files != null) {
43.             for (int i = 0; i < files.length; i++) {
44.                 String fileName = files[i].getName();
45.                 if (files[i].isDirectory()) { // 判断是文件还是文件夹
46.                     getFileList(files[i].getAbsolutePath()); // 获取文件绝对路径
47.                 } else  { // 判断文件名
48.                     String strFileName = files[i].getAbsolutePath();
49.                     //                    System.out.println("---" + strFileName);
50.                     filelist.add(files[i]);
51.                 }
52.             }
54.         }
55.         return filelist;
56.     }
58.     /**
59.      * 合并文件
60.      * @param from
61.      * @param to
62.      * @throws IOException
63.      */
64.     public static void mergeFile(String from, String to) throws IOException {
65.         File t = new File(to);
66.         FileInputStream in = null;
67.         FileChannel inChannel = null;
68.         System.out.println("t "+t);
70.         FileOutputStream out = new FileOutputStream(t,true);
71.         FileChannel outChannel = out.getChannel();
73.         File f = new File(from);
74.         System.out.println("f "+f.isDirectory());
75.         // 获取目录下的每一个文件名，再将每个文件一次写入目标文件
76.         if (f.isDirectory()) {
77.             List<File> list = getAllFileAndSort(from);
78.             System.out.println("sortlist  "+list);
79.             // 记录新文件最后一个数据的位置
80.             long start = 0;
81.             for (File file : list) {
83.                 in = new FileInputStream(file);
84.                 inChannel = in.getChannel();
86.                 // 从inChannel中读取file.length()长度的数据，写入outChannel的start处
87.                 outChannel.transferFrom(inChannel, start, file.length());
88.                 start += file.length();
89.                 in.close();
90.                 inChannel.close();
91.             }
92.         }
93.         out.close();
94.         outChannel.close();
95.     }
97.     /**
98.      * 所有文件排序
99.      * @param dirPath 文件根目录路径
100.      * @return
101.      */
102.     public static List<File> getAllFileAndSort(String dirPath) {
103.         File dirFile = new File(dirPath);
104.         File[] listFiles = dirFile.listFiles();
105.         List<File> list = Arrays.asList(listFiles);
106.         Collections.sort(list, (o1, o2) -> {
107.             String _str=o1.getName().split("\\.")[0];
108.             String _num=_str.split("_")[1];
109.             String _str2=o2.getName().split("\\.")[0];
110.             String _num2=_str2.split("_")[1];
111.             return Integer.parseInt(_num) - Integer.parseInt(_num2);
112.         });
113.         return list;
114.     }
116.     /**
117.      * 删除文件夹
118.      * 删除文件夹需要把包含的文件及文件夹先删除，才能成功
119.      * https://blog.csdn.net/m0_57640408/article/details/120774050
120.      * @param directory 文件夹名
121.      * @return 删除成功返回true,失败返回false
122.      */
123.     public static boolean deleteDirectory(String directory) {
124.         // directory不以文件分隔符（/或\）结尾时，自动添加文件分隔符，不同系统下File.separator方法会自动添加相应的分隔符
125.         if (!directory.endsWith(File.separator)) {
126.             directory = directory + File.separator;
127.         }
128.         File directoryFile = new File(directory);
129.         // 判断directory对应的文件是否存在，或者是否是一个文件夹
130.         if (!directoryFile.exists() || !directoryFile.isDirectory()) {
131.             System.out.println("文件夹删除失败，文件夹不存在" + directory);
132.             return false;
133.         }
134.         boolean flag = true;
135.         // 删除文件夹下的所有文件和文件夹
136.         File[] files = directoryFile.listFiles();
137.         for (int i = 0; i < files.length; i++) {  // 循环删除所有的子文件及子文件夹
138.             // 删除子文件
139.             if (files[i].isFile()) {
140.                 flag = deleteFile(files[i].getAbsolutePath());
141.                 if (!flag) {
142.                     break;
143.                 }
144.             } else {  // 删除子文件夹
145.                 flag = deleteDirectory(files[i].getAbsolutePath());
146.                 if (!flag) {
147.                     break;
148.                 }
149.             }
150.         }
152.         if (!flag) {
153.             System.out.println("删除失败");
154.             return false;
155.         }
156.         // 最后删除当前文件夹
157.         if (directoryFile.delete()) {
158.             System.out.println("删除成功：" + directory);
159.             return true;
160.         } else {
161.             System.out.println("删除失败：" + directory);
162.             return false;
163.         }
164.     }
166.     /**
167.      * 删除文件
168.      *
169.      * @param fileName 文件名
170.      * @return 删除成功返回true,失败返回false
171.      */
172.     public static boolean deleteFile(String fileName) {
173.         File file = new File(fileName);
174.         if (file.isFile() && file.exists()) {
175.             file.delete();
176.             System.out.println("删除文件成功：" + fileName);
177.             return true;
178.         } else {
179.             System.out.println("删除文件失败：" + fileName);
180.             return false;
181.         }
182.     }
184. }

复制代码

 
分片上传文件接口

1.  package com.youmejava.chun.commoninterface;
3. import com.youmejava.chun.util.FileUtil;
4. import com.youmejava.chun.util.ResultVo;
5. import com.youmejava.chun.util.StringUtil;
6. import io.swagger.annotations.Api;
7. import io.swagger.annotations.ApiImplicitParam;
8. import io.swagger.annotations.ApiImplicitParams;
9. import io.swagger.annotations.ApiOperation;
10. import org.apache.shiro.authc.ExpiredCredentialsException;
11. import org.springframework.beans.factory.annotation.Value;
12. import org.springframework.stereotype.Service;
13. import org.springframework.transaction.annotation.Transactional;
14. import org.springframework.web.bind.annotation.*;
15. import org.springframework.web.multipart.MultipartFile;
16. import org.springframework.web.multipart.MultipartHttpServletRequest;
18. import javax.servlet.http.HttpServletRequest;
19. import java.io.*;
20. import java.util.Arrays;
21. import java.util.HashMap;
22. import java.util.List;
23. import java.util.Map;
25. @RestController
26. @RequestMapping("/api/apiSystem/upload")
27. @Api(value = "文件上传", tags = "文件上传")
28. public class UploadController {
30.     @Value("${filePath1}")
31.     private String filePath;
33.     @PostMapping("/register")
34.     @ApiOperation(value = "文件注册", notes = "文件注册")
35.     @ApiImplicitParams({@ApiImplicitParam(value = "哈希值", name = "hash", required = true, paramType = "body")})
36.     public ResultVo register(@RequestBody Map<String, Object> map) {
37.         System.out.println("hash: " + map.get("hash"));
38.         if (!StringUtil.isNotBlankAndNull(map.get("hash").toString())) {
39.             //            return ResultVo.failure("哈希值不可为空");
40.             throw new ExpiredCredentialsException("哈希值不可为空！");
41.         }
42.         String _filePath=filePath;
43.         if (!_filePath.endsWith("/")) {
44.             _filePath+="/";
45.         }
46. //        String _pathStr = "C:\\Users\\JH-rent\\Desktop\\java启动文件\\test" + "\" + map.get("hash");
47.         String _pathStr=_filePath+map.get("hash");
48.         //创建不同的文件夹目录
49.         File file = new File(_pathStr);
50.         //判断文件夹是否存在
51.         if (!file.exists()) {
52.             //如果文件夹不存在，则创建新的的文件夹
53.             file.mkdirs();
54.         }
55.         File f = new File(_pathStr);
57.         // 检查目录是否已上传过文件，如果上传过，返回上传个数
58.         if (f.isDirectory()) {
59.             File dirFile = new File(_pathStr);
60.             File[] listFiles = dirFile.listFiles();
61.             List<File> list = Arrays.asList(listFiles);
62.             if (list == null&&list.size()>0) {
63.                 Map<String, Object>map1=new HashMap<>();
64.                 map1.put("number",list.size());
65.                 return ResultVo.success(map1);
66.             }
67.         }
70.         return ResultVo.success();
71.     }
73.     @PostMapping("/uploadFile")
74.     @ResponseBody
75.     @ApiOperation(value = "上传文件", notes = "上传文件")
76.     @ApiImplicitParams({@ApiImplicitParam(value = "哈希值", name = "hash", required = true, paramType = "body"), @ApiImplicitParam(value = "文件流", name = "file", required = true, paramType = "body"), @ApiImplicitParam(value = "文件名称", name = "fileName", required = true, paramType = "body"),})
77.     public ResultVo uploadFile(HttpServletRequest request) {
78.         MultipartHttpServletRequest params = ((MultipartHttpServletRequest) request);
79.         List<MultipartFile> files = ((MultipartHttpServletRequest) request).getFiles("file");
80.         String _fileName = params.getParameter("fileName");
81.         String _hash = params.getParameter("hash");
82.         if (!StringUtil.isNotBlankAndNull(_hash)) {
83.             throw new ExpiredCredentialsException("哈希值不可为空！");
84.         }
85.         if (!StringUtil.isNotBlankAndNull(_fileName)) {
86.             throw new ExpiredCredentialsException("文件名称不可为空！");
87.         }
88. //        System.out.println("_fileName: " + _fileName);
89. //        System.out.println("_hash: " + _hash);
90. //        System.out.println("files: " + files);
91. //        System.out.println(params.getParameter("file"));
92. //        String _pathStr = "C:\\Users\\JH-rent\\Desktop\\java启动文件\\test" + "\" + _hash + "\";
94.         String _filePath=filePath;
95.         if (!_filePath.endsWith("/")) {
96.             _filePath+="/";
97.         }
98.         String _pathStr =_filePath+_hash+"/";
100.         FileOutputStream fileOut = null;
101.         //写入到文件（注意文件保存路径的后面一定要加上文件的名称）
103.         try {
104.             fileOut = new FileOutputStream(_pathStr + _fileName);
105.             BufferedOutputStream bos = new BufferedOutputStream(fileOut);
106.             BufferedInputStream bis = null;
107.             for (MultipartFile file : files) {
108.                 //                file.transferTo(new File(_pathStr + file.getOriginalFilename()));
109.                 //                System.out.println(file.getInputStream());
110.                 bis = new BufferedInputStream(file.getInputStream());
111.             }
113.             byte[] buf = new byte[4096];
114.             int length = bis.read(buf);
115.             //保存文件
116.             while (length != -1) {
117.                 bos.write(buf, 0, length);
118.                 length = bis.read(buf);
119.             }
120.             bos.close();
121.             bis.close();
122.             return ResultVo.success();
123.         } catch (Exception e) {
124.             e.printStackTrace();
125.             return ResultVo.failure(e.getMessage());
126.         }
128.     }
130.     @GetMapping("/getMergeFile")
131.     @ApiOperation(value = "获取合并文件", notes = "获取合并文件")
132.     @ApiImplicitParams({@ApiImplicitParam(value = "哈希值", name = "hash", required = true, dataType = "String"), @ApiImplicitParam(value = "文件名称", name = "fileName", required = true, dataType = "String")})
133.     public ResultVo getMergeFile(@RequestParam(value = "hash") String hash, @RequestParam(value = "fileName") String fileName) {
134. //        String _pathStr = "C:\\Users\\JH-rent\\Desktop\\java启动文件\\test" + "\" + hash + "\";
135. //        String _pathStr1 = "C:\\Users\\JH-rent\\Desktop\\java启动文件\\test";
137.         String _filePath=filePath;
138.         if (!_filePath.endsWith("/")) {
139.             _filePath+="/";
140.         }
141.         String _pathStr = _filePath + hash + "/";
142.         String _pathStr1 = _filePath;
143.         try {
144. //            if (!_pathStr1.endsWith("\")) {
145. //                _pathStr1 += "\";
146. //            }
147.             _pathStr1 += fileName;
148.             FileUtil.mergeFile(_pathStr, _pathStr1);
149.             //合并成功删除加密文件
150.             FileUtil.deleteDirectory(_pathStr);
151.         } catch (IOException e) {
152.             e.printStackTrace();
153.         }
154.         Map<String, Object>map=new HashMap<>();
155.         map.put("fileUrl",_pathStr1);
156.         return ResultVo.success(map);
157.     }
159. }

复制代码

前端分片链接：https://www.cnblogs.com/wxchun/p/15892243.html

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！