Java视频文件上传

ゞ浴缸里的玫瑰 2023-10-02 12:53 15阅读 0赞

最近在学习上传视频的时候发现阿里云有已经提供的一些接口，可以快速的帮助我们实现视频上传功能。但是文件上传的底层原理我们却不太清除，所以小编整理了一下通过分片上传、断点续传的方式实现上传视频的底层原理，帮助大家更好的理解上传视频功能。

### 分片上传+断点续传 ###

当我们上传一个非常巨大的视频时，发现总是上传失败，那是因为上传的视频文件大小过大，导致后台接受文件时出现异常，还有一种就是上传视频文件到一半的时候，关闭了上传功能，再次上传时还要从头开始上传视频文件，那么这样就导致了用户使用不舒服的情况，所以接下来，小编将通过底层代码的方式，让大家更快了解分片上传功能。

文档：[WebUploader API文档 - Web Uploader][WebUploader API_ - Web Uploader]

说用：使用分片上传功能时，最主要的3个传入服务器的参数：单个分片数，总分片数，名称，通过这3样信息，可以实现分片上传，单点续传功能。

如果看完小编的情况还不是太清楚的话，可以去看上面的文档。

@Controller
    public class UploadController {
        private final static String utf8="utf-8";
        @RequestMapping("/upload")
        @ResponseBody
        public void upload(HttpServletRequest request, HttpServletResponse response) throws UnsupportedEncodingException {
            //分片
            response.setCharacterEncoding(utf8);
            Integer schunk =null;//当前分片数
            //总分片数
            Integer schunks=null;
            //文件的名字
            String name =null;
            //文件的存储目录
            String uploadPath="";
            //文件流
            BufferedOutputStream os =null;
            try {
                //处理接受的文件
                DiskFileItemFactory factory = new DiskFileItemFactory();
                factory.setSizeThreshold(1024);//设置缓冲区
                factory.setRepository(new File(uploadPath));//设置临时目录
                //解析传过来的文件
                ServletFileUpload upload = new ServletFileUpload(factory);
                    upload.setFileSizeMax(51*10241*10241*10241);//设置单个文件的大小
                upload.setSizeMax(101*10241*10241*10241);//设置总文件的大小
                List<FileItem> items = upload.parseRequest(request); //得到上传的所有文件信息
                for (FileItem item : items) {
                    //判断是否为文件对象，如果true表示为是表单域，如果为false表示为文件对象
                    if (item.isFormField()){
                        //如果为表单域，则从提交的表单中获取分片数
                        if ("chunk".equals(item.getFieldName())){
                            schunk =Integer.parseInt(item.getString(utf8));
                        }
    //                        分片总数
                        if ("chunks".equals(item.getFieldName())){
                            schunks =Integer.parseInt(item.getString(utf8));
                        }
                            // 名称
                        if ("name".equals(item.getFieldName())){
                            name =item.getString(utf8);
                        }
                    }
                }
    
    
                for (FileItem item : items) {
                    //判断是否为文件对象，如果true表示为是表单域，如果为false表示为文件对象
                    if (!item.isFormField()){
                        String temFileName=name;
                      if (name!=null){
                          if (schunk!=null){
                              temFileName= schunk+"_"+name;
                          }
                          // 传入文件
                          File temFile = new File(uploadPath, temFileName);
                          //断点续传
                          if (!temFile.exists()){
                              item.write(temFile);
                          }
                      }
                    }
                }
    
                //文件合并
                //如果分片不等于null并且 总分片与最后一个分片相等，就证明所有分片成功
                if (schunk!=null && schunk.intValue() == schunks-1){
                    File tempFile = new File(uploadPath,name);
                    os=new BufferedOutputStream(new FileOutputStream(tempFile));
                    for (int i=0 ;i<schunks;i++){
                        File file = new File(uploadPath,i+"_"+name);
                        while (file.exists()){
                            Thread.sleep(100);
                        }
                        //合并
                       byte[] bytes= FileUtils.readFileToByteArray(file);
                        os.write(bytes);
                        os.flush();
                        //临时文件删除
                        file.delete();
                    }
                    os.flush();
                }
                response.getWriter().write("上传成功");
    
            } catch (FileUploadException e) {
                e.printStackTrace();
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
                try {
                    if (os!=null){
                        //关闭流
                        os.close();
                    }
                }catch (IOException e){
                    e.printStackTrace();
                }
            }
    
        }
    }

### 总结： ###

以上就是代码的演示部分，总的来说就是，通过前端传过来的数据，获取到 单个分片数，总分片数，名称，这三个参数，然后自己创建一个文件解析工厂，设置单个文件的大小和总文件大小（这两个根据自己的需求来设置），然后获取传过来的每一个单个分片数，判断是否已经传过，如果传过那么就略过这个分片，继续执行没传过的分片，最后通过最后一个分片数和总分片数比较，如果他们两个相等那么就证明单个的分片数都传入完成，最后将所有的分片进行合并，在将这个分片删除即可。

最后，如果这篇博客对你有些许的帮助，记得为我点赞哦！

[WebUploader API_ - Web Uploader]: http://fex.baidu.com/webuploader/doc/index.html