快捷導(dǎo)航

java拷貝指定目錄下所有內(nèi)容到minIO代碼實(shí)例

更新時(shí)間：2024年01月24日 09:22:17 作者：祺稷

這篇文章主要介紹了java拷貝指定目錄下所有內(nèi)容到minIO代碼實(shí)例,創(chuàng)建桶直接使用工具類先判斷,再創(chuàng)建即可,創(chuàng)建文件夾,需要注意以"/"結(jié)尾,實(shí)際也是在minIO上創(chuàng)建文件,只是作為目錄的表現(xiàn)形式展示,需要的朋友可以參考下

MinIO及java工具類

minIO知識(shí)及java客戶端內(nèi)容詳情見上篇 MinIO的常用操作示例

本文主要記錄把指定目錄下全部?jī)?nèi)容遞歸寫入MinIO中。

創(chuàng)建桶及文件夾

創(chuàng)建桶

直接使用工具類先判斷，再創(chuàng)建即可

創(chuàng)建文件夾

需要注意以“/”結(jié)尾，實(shí)際也是在minIO上創(chuàng)建文件，只是作為目錄的表現(xiàn)形式展示。

代碼如下：

List<AITrainVOutputConfigPO> outList = versionPO.getOutputList();
        String bucketName = null;
        String trainNameVersion = null;
        if (!outList.isEmpty()) {
            bucketName = Constants.AI_TRAIN_BUCKET_NAME;
            if (!minIOUtil.bucketExists(bucketName) && !minIOUtil.makeBucket(bucketName)) {
                return AIPRet.<String>builder().success(false).message("創(chuàng)建桶失?。?).build();
            }
            //以每個(gè)訓(xùn)練每個(gè)版本 創(chuàng)建一個(gè)文件夾 文件夾必須以 / 結(jié)尾
            trainNameVersion = versionPO.getTrainName() + "-" + versionPO.getVersionNo() + "/";
            if (!minIOUtil.listObjects(bucketName, trainNameVersion).iterator().hasNext()
                    && !minIOUtil.mkdir(bucketName, trainNameVersion)) {
                return AIPRet.<String>builder().success(false).message("創(chuàng)建文件夾" + trainNameVersion + "失??！").build();
            }
        }

指定目錄下所有文件拷貝到MinIO

把指定目錄下所有文件及子目錄及其下所有文件拷貝到MinIO上。代碼如下：

調(diào)用代碼：

		for (AITrainVOutputConfigPO out : outList) {
            String outUrl = out.getTrainUrl();
            if (!this.writeFilesToMinIO(outUrl, bucketName, trainNameVersion)) {
                return AIPRet.<String>builder().success(false).message("導(dǎo)出文件目錄" + outUrl + "失?。?).build();
            }
        }

writeFilesToMinIO 寫入MinIO方法注意：這里判斷目錄還是文件，如果是目錄，進(jìn)行遞歸調(diào)用。

/**
     *
     * @param dir 待拷貝的目錄
     * @param bucketName minIO的桶名稱
     * @param path minIO上的路徑名稱
     * @return 寫到minIO是否成功
*/
private boolean writeFilesToMinIO(String dir, String bucketName, String path) {
        boolean flag = true;
        File file = Paths.get(dir).toFile();
        File[] files = file.listFiles();
        try {
            assert files != null;
            for (File f : files) {
                log.info("文件路徑:" + f.getPath());
                log.info("文件名稱:" + f.getName());
                if (f.isDirectory()) {
                    minIOUtil.mkdir(bucketName, path + f.getName() + "/");
                    writeFilesToMinIO(f.getPath(), bucketName, path + f.getName() + "/");
                } else {
                    try (InputStream inputStream = Files.newInputStream(f.toPath())) {
                        minIOUtil.putObject(bucketName, path + f.getName(), inputStream);
                    }
                }
            }
        } catch (Exception ex) {
            flag = false;
            log.error("寫入MinIO異常", ex);
        }
        return flag;
    }

到此這篇關(guān)于java拷貝指定目錄下所有內(nèi)容到minIO代碼實(shí)例的文章就介紹到這了,更多相關(guān)java拷貝內(nèi)容到minIO內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: