文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

如何使用vue+springboot上传大文件

2023-07-06 13:08

关注

这篇文章主要介绍“如何使用vue+springboot上传大文件”的相关知识,小编通过实际案例向大家展示操作过程,操作方法简单快捷,实用性强,希望这篇“如何使用vue+springboot上传大文件”文章能帮助大家解决问题。

逻辑

需要做大文件上传应该考虑到如下逻辑:

前端

<!DOCTYPE html><html lang="en"><head>    <meta charset="UTF-8">    <title>File Upload</title></head><body>    <input type="file" id="fileInput">    <button onclick="upload()">Upload</button>    <script>        function upload() {            let file = document.getElementById("fileInput").files[0];            let chunkSize = 5 * 1024 * 1024; // 切片大小为5MB            let totalChunks = Math.ceil(file.size / chunkSize); // 计算切片总数            let index = 0;            while (index < totalChunks) {                let chunk = file.slice(index * chunkSize, (index + 1) * chunkSize);                let formData = new FormData();                formData.append("file", chunk);                formData.append("index", index);                formData.append("totalChunks", totalChunks);                // 发送Ajax请求上传切片                $.ajax({                    url: "/uploadChunk",                    type: "POST",                    data: formData,                    processData: false,                    contentType: false,                    success: function () {                        if (++index >= totalChunks) {                            // 所有切片上传完成,通知服务端合并文件                            $.post("/mergeFile", {fileName: file.name}, function () {                                alert("Upload complete!");                            })                        }                    }                });            }        }    </script></body></html>

后端

controller层:

@RestControllerpublic class FileController {    @Value("${file.upload-path}")    private String uploadPath;    @PostMapping("/uploadChunk")    public void uploadChunk(@RequestParam("file") MultipartFile file,                            @RequestParam("index") int index,                            @RequestParam("totalChunks") int totalChunks) throws IOException {        // 以文件名+切片索引号为文件名保存切片文件        String fileName = file.getOriginalFilename() + "." + index;        Path tempFile = Paths.get(uploadPath, fileName);        Files.write(tempFile, file.getBytes());        // 记录上传状态        String uploadFlag = UUID.randomUUID().toString();        redisTemplate.opsForList().set("upload:" + fileName, index, uploadFlag);        // 如果所有切片已上传,则通知合并文件        if (isAllChunksUploaded(fileName, totalChunks)) {            sendMergeRequest(fileName, totalChunks);        }    }    @PostMapping("/mergeFile")    public void mergeFile(String fileName) throws IOException {        // 所有切片均已成功上传,进行文件合并        List<File> chunkFiles = new ArrayList<>();        for (int i = 0; i < getTotalChunks(fileName); i++) {            String chunkFileName = fileName + "." + i;            Path tempFile = Paths.get(uploadPath, chunkFileName);            chunkFiles.add(tempFile.toFile());        }        Path destFile = Paths.get(uploadPath, fileName);        try (OutputStream out = Files.newOutputStream(destFile);             SequenceInputStream seqIn = new SequenceInputStream(Collections.enumeration(chunkFiles));             BufferedInputStream bufIn = new BufferedInputStream(seqIn)) {            byte[] buffer = new byte[1024];            int len;            while ((len = bufIn.read(buffer)) > 0) {                out.write(buffer, 0, len);            }        }        // 清理临时文件和上传状态记录        for (int i = 0; i < getTotalChunks(fileName); i++) {            String chunkFileName = fileName + "." + i;            Path tempFile = Paths.get(uploadPath, chunkFileName);            Files.deleteIfExists(tempFile);            redisTemplate.delete("upload:" + chunkFileName);        }    }    private int getTotalChunks(String fileName) {        // 根据文件名获取总切片数        return Objects.requireNonNull(Paths.get(uploadPath, fileName).toFile().listFiles()).length;    }    private boolean isAllChunksUploaded(String fileName, int totalChunks) {        // 判断所有切片是否已都上传完成        List<String> uploadFlags = redisTemplate.opsForList().range("upload:" + fileName, 0, -1);        return uploadFlags != null && uploadFlags.size() == totalChunks;    }    private void sendMergeRequest(String fileName, int totalChunks) {        // 发送合并文件请求        new Thread(() -> {            try {                URL url = new URL("http://localhost:8080/mergeFile");                HttpURLConnection conn = (HttpURLConnection) url.openConnection();                conn.setRequestMethod("POST");                conn.setDoOutput(true);                conn.setDoInput(true);                conn.setRequestProperty("Content-Type", "application/x-www-form-urlencoded;charset=utf-8");                OutputStream out = conn.getOutputStream();                String query = "fileName=" + fileName;                out.write(query.getBytes());                out.flush();                out.close();                BufferedReader br = new BufferedReader(new InputStreamReader(conn.getInputStream(), StandardCharsets.UTF_8));                while (br.readLine() != null) ;                br.close();            } catch (IOException e) {                e.printStackTrace();            }        }).start();    }    @Autowired    private RedisTemplate<String, Object> redisTemplate;}

其中,file.upload-path为文件上传的保存路径,可以在application.properties或application.yml中进行配置。同时需要添加RedisTemplate的Bean以便记录上传状态。

RedisTemplate配置

如果需要使用RedisTemplate,需要引入下方的包

<dependency>    <groupId>org.springframework.boot</groupId>    <artifactId>spring-boot-starter-data-redis</artifactId></dependency>

同时在yml配置redis的信息

spring.redis.host=localhostspring.redis.port=6379spring.redis.database=0

然后在自己的类中这样使用

@Componentpublic class myClass {    @Autowired    private RedisTemplate<String, Object> redisTemplate;    public void set(String key, Object value) {        redisTemplate.opsForValue().set(key, value);    }    public Object get(String key) {        return redisTemplate.opsForValue().get(key);    }}

注意事项

关于“如何使用vue+springboot上传大文件”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识,可以关注编程网行业资讯频道,小编每天都会为大家更新不同的知识点。

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     807人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     351人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     314人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     433人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     221人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯