/**
     * 文件分塊上傳測(cè)試
     */
    @Test
    public  void  testChunk(){
        //獲取源文件
        File sourceFile = new File("B:\\workspace\\test\\you.ncm");
        //源文件字節(jié)大小
        long length = sourceFile.length();
        //分塊文件目錄
        String chunkPath="B:\\workspace\\test\\chunk\\";
        File chunkFolder = new File(chunkPath);
        //檢查目錄是否存在
        if (!chunkFolder.exists()) {
            //不存在就創(chuàng)建
            chunkFolder.mkdirs();
        }
        //分塊大小
        long chunkSize = 1024*1024*1;
        //分塊數(shù)量
        long chunkNum = (long) Math.ceil(length * 1.0 / chunkSize);
        //緩沖區(qū)大小
        byte[] b = new byte[1024];
        //使用RandomAccessFile訪問文件
        try {
            RandomAccessFile read = new RandomAccessFile(sourceFile, "r");
            for (int i = 0; i < chunkNum; i++) {
                //創(chuàng)建分塊文件
                File file = new File(chunkPath + i);
                //檢查文件是否存在，如果存在就刪除文件
                if(file.exists()){
                    file.delete();
                }
                //創(chuàng)建一個(gè)新文件
                boolean newFile = file.createNewFile();
                if (newFile){
                    //向分塊文件中寫數(shù)據(jù)
                    RandomAccessFile write = new RandomAccessFile(file,"rw");
                    int len = -1;
                    while ((len = read.read(b)) != -1) {
                        write.write(b, 0, len);
                        //如果分塊文件的大小大于等于分塊大小就跳過本次循環(huán)
                        if (file.length() >= chunkSize) {
                            break;
                        }
                    }
                    write.close();
                    System.out.println("完成分塊"+i);
                }

            }
            read.close();
        } catch (Exception e) {
            e.printStackTrace();
        }

    }

//測(cè)試文件合并方法
    @Test
    public void testMerge(){
        try {
            //獲取源文件
            File sourceFile = new File("B:\\workspace\\test\\you.ncm");
            //分塊文件目錄
            String chunkPath="B:\\workspace\\test\\chunk\\";
            //合并后的文件
            File mergeFile = new File("B:\\workspace\\test\\you1.ncm");
            if (mergeFile.exists()) {
                mergeFile.delete();
            }
            //創(chuàng)建新的合并文件
            mergeFile.createNewFile();
            RandomAccessFile write = new RandomAccessFile(mergeFile,"rw");
            //指針指向文件頂端
            write.seek(0);
            //緩沖區(qū)
            byte[] b = new byte[1024];
            //獲取分塊文件數(shù)組
            File file = new File(chunkPath);
            File[] files = file.listFiles();
            // 轉(zhuǎn)成集合，便于排序
            List<File> fileList = Arrays.asList(files);
            //使用工具類和自定義比較類進(jìn)行排序

            Collections.sort(fileList, new Comparator<File>() {
                @Override
                public int compare(File o1, File o2) {
                    Integer o1Name = Integer.parseInt(o1.getName());
                    Integer o2Name=Integer.parseInt(o2.getName());
                    return o1Name-o2Name;
                }
            });
            //合并文件
            for (File file1 : fileList) {
                RandomAccessFile read = new RandomAccessFile(file1,"r");
                int len = -1;
                while ((len = read.read(b)) != -1) {
                    write.write(b, 0, len);

                }
                read.close();
            }
            write.close();
            //校驗(yàn)文件
            FileInputStream fileInputStream = new FileInputStream(sourceFile);
            FileInputStream mergeFileStream = new FileInputStream(mergeFile);
            //取出原始文件的md5
            String originalMd5 = DigestUtils.md5Hex(fileInputStream);
            //取出合并文件的md5進(jìn)行比較
            String mergeFileMd5 = DigestUtils.md5Hex(mergeFileStream);
            if (originalMd5.equals(mergeFileMd5)) {
                System.out.println("合并文件成功");
            } else {
                System.out.println("合并文件失敗");
            }





        } catch (Exception e) {
            e.printStackTrace();
        }


    }

 //將分塊文件上傳至minio
    @Test
    public void uploadChunk(){
        String chunkFolderPath = "B:\\workspace\\test\\chunk\\";
        File chunkFolder = new File(chunkFolderPath);
        //分塊文件
        File[] files = chunkFolder.listFiles();
        //將分塊文件上傳至minio
        for (int i = 0; i < files.length; i++) {
            try {
                UploadObjectArgs uploadObjectArgs = UploadObjectArgs
                                                      .builder()
                                                      .bucket("testbucket")//桶名
                                                      .object("chunk/" + i)//存儲(chǔ)路徑+文件名
                                                      .filename(files[i].getAbsolutePath())
                                                      .build();
                minioClient.uploadObject(uploadObjectArgs);
                System.out.println("上傳分塊成功"+i);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }

    }

//合并文件，要求分塊文件最小5M
    @Test
    public void test_merge() throws Exception {
        List<ComposeSource> sources = new ArrayList<>();
        for (int i = 0; i <=7; i++) {
            ComposeSource composeSource = ComposeSource
                    .builder()//指定分塊文件信息
                    .bucket("testbucket")
                    .object("chunk/" + (Integer.toString(i)))//目標(biāo)文件信息
                    .build();
            sources.add(composeSource);
        }
        ComposeObjectArgs composeObjectArgs = ComposeObjectArgs
                                                        .builder()
                                                        .bucket("testbucket")
                                                        .object("merge01.npm")//目標(biāo)文件
                                                        .sources(sources)//源文件
                                                        .build();
        //合并文件
        minioClient.composeObject(composeObjectArgs);

    }

//清除分塊文件
    @Test
    public void test_removeObjects(){
        //合并分塊完成將分塊文件清除
        List<DeleteObject> deleteObjects = Stream.iterate(0, i -> ++i)
                .limit(2)//循環(huán)幾次
                .map(i -> new DeleteObject("chunk/".concat(Integer.toString(i))))
                .collect(Collectors.toList());

        RemoveObjectsArgs removeObjectsArgs = RemoveObjectsArgs.builder().bucket("testbucket").objects(deleteObjects).build();
        Iterable<Result<DeleteError>> results = minioClient.removeObjects(removeObjectsArgs);
        results.forEach(r->{
            DeleteError deleteError = null;
            try {
                deleteError = r.get();
            } catch (Exception e) {
                e.printStackTrace();
            }
        });
    }