快速学习-断点续传解决方案

//测试文件分块
    @Test
    public void testChunk() throws IOException {
        //源文件
        File sourceFile = new File("E:\\ffmpeg_test\\lucene.avi");
        //块文件目录
        String chunkFileFolder = "E:\\ffmpeg_test\\chunks\\";

        //先定义块文件大小
        long chunkFileSize = 1 * 1024 * 1024;

        //块数
        long chunkFileNum = (long) Math.ceil(sourceFile.length() * 1.0 /chunkFileSize);

        //创建读文件的对象
        RandomAccessFile raf_read = new RandomAccessFile(sourceFile,"r");

        //缓冲区
        byte[] b = new byte[1024];
        for(int i=0;i<chunkFileNum;i++){
            //块文件
            File chunkFile = new File(chunkFileFolder+i);
            //创建向块文件的写对象
            RandomAccessFile raf_write = new RandomAccessFile(chunkFile,"rw");
            int len = -1;

            while((len = raf_read.read(b))!=-1){

                raf_write.write(b,0,len);
                //如果块文件的大小达到 1M开始写下一块儿
                if(chunkFile.length()>=chunkFileSize){
                    break;
                }
            }
            raf_write.close();


        }
        raf_read.close();
    }

//测试文件合并
    @Test
    public void testMergeFile() throws IOException {
        //块文件目录
        String chunkFileFolderPath = "E:\\ffmpeg_test\\chunks\\";
        //块文件目录对象
        File chunkFileFolder = new File(chunkFileFolderPath);
        //块文件列表
        File[] files = chunkFileFolder.listFiles();
        //将块文件排序，按名称升序
        List<File> fileList = Arrays.asList(files);
        Collections.sort(fileList, new Comparator<File>() {
            @Override
            public int compare(File o1, File o2) {
                if(Integer.parseInt(o1.getName())>Integer.parseInt(o2.getName())){
                    return 1;
                }
                return -1;

            }
        });

        //合并文件
        File mergeFile = new File("E:\\ffmpeg_test\\lucene_merge.avi");
        //创建新文件
        boolean newFile = mergeFile.createNewFile();

        //创建写对象
        RandomAccessFile raf_write = new RandomAccessFile(mergeFile,"rw");

        byte[] b = new byte[1024];
        for(File chunkFile:fileList){
            //创建一个读块文件的对象
            RandomAccessFile raf_read = new RandomAccessFile(chunkFile,"r");
            int len = -1;
            while((len = raf_read.read(b))!=-1){
                raf_write.write(b,0,len);
            }
            raf_read.close();
        }
        raf_write.close();
    }

WebUploader.Uploader.register({
			"before‐send‐file": "beforeSendFile",
			"before‐send": "beforeSend",
			"after‐send‐file": "afterSendFile"
		}

this.uploader = WebUploader.create({
			swf: "/static/plugins/webuploader/dist/Uploader.swf", //上传文件的flash文件，浏览器不支持h5时启动 
			flashserver:"/api/media/upload/uploadchunk",//上传分块的服务端地址，注意跨域问题 
			fileVal:"file",//文件上传域的name 
			pick:"#picker",//指定选择文件的按钮容器 
			auto:false,//手动触发上传 
			disableGlobalDnd:true,//禁掉整个页面的拖拽功能 
			chunked:true,// 是否分块上传 
			chunkSize:1*1024*1024, // 分块大小（默认5M） 
			threads:3, // 开启多个线程（默认3个） 
			prepareNextFile:true// 允许在文件传输时提前把下一个文件准备好 
			} 
		)

type: "POST", 
url: "/api/media/upload/register", 
data: { 
	// 文件唯一表示 
	fileMd5:this.fileMd5, 
	fileName: file.name, 
	fileSize:file.size, 
	mimetype:file.type, 
	fileExt:file.ext 
}

type:"POST", 
url:"/api/media/upload/checkchunk", 
data:{ 
	// 文件唯一表示 
	fileMd5:this.fileMd5, 
	// 当前分块下标 
	chunk:block.chunk, 
	// 当前分块大小 
	chunkSize:block.end‐block.start 
}

type:"POST", 
url:"/api/media/upload/mergechunks", 
data:{ 
	fileMd5:this.fileMd5, 
	fileName: file.name, 
	fileSize:file.size, 
	mimetype:file.type, 
	fileExt:file.ext 
}