public Result<Boolean> checkFile(String fileMd5) {
        //正常做業(yè)務(wù)時應(yīng)該先從數(shù)據(jù)庫中查詢

            //如果數(shù)據(jù)庫存在再查詢 minio
            GetObjectArgs getObjectArgs = GetObjectArgs.builder()
                    .bucket(bucketName)
                    //                    todo 這里固定了文件的后綴，實(shí)際情況下應(yīng)該從數(shù)據(jù)庫開始查詢，得到文件的路徑
                    .object(getFilePathByMd5(fileMd5,"png"))
                    .build();
            //查詢遠(yuǎn)程服務(wù)獲取到一個流對象
            try {
                FilterInputStream inputStream = minioClient.getObject(getObjectArgs);
                if(inputStream!=null){
                    //文件已存在
                    return Result.success(true);
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
        //文件不存在
        return Result.success(false);
        }

 public Result<Boolean> checkChunk(String fileMd5, int chunkIndex) {

        //根據(jù)md5得到分塊文件所在目錄的路徑
        String chunkFileFolderPath = getChunkFileFolderPath(fileMd5);

        //如果數(shù)據(jù)庫存在再查詢 minio
        GetObjectArgs getObjectArgs = GetObjectArgs.builder()
                .bucket(bucketName)
                .object(chunkFileFolderPath+chunkIndex)
                .build();
        //查詢遠(yuǎn)程服務(wù)獲取到一個流對象
        try {
            FilterInputStream inputStream = minioClient.getObject(getObjectArgs);
            if(inputStream!=null){
                //文件已存在
                return Result.success(true);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }

        //文件不存在
        return Result.success(false);
    }

    public Result uploadChunk(String fileMd5, int chunk, String localChunkFilePath) {
        //分塊文件的路徑
        String chunkFilePath = getChunkFileFolderPath(fileMd5) + chunk;
        //獲取mimeType
        String mimeType = localChunkFilePath.substring(localChunkFilePath.lastIndexOf("."));
        //將分塊文件上傳到minio
        boolean b = addMediaFilesToMinIO(localChunkFilePath, mimeType, bucketName, chunkFilePath);
        if(!b){
            return Result.error("上傳分塊文件失敗");
        }
        //上傳成功
        return Result.success(true);
    }

public Result mergechunks(String fileMd5, int chunkTotal) {
        //分塊文件所在目錄
        String chunkFileFolderPath = getChunkFileFolderPath(fileMd5);
        //找到所有的分塊文件
        List<ComposeSource> sources = Stream.iterate(0, i -> ++i)
                .limit(chunkTotal).map(i -> ComposeSource.builder()
                        .bucket(bucketName)
                        .object(chunkFileFolderPath + i).build()).collect(Collectors.toList());


        //合并后文件的objectname
        String objectName = getFilePathByMd5(fileMd5, "png");
        //指定合并后的objectName等信息
        ComposeObjectArgs composeObjectArgs = ComposeObjectArgs.builder()
                .bucket(bucketName)
                .object(objectName)//合并后的文件的objectname
                .sources(sources)//指定源文件
                .build();
        //===========合并文件============
        //報(bào)錯size 1048576 must be greater than 5242880，minio默認(rèn)的分塊文件大小為5M
        try {
            minioClient.composeObject(composeObjectArgs);
        } catch (Exception e) {
            e.printStackTrace();
            log.error("合并文件出錯,bucket:{},objectName:{},錯誤信息:{}",bucketName,objectName,e.getMessage());
            return Result.error("合并文件異常");
        }

        //===========校驗(yàn)合并后的和源文件是否一致，視頻上傳才成功===========
        //先下載合并后的文件
        File file = downloadFileFromMinIO(bucketName, objectName);
        try(FileInputStream fileInputStream = new FileInputStream(file)){
            //計(jì)算合并后文件的md5
            String mergeFile_md5 = DigestUtils.md5Hex(fileInputStream);
            //比較原始md5和合并后文件的md5
            if(!fileMd5.equals(mergeFile_md5)){
                log.error("校驗(yàn)合并文件md5值不一致,原始文件:{},合并文件:{}",fileMd5,mergeFile_md5);
                return Result.error("文件校驗(yàn)失敗");
            }

        }catch (Exception e) {
            return Result.error("文件校驗(yàn)失敗");
        }

        //==============將文件信息入庫============
//        在做業(yè)務(wù)時要將得到的路徑存入數(shù)據(jù)庫
        //==========清理分塊文件=========
        clearChunkFiles(chunkFileFolderPath,chunkTotal);


        return Result.success(true);
    }

    /**
     * 清除分塊文件
     * @param chunkFileFolderPath 分塊文件路徑
     * @param chunkTotal 分塊文件總數(shù)
     */
    private void clearChunkFiles(String chunkFileFolderPath,int chunkTotal){
        Iterable<DeleteObject> objects =  Stream.iterate(0, i -> ++i).limit(chunkTotal).map(i -> new DeleteObject(chunkFileFolderPath+ i)).collect(Collectors.toList());;
        RemoveObjectsArgs removeObjectsArgs = RemoveObjectsArgs.builder().bucket(bucketName).objects(objects).build();
        Iterable<io.minio.Result<DeleteError>> results = minioClient.removeObjects(removeObjectsArgs);
        //要想真正刪除
        results.forEach(f->{
            try {
                DeleteError deleteError = f.get();
            } catch (Exception e) {
                e.printStackTrace();
            }
        });

    }