MinIO测试的详细步骤

冷不防 2023-10-04 21:44 21阅读 0赞

## **上传文件** ##

MinIO提供多个语言版本SDK的支持，下边找到java版本的文档：

地址：https://docs.min.io/docs/java-client-quickstart-guide.html

最低需求Java 1.8或更高版本:

maven依赖如下：

<table> 
 <tbody> 
 <tr> 
 <td style="background-color:#f5f6f7;border-color:#dee0e3;width:15cm;"> XML <pre>&lt;dependency&gt;
 &lt;groupId&gt;io.minio&lt;/groupId&gt;
 &lt;artifactId&gt;minio&lt;/artifactId&gt;
 &lt;version&gt;8.5.1&lt;/version&gt;
&lt;/dependency&gt;
&lt;dependency&gt;
 &lt;groupId&gt;com.squareup.okhttp3&lt;/groupId&gt;
 &lt;artifactId&gt;okhttp&lt;/artifactId&gt;
 &lt;version&gt;4.8.1&lt;/version&gt;
&lt;/dependency&gt;</pre> </td> 
 </tr> 
 </tbody> 
</table>

在media-service工程添加此依赖。

参数说明：

需要三个参数才能连接到minio服务。

<table> 
 <tbody> 
 <tr> 
 <td style="background-color:#ffffff;border-color:#dee0e3;width:134.8pt;"> 参数 </td> 
 <td style="background-color:#ffffff;border-color:#dee0e3;width:290.4pt;"> 说明 </td> 
 </tr> 
 <tr> 
 <td style="border-color:#dee0e3;vertical-align:top;width:134.8pt;"> Endpoint </td> 
 <td style="vertical-align:top;width:290.4pt;"> 对象存储服务的URL </td> 
 </tr> 
 <tr> 
 <td style="border-color:#dee0e3;vertical-align:top;width:134.8pt;"> Access Key </td> 
 <td style="vertical-align:top;width:290.4pt;"> Access key就像用户ID，可以唯一标识你的账户。 </td> 
 </tr> 
 <tr> 
 <td style="border-color:#dee0e3;vertical-align:top;width:134.8pt;"> Secret Key </td> 
 <td style="vertical-align:top;width:290.4pt;"> Secret key是你账户的密码。 </td> 
 </tr> 
 </tbody> 
</table>

示例代码如下：

<table> 
 <tbody> 
 <tr> 
 <td style="background-color:#f5f6f7;border-color:#dee0e3;width:15cm;"> Java import io.minio.BucketExistsArgs; import io.minio.MakeBucketArgs; import io.minio.MinioClient; import io.minio.UploadObjectArgs; import io.minio.errors.MinioException; import java.io.IOException; import java.security.InvalidKeyException; import java.security.NoSuchAlgorithmException; public class FileUploader { &nbsp; public static void main(String[] args)throws IOException, NoSuchAlgorithmException, InvalidKeyException { &nbsp;&nbsp;&nbsp; try { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // Create a minioClient with the MinIO server playground, its access key and secret key. &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; MinioClient minioClient = &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; MinioClient.builder() &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; .endpoint("https://play.min.io") &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; .credentials("Q3AM3UQ867SPQQA43P2F", "zuf+tfteSlswRu7BJ86wekitnifILbZam1KYY3TG") &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; .build(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // Make 'asiatrip' bucket if not exist. &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; boolean found = &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; minioClient.bucketExists(BucketExistsArgs.builder().bucket("asiatrip").build()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if (!found) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // Make a new bucket called 'asiatrip'. &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; minioClient.makeBucket(MakeBucketArgs.builder().bucket("asiatrip").build()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } else { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("Bucket 'asiatrip' already exists."); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // Upload '/home/user/Photos/asiaphotos.zip' as object name 'asiaphotos-2015.zip' to bucket &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // 'asiatrip'. &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; minioClient.uploadObject( &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; UploadObjectArgs.builder() &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; .bucket("asiatrip") &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; .object("asiaphotos-2015.zip") &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; .filename("/home/user/Photos/asiaphotos.zip") &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; .build()); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println( &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "'/home/user/Photos/asiaphotos.zip' is successfully uploaded as " &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; + "object 'asiaphotos-2015.zip' to bucket 'asiatrip'."); &nbsp;&nbsp;&nbsp; } catch (MinioException e) { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("Error occurred: " + e); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("HTTP trace: " + e.httpTrace()); &nbsp;&nbsp;&nbsp; } &nbsp; } } </td> 
 </tr> 
 </tbody> 
</table>

参考示例在media-service工程中 测试上传文件功能，

首先创建一个用于测试的bucket

![328cc424d30045c89b619f41fe15d92f.png][]

点击“Manage”修改bucket的访问权限

![9a73848969804665bff569b99a8a9dfa.png][]

选择public权限

## 上传文件 ##

测试代码如下：

以下代码都是经过我自己的简化的，简化版，官方给的参考文档里面的东西很多，有很多用不到

<table> 
 <tbody> 
 <tr> 
 <td style="background-color:#f5f6f7;border-color:#dee0e3;width:15cm;"> Java package com.xuecheng.media; import io.minio.BucketExistsArgs; import io.minio.MakeBucketArgs; import io.minio.MinioClient; import io.minio.UploadObjectArgs; import io.minio.errors.MinioException; import java.io.IOException; import java.security.InvalidKeyException; import java.security.NoSuchAlgorithmException; &nbsp; <pre>/**
 * @author Mr.M
 * @version 1.0
 * @description 测试minio上传文件、删除文件、查询文件
 * @date 2023/2/20 14:42
 */
public class MinIOTest {

</pre> <pre>static MinioClient minioClient =
 MinioClient.builder()
//自己服务器地址+端口号
 .endpoint("http://26.252.208.115:9090")
//登录的账户密码
 .credentials("minioadmin", "minioadmin")
 .build();

//上传文件，指定桶内的子目录
@Test
public void upload() {
    try {
        UploadObjectArgs uploadObjectArgs = UploadObjectArgs.builder()
//桶名
                .bucket("mediafiles")
//test：是mediafiles里的文件路径，文件名：Java学习路线.md
                .object("test/Java学习路线.md")
//自己电脑的文件路径，进行上传
                .filename("D:\\Desktop\\code-roadmap-main\\code-roadmap-main\\docs\\roadmap\\Java学习路线.md")
                .build();
        //上传
        minioClient.uploadObject(uploadObjectArgs);
        System.out.println("上传成功了");
    } catch (Exception e) {
        System.out.println("上传失败");
    }

}</pre> } </td> 
 </tr> 
 </tbody> 
</table>

执行main方法，共上传两个文件，1.mp4上传到桶根目录下，1.avi上传到 桶中的avi目录下，avi目录会自动创建。

上传成功，通过web控制台查看文件，并预览文件。

下面就是上传成功了

![c6187d5d9ece49c4a914d5840540ccce.png][]

## **删除文件** ##

下边测试删除文件

参考：https://docs.min.io/docs/java-client-api-reference\#removeObject

<table> 
 <tbody> 
 <tr> 
 <td style="background-color:#f5f6f7;border-color:#dee0e3;width:15cm;"> <pre>//删除文件
@Test
public void delete() {

try {
//查询要删除的文件在哪个桶，然后进行删除文件
        RemoveObjectArgs removeObjectArgs = RemoveObjectArgs.builder().bucket("mediafiles").object("test/Java学习路线.md").build();
        minioClient.removeObject(removeObjectArgs);
    } catch (Exception e) {
    }

}</pre> </td> 
 </tr> 
 </tbody> 
</table>

## **查询文件** ##

通过查询文件查看文件是否存在minio中。

参考：https://docs.min.io/docs/java-client-api-reference\#getObject

<table> 
 <tbody> 
 <tr> 
 <td style="background-color:#f5f6f7;border-color:#dee0e3;width:15cm;"> <pre>//查询文件
@Test
public void getFile() {
//要查询的桶和文件名
 GetObjectArgs getObjectArgs = 
GetObjectArgs.builder().bucket("mediafiles").object("Java学习路线.md").build();
 try (
 FilterInputStream inputStream = minioClient.getObject(getObjectArgs);
//下面路径是输出到自己电脑的位置
 FileOutputStream outputStream = new FileOutputStream(new File("D:\\Desktop\\code-roadmap-main\\code-roadmap-main\\docs\\roadmap\\Java学习路线11.md"));
 ) {

if (inputStream != null) {
            IOUtils.copy(inputStream, outputStream);
        }
    } catch (Exception e) {
    }

}</pre> </td> 
 </tr> 
 </tbody> 
</table>

[328cc424d30045c89b619f41fe15d92f.png]: https://img-blog.csdnimg.cn/328cc424d30045c89b619f41fe15d92f.png
[9a73848969804665bff569b99a8a9dfa.png]: https://img-blog.csdnimg.cn/9a73848969804665bff569b99a8a9dfa.png
[c6187d5d9ece49c4a914d5840540ccce.png]: https://img-blog.csdnimg.cn/c6187d5d9ece49c4a914d5840540ccce.png