SpringBoot-整合minio文件系统实现上传下载和分享文件

搭建minio服务器

这个我在另一篇中有说明，这里不再赘述。

导入相关依赖

<!--必要的依赖 -->
<dependency>
    <groupId>io.minio</groupId>
    <artifactId>minio</artifactId>
    <version>7.0.2</version>
</dependency>
<!--可选的依赖 -->
<dependency>
    <groupId>org.apache.commons</groupId>
    <artifactId>commons-lang3</artifactId>
    <version>3.4</version>
</dependency>

必要的配置

文件上传配置

spring:
  servlet:
    multipart:
      max-file-size: 5MB
      max-request-size: 5MB

Configruation配置

/**
 * Minio配置
 *
 * @author Cikaros QQ：1032325640
 * @date 2020/10/29 17:18
 */
@Data
@Configuration
@ConfigurationProperties(prefix = "minio")//这里的参数请在yml文件中配置出来
public class MinioConfig {

    @ApiModelProperty("endPoint是一个URL，域名，IPv4或者IPv6地址")
    private String endpoint;

    @ApiModelProperty("TCP/IP端口号")
    private int port;

    @ApiModelProperty("accessKey类似于用户ID，用于唯一标识你的账户")
    private String accessKey;

    @ApiModelProperty("secretKey是你账户的密码")
    private String secretKey;

    @ApiModelProperty("如果是true，则用的是https而不是http,默认值是true")
    private Boolean secure;

    @Bean
    public MinioClient getMinioClient() throws InvalidEndpointException, InvalidPortException {
        MinioClient minioClient = new MinioClient(endpoint, port, accessKey, secretKey, secure);
        return minioClient;
    }

}

然后就可以用MinioClient这个类来操作Minio了，下面附上API文档，Copy过来的，不是原创！！！

Java Client API参考文档

初始化Minio Client object。

MinIO

MinioClient minioClient = new MinioClient("https://play.min.io", "Q3AM3UQ867SPQQA43P2F", "zuf+tfteSlswRu7BJ86wekitnifILbZam1KYY3TG");

AWS S3

MinioClient s3Client = new MinioClient("https://s3.amazonaws.com", "YOUR-ACCESSKEYID", "YOUR-SECRETACCESSKEY");

存储桶操作	文件对象操作	Presigned操作	存储桶策略
`makeBucket`	`getObject`	`presignedGetObject`	`getBucketPolicy`
`listBuckets`	`putObject`	`presignedPutObject`	`setBucketPolicy`
`bucketExists`	`copyObject`	`presignedPostPolicy`
`removeBucket`	`statObject`
`listObjects`	`removeObject`
`listIncompleteUploads`	`removeIncompleteUpload`

1. 构造函数


`public MinioClient(String endpoint) throws NullPointerException, InvalidEndpointException, InvalidPortException`
使用给定的endpoint以及匿名方式创建一个Minio client对象。
查看 Javadoc


`public MinioClient(URL url) throws NullPointerException, InvalidEndpointException, InvalidPortException`
使用给定的url以及匿名方式创建一个Minio client对象。
查看 Javadoc


`public MinioClient(com.squareup.okhttp.HttpUrl url) throws NullPointerException, InvalidEndpointException, InvalidPortException`
使用给定的HttpUrl以及匿名方式创建一个Minio client对象。
查看 Javadoc


`public MinioClient(String endpoint, String accessKey, String secretKey) throws NullPointerException, InvalidEndpointException, InvalidPortException`
使用给定的endpoint、access key和secret key创建一个Minio client对象。
查看 Javadoc


`public MinioClient(String endpoint, int port, String accessKey, String secretKey) throws NullPointerException, InvalidEndpointException, InvalidPortException`
使用给定的endpoint、port、access key和secret key创建一个Minio client对象。
查看 Javadoc


`public MinioClient(String endpoint, String accessKey, String secretKey, boolean secure) throws NullPointerException, InvalidEndpointException, InvalidPortException`
使用给定的endpoint、access key、secret key和一个secure选项（是否使用https）创建一个Minio client对象。
查看 Javadoc


`public MinioClient(String endpoint, int port, String accessKey, String secretKey, boolean secure) throws NullPointerException, InvalidEndpointException, InvalidPortException`
使用给定的endpoint、port、access key、secret key和一个secure选项（是否使用https）创建一个Minio client对象。
查看 Javadoc


`public MinioClient(com.squareup.okhttp.HttpUrl url, String accessKey, String secretKey) throws NullPointerException, InvalidEndpointException, InvalidPortException`
使用给定的HttpUrl对象、access key、secret key创建一个Minio client对象。
查看 Javadoc


`public MinioClient(URL url, String accessKey, String secretKey) throws NullPointerException, InvalidEndpointException, InvalidPortException`
使用给定的URL对象、access key、secret key创建一个Minio client对象。
查看 Javadoc

参数

参数	类型	描述
`endpoint`	string	endPoint是一个URL，域名，IPv4或者IPv6地址。以下是合法的endpoints:
		https://s3.amazonaws.com
		https://play.min.io
		localhost
		play.min.io
`port`	int	TCP/IP端口号。可选，默认值是，如果是http,则默认80端口，如果是https,则默认是443端口。
`accessKey`	string	accessKey类似于用户ID，用于唯一标识你的账户。
`secretKey`	string	secretKey是你账户的密码。
`secure`	boolean	如果是true，则用的是https而不是http,默认值是true。
`url`	URL	Endpoint URL对象。
`url`	HttpURL	Endpoint HttpUrl对象。

示例

MinIO

// 1. public MinioClient(String endpoint)
MinioClient minioClient = new MinioClient("https://play.min.io");

// 2. public MinioClient(URL url)
MinioClient minioClient = new MinioClient(new URL("https://play.min.io"));

// 3. public MinioClient(com.squareup.okhttp.HttpUrl url)
 MinioClient minioClient = new MinioClient(new HttpUrl.parse("https://play.min.io"));

// 4. public MinioClient(String endpoint, String accessKey, String secretKey)
MinioClient minioClient = new MinioClient("https://play.min.io", "Q3AM3UQ867SPQQA43P2F", "zuf+tfteSlswRu7BJ86wekitnifILbZam1KYY3TG");

// 5. public MinioClient(String endpoint, int port,  String accessKey, String secretKey)
MinioClient minioClient = new MinioClient("https://play.min.io", 9000, "Q3AM3UQ867SPQQA43P2F", "zuf+tfteSlswRu7BJ86wekitnifILbZam1KYY3TG");

// 6. public MinioClient(String endpoint, String accessKey, String secretKey, boolean insecure)
MinioClient minioClient = new MinioClient("https://play.min.io", "Q3AM3UQ867SPQQA43P2F", "zuf+tfteSlswRu7BJ86wekitnifILbZam1KYY3TG", true);

// 7. public MinioClient(String endpoint, int port,  String accessKey, String secretKey, boolean insecure)
MinioClient minioClient = new MinioClient("https://play.min.io", 9000, "Q3AM3UQ867SPQQA43P2F", "zuf+tfteSlswRu7BJ86wekitnifILbZam1KYY3TG", true);

// 8. public MinioClient(com.squareup.okhttp.HttpUrl url, String accessKey, String secretKey)
 MinioClient minioClient = new MinioClient(new URL("https://play.min.io"), "Q3AM3UQ867SPQQA43P2F", "zuf+tfteSlswRu7BJ86wekitnifILbZam1KYY3TG");

// 9. public MinioClient(URL url, String accessKey, String secretKey)
MinioClient minioClient = new MinioClient(HttpUrl.parse("https://play.min.io"), "Q3AM3UQ867SPQQA43P2F", "zuf+tfteSlswRu7BJ86wekitnifILbZam1KYY3TG");

AWS S3

// 1. public MinioClient(String endpoint)
MinioClient s3Client = new MinioClient("https://s3.amazonaws.com");

// 2. public MinioClient(URL url)
MinioClient minioClient = new MinioClient(new URL("https://s3.amazonaws.com"));

// 3. public MinioClient(com.squareup.okhttp.HttpUrl url)
 MinioClient s3Client = new MinioClient(new HttpUrl.parse("https://s3.amazonaws.com"));

// 4. public MinioClient(String endpoint, String accessKey, String secretKey)
MinioClient s3Client = new MinioClient("s3.amazonaws.com", "YOUR-ACCESSKEYID", "YOUR-SECRETACCESSKEY");

// 5. public MinioClient(String endpoint, int port,  String accessKey, String secretKey)
MinioClient s3Client = new MinioClient("s3.amazonaws.com", 80, "YOUR-ACCESSKEYID", "YOUR-SECRETACCESSKEY");

// 6. public MinioClient(String endpoint, String accessKey, String secretKey, boolean insecure)
MinioClient s3Client = new MinioClient("s3.amazonaws.com", "YOUR-ACCESSKEYID", "YOUR-SECRETACCESSKEY", false);

// 7. public MinioClient(String endpoint, int port,  String accessKey, String secretKey, boolean insecure)
MinioClient s3Client = new MinioClient("s3.amazonaws.com", 80, "YOUR-ACCESSKEYID", "YOUR-SECRETACCESSKEY",false);

// 8. public MinioClient(com.squareup.okhttp.HttpUrl url, String accessKey, String secretKey)
 MinioClient s3Client = new MinioClient(new URL("s3.amazonaws.com"), "YOUR-ACCESSKEYID", "YOUR-SECRETACCESSKEY");

// 9. public MinioClient(URL url, String accessKey, String secretKey)
MinioClient s3Client = new MinioClient(HttpUrl.parse("s3.amazonaws.com"), "YOUR-ACCESSKEYID", "YOUR-SECRETACCESSKEY");

2. 存储桶操作

makeBucket(String bucketName)

public void makeBucket(String bucketName);

创建一个新的存储桶

查看Javadoc

参数

参数	类型	描述
`bucketName`	String	存储桶名称

返回值类型	异常
`None`	异常列表:
	`InvalidBucketNameException` : 非法的存储桶名称。
	`NoResponseException` : 服务器无响应。
	`IOException` : 连接异常
	`org.xmlpull.v1.XmlPullParserException` : 解析返回的XML异常
	`ErrorResponseException` : 执行失败
	`InternalException` : 内部异常

示例

try {
  // 如存储桶不存在，创建之。
  boolean found = minioClient.bucketExists("mybucket");
  if (found) {
    System.out.println("mybucket already exists");
  } else {
    // 创建名为'my-bucketname'的存储桶。
    minioClient.makeBucket("mybucket");
    System.out.println("mybucket is created successfully");
  }
} catch (MinioException e) {
  System.out.println("Error occurred: " + e);
}

listBuckets()

public List<Bucket> listBuckets()

列出所有存储桶。

查看Javadoc

返回值类型	异常
`List Bucket` : List of bucket type.	异常列表：
	`NoResponseException` : 服务端无响应
	`IOException` : 连接异常
	`org.xmlpull.v1.XmlPullParserException` : 解析返回的XML异常
	`ErrorResponseException` :执行失败异溃
	`InternalException` : 内部错误

示例

try {
  // 列出所有存储桶
  List<Bucket> bucketList = minioClient.listBuckets();
  for (Bucket bucket : bucketList) {
    System.out.println(bucket.creationDate() + ", " + bucket.name());
  }
} catch (MinioException e) {
  System.out.println("Error occurred: " + e);
}

bucketExists(String bucketName)

public boolean bucketExists(String bucketName)

检查存储桶是否存在。

查看 Javadoc

参数

参数	类型	描述
`bucketName`	String	存储桶名称

返回值值类型	异常
`boolean`: true if the bucket exists	异常列表：
	`InvalidBucketNameException` : 不合法的存储桶名称。
	`NoResponseException` : 服务器无响应。
	`IOException` : 连接异常。
	`org.xmlpull.v1.XmlPullParserException` : 解析返回的XML异常。
	`ErrorResponseException` : 执行失败异常。
	`InternalException` : 内部错误。

示例

try {
  // 检查'my-bucketname'是否存在。
  boolean found = minioClient.bucketExists("mybucket");
  if (found) {
    System.out.println("mybucket exists");
  } else {
    System.out.println("mybucket does not exist");
  }
} catch (MinioException e) {
  System.out.println("Error occurred: " + e);
}

removeBucket(String bucketName)

public void removeBucket(String bucketName)

删除一个存储桶。

查看 Javadoc

注意: - removeBucket不会删除存储桶里的对象，你需要通过removeObject API来删除它们。

参数

参数	类型	描述
`bucketName`	String	存储桶名称。

返回值类型	异常
None	异常列表：
	`InvalidBucketNameException` : 不合法的存储桶名称。
	`NoResponseException` : 服务器无响应。
	`IOException` : 连接异常。
	`org.xmlpull.v1.XmlPullParserException` : 解析返回的XML异常。
	`ErrorResponseException` : 执行失败异常。
	`InternalException` : 内部错误。

示例

try {
  // 删除之前先检查`my-bucket`是否存在。
  boolean found = minioClient.bucketExists("mybucket");
  if (found) {
    // 删除`my-bucketname`存储桶，注意，只有存储桶为空时才能删除成功。
    minioClient.removeBucket("mybucket");
    System.out.println("mybucket is removed successfully");
  } else {
    System.out.println("mybucket does not exist");
  }
} catch(MinioException e) {
  System.out.println("Error occurred: " + e);
}

listObjects(String bucketName, String prefix, boolean recursive, boolean useVersion1)

public Iterable<Result<Item>> listObjects(String bucketName, String prefix, boolean recursive, boolean useVersion1)

列出某个存储桶中的所有对象。

查看Javadoc

参数

参数	类型	描述
`bucketName`	String	存储桶名称。
`prefix`	String	对象名称的前缀
`recursive`	boolean	是否递归查找，如果是false,就模拟文件夹结构查找。
`useVersion1`	boolean	如果是true, 使用版本1 REST API

返回值类型	异常
`Iterable<Result<Item>>`:an iterator of Result Items.	None

示例

try {
  // 检查'mybucket'是否存在。
  boolean found = minioClient.bucketExists("mybucket");
  if (found) {
    // 列出'my-bucketname'里的对象
    Iterable<Result<Item>> myObjects = minioClient.listObjects("mybucket");
    for (Result<Item> result : myObjects) {
      Item item = result.get();
      System.out.println(item.lastModified() + ", " + item.size() + ", " + item.objectName());
    }
  } else {
    System.out.println("mybucket does not exist");
  }
} catch (MinioException e) {
  System.out.println("Error occurred: " + e);
}

listIncompleteUploads(String bucketName, String prefix, boolean recursive)

public Iterable<Result<Upload>> listIncompleteUploads(String bucketName, String prefix, boolean recursive)

列出存储桶中被部分上传的对象。

查看 Javadoc

参数

参数	类型	描述
`bucketName`	String	存储桶名称。
`prefix`	String	对象名称的前缀，列出有该前缀的对象
`recursive`	boolean	是否递归查找，如果是false,就模拟文件夹结构查找。

返回值类型	异常
`Iterable<Result<Upload>>`: an iterator of Upload.	None

示例

try {
  // 检查'mybucket'是否存在。
  boolean found = minioClient.bucketExists("mybucket");
  if (found) {
    // 列出'mybucket'中所有未完成的multipart上传的的对象。 
    Iterable<Result<Upload>> myObjects = minioClient.listIncompleteUploads("mybucket");
    for (Result<Upload> result : myObjects) {
      Upload upload = result.get();
      System.out.println(upload.uploadId() + ", " + upload.objectName());
    }
  } else {
    System.out.println("mybucket does not exist");
  }
} catch (MinioException e) {
  System.out.println("Error occurred: " + e);
}

getBucketPolicy(String bucketName, String objectPrefix)

public PolicyType getBucketPolicy(String bucketName, String objectPrefix)

获得指定对象前缀的存储桶策略。

查看 Javadoc

参数

参数	类型	描述
`bucketName`	String	存储桶名称。
`objectPrefix`	String	策略适用的对象的前缀

返回值类型	异常
`PolicyType`: The current bucket policy type for a given bucket and objectPrefix.	异常列表：
	`InvalidBucketNameException` : 不合法的存储桶名称。
	`NoResponseException` : 服务器无响应。
	`IOException` : 连接异常。
	`org.xmlpull.v1.XmlPullParserException` : 解析返回的XML异常。
	`ErrorResponseException` : 执行失败异常。
	`InternalException` : 内部错误。
	`InvalidBucketNameException` : 不合法的存储桶名称。
	`InvalidObjectPrefixException` : 不合法的对象前缀
	`NoSuchAlgorithmException` : 找不到相应的签名算法。
	`InsufficientDataException` : 在读到相应length之前就得到一个EOFException。

示例

try {
  System.out.println("Current policy: " + minioClient.getBucketPolicy("myBucket", "downloads"));
} catch (MinioException e) {
  System.out.println("Error occurred: " + e);
}

setBucketPolicy(String bucketName, String objectPrefix, PolicyType policy)

public void setBucketPolicy(String bucketName, String objectPrefix, PolicyType policy)

给一个存储桶+对象前缀设置策略。

查看 Javadoc

参数

参数	类型	描述
`bucketName`	String	存储桶名称。
`objectPrefix`	String	对象前缀。
`policy`	PolicyType	要赋予的策略，可选值有[PolicyType.NONE, PolicyType.READ_ONLY, PolicyType.READ_WRITE, PolicyType.WRITE_ONLY].

返回值类型	异常
None	异常列表：
	`InvalidBucketNameException` : 不合法的存储桶名称。
	`NoResponseException` : 服务器无响应。
	`IOException` : 连接异常。
	`org.xmlpull.v1.XmlPullParserException` : 解析返回的XML异常。
	`ErrorResponseException` : 执行失败异常。
	`InternalException` : 内部错误。
	`InvalidBucketNameException` : 不合法的存储桶名称。
	`InvalidObjectPrefixException` : 不合法的对象前缀
	`NoSuchAlgorithmException` : 找不到相应的签名算法。
	`InsufficientDataException` : 在读到相应length之前就得到一个EOFException。

示例

try {
  minioClient.setBucketPolicy("myBucket", "uploads", PolicyType.READ_ONLY);
} catch (MinioException e) {
  System.out.println("Error occurred: " + e);
}

3. Object operations

getObject(String bucketName, String objectName)

public InputStream getObject(String bucketName, String objectName, long offset)

以流的形式下载一个对象。

查看 Javadoc

参数

参数	类型	描述
`bucketName`	String	存储桶名称。
`objectName`	String	存储桶里的对象名称。

返回值类型	异常
`InputStream`: InputStream containing the object data.	异常列表：
	`InvalidBucketNameException` : 不合法的存储桶名称。
	`NoResponseException` : 服务器无响应。
	`IOException` : 连接异常。
	`org.xmlpull.v1.XmlPullParserException` : 解析返回的XML异常。
	`ErrorResponseException` : 执行失败异常。
	`InternalException` : 内部错误。

示例

try {
  // 调用statObject()来判断对象是否存在。
  // 如果不存在, statObject()抛出异常,
  // 否则则代表对象存在。
  minioClient.statObject("mybucket", "myobject");

  // 获取"myobject"的输入流。
  InputStream stream = minioClient.getObject("mybucket", "myobject");

  // 读取输入流直到EOF并打印到控制台。
  byte[] buf = new byte[16384];
  int bytesRead;
  while ((bytesRead = stream.read(buf, 0, buf.length)) >= 0) {
    System.out.println(new String(buf, 0, bytesRead));
  }

  // 关闭流，此处为示例，流关闭最好放在finally块。
  stream.close();
} catch (MinioException e) {
  System.out.println("Error occurred: " + e);
}

getObject(String bucketName, String objectName, long offset, Long length)

public InputStream getObject(String bucketName, String objectName, long offset, Long length)

下载对象指定区域的字节数组做为流。（断点下载）

查看 Javadoc

参数

参数	类型	描述
`bucketName`	String	存储桶名称。
`objectName`	String	存储桶里的对象名称。
`offset`	Long	`offset` 是起始字节的位置
`length`	Long	`length`是要读取的长度 (可选，如果无值则代表读到文件结尾)。

返回值类型	异常
`InputStream` : InputStream containing the object’s data.	异常列表：
	`InvalidBucketNameException` : 不合法的存储桶名称。
	`NoResponseException` : 服务器无响应。
	`IOException` : 连接异常。
	`org.xmlpull.v1.XmlPullParserException` : 解析返回的XML异常。
	`ErrorResponseException` : 执行失败异常。
	`InternalException` : 内部错误。

示例

try {

  // 调用statObject()来判断对象是否存在。
  // 如果不存在, statObject()抛出异常,
  // 否则则代表对象存在。
  minioClient.statObject("mybucket", "myobject");

  // 获取指定offset和length的"myobject"的输入流。
  InputStream stream = minioClient.getObject("mybucket", "myobject", 1024L, 4096L);

  // 读取输入流直到EOF并打印到控制台。
  byte[] buf = new byte[16384];
  int bytesRead;
  while ((bytesRead = stream.read(buf, 0, buf.length)) >= 0) {
    System.out.println(new String(buf, 0, bytesRead));
  }

  // 关闭流。
  stream.close();
} catch (MinioException e) {
  System.out.println("Error occurred: " + e);
}

getObject(String bucketName, String objectName, String fileName)

public void getObject(String bucketName, String objectName, String fileName)

下载并将文件保存到本地。

查看 Javadoc

参数

参数	类型	描述
`bucketName`	String	存储桶名称。
`objectName`	String	存储桶里的对象名称。
`fileName`	String	File name.

返回值类型	异常
None	异常列表：
	`InvalidBucketNameException` : 不合法的存储桶名称。
	`NoResponseException` : 服务器无响应。
	`IOException` : 连接异常。
	`org.xmlpull.v1.XmlPullParserException` : 解析返回的XML异常。
	`ErrorResponseException` : 执行失败异常。
	`InternalException` : 内部错误。

示例

try {
  // 调用statObject()来判断对象是否存在。
  // 如果不存在, statObject()抛出异常,
  // 否则则代表对象存在。
  minioClient.statObject("mybucket", "myobject");

  // 获取myobject的流并保存到photo.jpg文件中。
  minioClient.getObject("mybucket", "myobject", "photo.jpg");

} catch (MinioException e) {
  System.out.println("Error occurred: " + e);
}

getObject(String bucketName, String objectName, SecretKey key)

public CipherInputStream getObject(String bucketName, String objectName, SecretKey key)

在给定的存储桶中获取整个加密对象的数据作为InputStream，然后用传入的master key解密和加密对象关联的content key。然后创建一个含有InputStream和Cipher的CipherInputStream。这个Cipher被初始为用于使用content key进行解密，所以CipherInputStream会在返回数据前，尝试读取数据并进行解密。所以read()方法返回的是处理过的原始对象数据。

CipherInputStream必须用完关闭，否则连接不会被释放。

查看 Javadoc

参数

参数	类型	描述
`bucketName`	String	存储桶名称。
`objectName`	String	存储桶里的对象名称。
`key`	SecretKey	SecretKey类型的数据。

返回值类型	异常
None	异常列表：
	`InvalidBucketNameException` : 不合法的存储桶名称。
	`NoResponseException` : 服务器无响应。
	`IOException` : 连接异常。
	`org.xmlpull.v1.XmlPullParserException` : 解析返回的XML异常。
	`ErrorResponseException` : 执行失败异常。
	`InternalException` : 内部错误。
	`InvalidEncryptionMetadataException` : 加密秘钥错误。
	`BadPaddingException` : 错误的padding
	`IllegalBlockSizeException` : 不正确的block size
	`NoSuchPaddingException` : 错误的pading类型
	`InvalidAlgorithmParameterException` : 该算法不存在

示例

try {
  // 调用statObject()来判断对象是否存在。
  // 如果不存在, statObject()抛出异常,
  // 否则则代表对象存在。
  minioClient.statObject("mybucket", "myobject");

  //生成256位AES key。
  KeyGenerator symKeyGenerator = KeyGenerator.getInstance("AES");
  symKeyGenerator.init(256);
  SecretKey symKey = symKeyGenerator.generateKey();

  // 获取对象数据并保存到photo.jpg
  InputStream stream = minioClient.getObject("testbucket", "my-objectname", symKey);

  // 读流到EOF，并输出到控制台。
  byte[] buf = new byte[16384];
  int bytesRead;
  while ((bytesRead = stream.read(buf, 0, buf.length)) >= 0) {
    System.out.println(new String(buf, 0, bytesRead, StandardCharsets.UTF_8));
  }

  // 关闭流。
  stream.close();

} catch (MinioException e) {
  System.out.println("Error occurred: " + e);
}

getObject(String bucketName, String objectName, KeyPair key)

public InputStream getObject(String bucketName, String objectName, KeyPair key)

在给定的存储桶中获取整个加密对象的数据作为InputStream，然后用传入的master keyPair解密和加密对象关联的content key。然后创建一个含有InputStream和Cipher的CipherInputStream。这个Cipher被初始为用于使用content key进行解密，所以CipherInputStream会在返回数据前，尝试读取数据并进行解密。所以read()方法返回的是处理过的原始对象数据。

CipherInputStream必须用完关闭，否则连接不会被释放。

查看 Javadoc

参数

参数	类型	描述
`bucketName`	String	存储桶名称。
`objectName`	String	存储桶里的对象名称。
`key`	KeyPair	RSA KeyPair类型的对象。

返回值类型	异常
None	异常列表：
	`InvalidBucketNameException` : 不合法的存储桶名称。
	`NoResponseException` : 服务器无响应。
	`IOException` : 连接异常。
	`org.xmlpull.v1.XmlPullParserException` : 解析返回的XML异常。
	`ErrorResponseException` : 执行失败异常。
	`InternalException` : 内部错误。
	`InvalidEncryptionMetadataException` : 加密秘钥错误。
	`BadPaddingException` : 错误的padding
	`IllegalBlockSizeException` : 不正确的block size
	`NoSuchPaddingException` : 错误的pading类型
	`InvalidAlgorithmParameterException` : 该算法不存在

示例

try {
  // 调用statObject()来判断对象是否存在。
  // 如果不存在, statObject()抛出异常,
  // 否则则代表对象存在。
  minioClient.statObject("mybucket", "myobject");

  KeyPairGenerator keyGenerator = KeyPairGenerator.getInstance("RSA");
  keyGenerator.initialize(1024, new SecureRandom());
  KeyPair keypair = keyGenerator.generateKeyPair();

  // 获取对象数据并保存到photo.jpg
  InputStream stream = minioClient.getObject("testbucket", "my-objectname", keypair);

  // 读流到EOF，并输出到控制台。
  byte[] buf = new byte[16384];
  int bytesRead;
  while ((bytesRead = stream.read(buf, 0, buf.length)) >= 0) {
    System.out.println(new String(buf, 0, bytesRead, StandardCharsets.UTF_8));
  }

  // 关闭流。
  stream.close();

} catch (MinioException e) {
  System.out.println("Error occurred: " + e);
}

putObject(String bucketName, String objectName, InputStream stream, long size, String contentType)

public void putObject(String bucketName, String objectName, InputStream stream, long size, String contentType)

通过InputStream上传对象。

查看 Javadoc

参数

参数	类型	描述
`bucketName`	String	存储桶名称。
`objectName`	String	存储桶里的对象名称。
`stream`	InputStream	要上传的流。
`size`	long	要上传的`stream`的size
`contentType`	String	Content type。

返回值类型	异常
None	异常列表：
	`InvalidBucketNameException` : 不合法的存储桶名称。
	`NoResponseException` : 服务器无响应。
	`IOException` : 连接异常。
	`org.xmlpull.v1.XmlPullParserException` : 解析返回的XML异常。
	`ErrorResponseException` : 执行失败异常。
	`InternalException` : 内部错误。

示例

单个对象的最大大小限制在5TB。putObject在对象大于5MiB时，自动使用multiple parts方式上传。这样，当上传失败时，客户端只需要上传未成功的部分即可（类似断点上传）。上传的对象使用MD5SUM签名进行完整性验证。

try {
  StringBuilder builder = new StringBuilder();
  for (int i = 0; i < 1000; i++) {
    builder.append("Sphinx of black quartz, judge my vow: Used by Adobe InDesign to display font samples. ");
    builder.append("(29 letters)\n");
    builder.append("Jackdaws love my big sphinx of quartz: Similarly, used by Windows XP for some fonts. ");
    builder.append("(31 letters)\n");
    builder.append("Pack my box with five dozen liquor jugs: According to Wikipedia, this one is used on ");
    builder.append("NASAs Space Shuttle. (32 letters)\n");
    builder.append("The quick onyx goblin jumps over the lazy dwarf: Flavor text from an Unhinged Magic Card. ");
    builder.append("(39 letters)\n");
    builder.append("How razorback-jumping frogs can level six piqued gymnasts!: Not going to win any brevity ");
    builder.append("awards at 49 letters long, but old-time Mac users may recognize it.\n");
    builder.append("Cozy lummox gives smart squid who asks for job pen: A 41-letter tester sentence for Mac ");
    builder.append("computers after System 7.\n");
    builder.append("A few others we like: Amazingly few discotheques provide jukeboxes; Now fax quiz Jack! my ");
    builder.append("brave ghost pled; Watch Jeopardy!, Alex Trebeks fun TV quiz game.\n");
    builder.append("- --\n");
  }
  ByteArrayInputStream bais = new
  ByteArrayInputStream(builder.toString().getBytes("UTF-8"));
  // 创建对象
  minioClient.putObject("mybucket", "myobject", bais, bais.available(), "application/octet-stream");
  bais.close();
  System.out.println("myobject is uploaded successfully");
} catch(MinioException e) {
  System.out.println("Error occurred: " + e);
}

putObject(String bucketName, String objectName, String fileName)

public void putObject(String bucketName, String objectName, String fileName)

通过文件上传到对象中。
查看 Javadoc

参数

参数	类型	描述
`bucketName`	String	存储桶名称。
`objectName`	String	存储桶里的对象名称。
`fileName`	String	File name.

返回值类型	异常
None	异常列表：
	`InvalidBucketNameException` : 不合法的存储桶名称。
	`NoResponseException` : 服务器无响应。
	`IOException` : 连接异常。
	`org.xmlpull.v1.XmlPullParserException` : 解析返回的XML异常。
	`ErrorResponseException` : 执行失败异常。
	`InternalException` : 内部错误。

示例

try {
  minioClient.putObject("mybucket",  "island.jpg", "/mnt/photos/island.jpg")
  System.out.println("island.jpg is uploaded successfully");
} catch(MinioException e) {
  System.out.println("Error occurred: " + e);
}

putObject(String bucketName, String objectName, InputStream stream, long size, String contentType, SecretKey key)

public void putObject(String bucketName, String objectName, InputStream stream, long size, String contentType, SecretKey key)

拿到流的数据，使用随机生成的content key进行加密，并上传到指定存储桶中。同时将加密后的content key和iv做为加密对象有header也上传到存储桶中。content key使用传入到该方法的master key进行加密。

如果对象大于5MB,客户端会自动进行multi part上传。

查看 Javadoc

参数

参数	类型	描述
`bucketName`	String	存储桶名称。
`objectName`	String	存储桶里的对象名称。
`stream`	InputStream	要上传的流。
`size`	long	要上传的流的大小。
`contentType`	String	Content type。
`key`	SecretKey	用AES初使化的对象SecretKey。

返回值类型	异常
None	异常列表：
	`InvalidBucketNameException` : 不合法的存储桶名称。
	`NoResponseException` : 服务器无响应。
	`IOException` : 连接异常。
	`org.xmlpull.v1.XmlPullParserException` : 解析返回的XML异常。
	`ErrorResponseException` : 执行失败异常。
	`InternalException` : 内部错误。
	`InvalidAlgorithmParameterException` : 错误的加密算法。
	`BadPaddingException` : 不正确的padding.
	`IllegalBlockSizeException` : 不正确的block。
	`NoSuchPaddingException` : 错误的padding类型。

示例

对象使用随机生成的key进行加密，然后这个用于加密数据的key又被由仅被client知道的master key(封装在encryptionMaterials对象里)进行加密。这个被加密后的key和IV做为对象的header和加密后的对象一起被上传到存储服务上。

try {
  StringBuilder builder = new StringBuilder();
  for (int i = 0; i < 1000; i++) {
    builder.append("Sphinx of black quartz, judge my vow: Used by Adobe InDesign to display font samples. ");
    builder.append("(29 letters)\n");
    builder.append("Jackdaws love my big sphinx of quartz: Similarly, used by Windows XP for some fonts. ");
    builder.append("(31 letters)\n");
    builder.append("Pack my box with five dozen liquor jugs: According to Wikipedia, this one is used on ");
    builder.append("NASAs Space Shuttle. (32 letters)\n");
    builder.append("The quick onyx goblin jumps over the lazy dwarf: Flavor text from an Unhinged Magic Card. ");
    builder.append("(39 letters)\n");
    builder.append("How razorback-jumping frogs can level six piqued gymnasts!: Not going to win any brevity ");
    builder.append("awards at 49 letters long, but old-time Mac users may recognize it.\n");
    builder.append("Cozy lummox gives smart squid who asks for job pen: A 41-letter tester sentence for Mac ");
    builder.append("computers after System 7.\n");
    builder.append("A few others we like: Amazingly few discotheques provide jukeboxes; Now fax quiz Jack! my ");
    builder.append("brave ghost pled; Watch Jeopardy!, Alex Trebeks fun TV quiz game.\n");
    builder.append("- --\n");
  }
  ByteArrayInputStream bais = new
  ByteArrayInputStream(builder.toString().getBytes("UTF-8"));

  //生成256位AES key.
  KeyGenerator symKeyGenerator = KeyGenerator.getInstance("AES");
  symKeyGenerator.init(256);
  SecretKey symKey = symKeyGenerator.generateKey();

  // 创建一个对象
  minioClient.putObject("mybucket", "myobject", bais, bais.available(), "application/octet-stream", symKey);
  bais.close();
  System.out.println("myobject is uploaded successfully");
} catch(MinioException e) {
  System.out.println("Error occurred: " + e);
}

putObject(String bucketName, String objectName, InputStream stream, long size, String contentType, KeyPair key)

public void putObject(String bucketName, String objectName, InputStream stream, long size, String contentType, KeyPair key)

如果对象大于5MB,客户端会自动进行multi part上传。

查看 Javadoc

参数

参数	类型	描述
`bucketName`	String	存储桶名称。
`objectName`	String	存储桶里的对象名称。
`stream`	InputStream	要上传的流。
`size`	long	要上传的流的大小。
`contentType`	String	Content type。
`key`	KeyPair	一个RSA KeyPair的对象。

返回值类型	异常
None	异常列表：
	`InvalidBucketNameException` : 不合法的存储桶名称。
	`NoResponseException` : 服务器无响应。
	`IOException` : 连接异常。
	`org.xmlpull.v1.XmlPullParserException` : 解析返回的XML异常。
	`ErrorResponseException` : 执行失败异常。
	`InternalException` : 内部错误。
	`InvalidAlgorithmParameterException` : 错误的加密算法。
	`BadPaddingException` : 不正确的padding。
	`IllegalBlockSizeException` : 不正确的block。
	`NoSuchPaddingException` : 错误的pading类型。

示例

try {
  StringBuilder builder = new StringBuilder();
  for (int i = 0; i < 1000; i++) {
    builder.append("Sphinx of black quartz, judge my vow: Used by Adobe InDesign to display font samples. ");
    builder.append("(29 letters)\n");
    builder.append("Jackdaws love my big sphinx of quartz: Similarly, used by Windows XP for some fonts. ");
    builder.append("(31 letters)\n");
    builder.append("Pack my box with five dozen liquor jugs: According to Wikipedia, this one is used on ");
    builder.append("NASAs Space Shuttle. (32 letters)\n");
    builder.append("The quick onyx goblin jumps over the lazy dwarf: Flavor text from an Unhinged Magic Card. ");
    builder.append("(39 letters)\n");
    builder.append("How razorback-jumping frogs can level six piqued gymnasts!: Not going to win any brevity ");
    builder.append("awards at 49 letters long, but old-time Mac users may recognize it.\n");
    builder.append("Cozy lummox gives smart squid who asks for job pen: A 41-letter tester sentence for Mac ");
    builder.append("computers after System 7.\n");
    builder.append("A few others we like: Amazingly few discotheques provide jukeboxes; Now fax quiz Jack! my ");
    builder.append("brave ghost pled; Watch Jeopardy!, Alex Trebeks fun TV quiz game.\n");
    builder.append("- --\n");
  }
  ByteArrayInputStream bais = new
  ByteArrayInputStream(builder.toString().getBytes("UTF-8"));

  KeyPairGenerator keyGenerator = KeyPairGenerator.getInstance("RSA");
  keyGenerator.initialize(1024, new SecureRandom());
  KeyPair keypair = keyGenerator.generateKeyPair();

  // Create an object
  minioClient.putObject("mybucket", "myobject", bais, bais.available(), "application/octet-stream", keypair);
  bais.close();
  System.out.println("myobject is uploaded successfully");
} catch(MinioException e) {
  System.out.println("Error occurred: " + e);
}

statObject(String bucketName, String objectName)

public ObjectStat statObject(String bucketName, String objectName)

获取对象的元数据。

查看 Javadoc

参数

参数	类型	描述
`bucketName`	String	存储桶名称。
`objectName`	String	存储桶里的对象名称。

返回值类型	异常
`ObjectStat`: Populated object meta data.	异常列表：
	`InvalidBucketNameException` : 不合法的存储桶名称。
	`NoResponseException` : 服务器无响应。
	`IOException` : 连接异常。
	`org.xmlpull.v1.XmlPullParserException` : 解析返回的XML异常。
	`ErrorResponseException` : 执行失败异常。
	`InternalException` : 内部错误。

示例

try {
  // 获得对象的元数据。
  ObjectStat objectStat = minioClient.statObject("mybucket", "myobject");
  System.out.println(objectStat);
} catch(MinioException e) {
  System.out.println("Error occurred: " + e);
}

copyObject(String bucketName, String objectName, String destBucketName, String destObjectName, CopyConditions cpConds, Map metadata)

public void copyObject(String bucketName, String objectName, String destBucketName, String destObjectName, CopyConditions cpConds, Map<String, String> metadata)

从objectName指定的对象中将数据拷贝到destObjectName指定的对象。

查看 Javadoc

参数

参数	类型	描述
`bucketName`	String	源存储桶名称。
`objectName`	String	源存储桶中的源对象名称。
`destBucketName`	String	目标存储桶名称。
`destObjectName`	String	要创建的目标对象名称,如果为空，默认为源对象名称。
`copyConditions`	CopyConditions	拷贝操作的一些条件Map。
`metadata`	Map	给目标对象的元数据Map。

返回值类型	异常
None	异常列表：
	`InvalidBucketNameException` : 不合法的存储桶名称。
	`NoResponseException` : 服务器无响应。
	`IOException` : 连接异常。
	`org.xmlpull.v1.XmlPullParserException` : 解析返回的XML异常。
	`ErrorResponseException` : 执行失败异常。
	`InternalException` : 内部错误。

示例

本API执行了一个服务端的拷贝操作。

try {
  CopyConditions copyConditions = new CopyConditions();
  copyConditions.setMatchETagNone("TestETag");

  minioClient.copyObject("mybucket",  "island.jpg", "mydestbucket", "processed.png", copyConditions);
  System.out.println("island.jpg is uploaded successfully");
} catch(MinioException e) {
  System.out.println("Error occurred: " + e);
}

removeObject(String bucketName, String objectName)

public void removeObject(String bucketName, String objectName)

删除一个对象。

查看 Javadoc

参数

参数	类型	描述
`bucketName`	String	存储桶名称。
`objectName`	String	存储桶里的对象名称。

返回值类型	异常
None	异常列表：
	`InvalidBucketNameException` : 不合法的存储桶名称。
	`NoResponseException` : 服务器无响应。
	`IOException` : 连接异常。
	`org.xmlpull.v1.XmlPullParserException` : 解析返回的XML异常。
	`ErrorResponseException` : 执行失败异常。
	`InternalException` : 内部错误。

示例

try {
      // 从mybucket中删除myobject。
      minioClient.removeObject("mybucket", "myobject");
      System.out.println("successfully removed mybucket/myobject");
} catch (MinioException e) {
      System.out.println("Error: " + e);
}

removeObject(String bucketName, Iterable objectNames)

public Iterable<Result<DeleteError>> removeObject(String bucketName, Iterable<String> objectNames)

删除多个对象。

查看 Javadoc

参数

参数	类型	描述
`bucketName`	String	存储桶名称。
`objectNames`	Iterable	含有要删除的多个object名称的迭代器对象。

返回值类型	异常
`Iterable<Result<DeleteError>>`:an iterator of Result DeleteError.	None

示例

List<String> objectNames = new LinkedList<String>();
objectNames.add("my-objectname1");
objectNames.add("my-objectname2");
objectNames.add("my-objectname3");
try {
      // 删除my-bucketname里的多个对象
      for (Result<DeleteError> errorResult: minioClient.removeObject("my-bucketname", objectNames)) {
        DeleteError error = errorResult.get();
        System.out.println("Failed to remove '" + error.objectName() + "'. Error:" + error.message());
      }
} catch (MinioException e) {
      System.out.println("Error: " + e);
}

removeIncompleteUpload(String bucketName, String objectName)

public void removeIncompleteUpload(String bucketName, String objectName)

删除一个未完整上传的对象。

查看 Javadoc

参数

参数	类型	描述
`bucketName`	String	存储桶名称。
`objectName`	String	存储桶里的对象名称。

返回值类型	异常
None	异常列表：
	`InvalidBucketNameException` : 不合法的存储桶名称。
	`NoResponseException` : 服务器无响应。
	`IOException` : 连接异常。
	`org.xmlpull.v1.XmlPullParserException` : 解析返回的XML异常。
	`ErrorResponseException` : 执行失败异常。
	`InternalException` : 内部错误。

示例

try {
    // 从存储桶中删除名为myobject的未完整上传的对象。
    minioClient.removeIncompleteUpload("mybucket", "myobject");
    System.out.println("successfully removed all incomplete upload session of my-bucketname/my-objectname");
} catch(MinioException e) {
    System.out.println("Error occurred: " + e);
}

4. Presigned操作

presignedGetObject(String bucketName, String objectName, Integer expires)

public String presignedGetObject(String bucketName, String objectName, Integer expires)

生成一个给HTTP GET请求用的presigned URL。浏览器/移动端的客户端可以用这个URL进行下载，即使其所在的存储桶是私有的。这个presigned URL可以设置一个失效时间，默认值是7天。

查看 Javadoc

参数

参数	类型	描述
`bucketName`	String	存储桶名称。
`objectName`	String	存储桶里的对象名称。
`expiry`	Integer	失效时间（以秒为单位），默认是7天，不得大于七天。

返回值类型	异常
`String` : string contains URL to download the object.	异常列表：
	`InvalidBucketNameException` : 不合法的存储桶名称。
	`InvalidKeyException` : 不合法的access key或者secret key。
	`IOException` : 连接异常。
	`NoSuchAlgorithmException` : 找不到相应的签名算法。
	`InvalidExpiresRangeException` : presigned URL已经过期了。

示例

try {
    String url = minioClient.presignedGetObject("mybucket", "myobject", 60 * 60 * 24);
    System.out.println(url);
} catch(MinioException e) {
  System.out.println("Error occurred: " + e);
}

presignedPutObject(String bucketName, String objectName, Integer expires)

public String presignedPutObject(String bucketName, String objectName, Integer expires)

生成一个给HTTP PUT请求用的presigned URL。浏览器/移动端的客户端可以用这个URL进行上传，即使其所在的存储桶是私有的。这个presigned URL可以设置一个失效时间，默认值是7天。

查看 Javadoc

参数

参数	类型	描述
`bucketName`	String	存储桶名称。
`objectName`	String	存储桶里的对象名称。
`expiry`	Integer	失效时间（以秒为单位），默认是7天，不得大于七天。

返回值类型	异常
`String` : string contains URL to download the object.	异常列表：
	`InvalidBucketNameException` : 不合法的存储桶名称。
	`InvalidKeyException` : 不合法的access key或者secret key。
	`IOException` : 连接异常。
	`NoSuchAlgorithmException` : 找不到相应的签名算法。
	`InvalidExpiresRangeException` : presigned URL已经过期了。

示例

try {
    String url = minioClient.presignedPutObject("mybucket", "myobject", 60 * 60 * 24);
    System.out.println(url);
} catch(MinioException e) {
  System.out.println("Error occurred: " + e);
}

presignedPostPolicy(PostPolicy policy)

public Map<String,String> presignedPostPolicy(PostPolicy policy)

允许给POST请求的presigned URL设置策略，比如接收对象上传的存储桶名称的策略，key名称前缀，过期策略。

查看 Javadoc

参数

参数	类型	描述
`policy`	PostPolicy	对象的post策略

返回值类型	异常
`Map`: Map of strings to construct form-data.	异常列表：
	`InvalidBucketNameException` : 不合法的存储桶名称。
	`InvalidKeyException` : 不合法的access key或者secret key。
	`IOException` : 连接异常。
	`NoSuchAlgorithmException` : 找不到相应的签名算法。

示例

try {
    PostPolicy policy = new PostPolicy("mybucket", "myobject",
  DateTime.now().plusDays(7));
    policy.setContentType("image/png");
    Map<String,String> formData = minioClient.presignedPostPolicy(policy);
    System.out.print("curl -X POST ");
    for (Map.Entry<String,String> entry : formData.entrySet()) {
    System.out.print(" -F " + entry.getKey() + "=" + entry.getValue());
    }
    System.out.println(" -F file=@/tmp/userpic.png  https://play.min.io/mybucket");
} catch(MinioException e) {
  System.out.println("Error occurred: " + e);

5. 了解更多

Java > Spring > Boot

#MinIO #文件上传 #文件下载 #文件分享

SpringBoot-整合minio文件系统实现上传下载和分享文件

https://blog.cikaros.top/doc/84f51c8e.html

作者

Cikaros

发布于

2020年10月29日

许可协议

SpringBoot-整合redis 上一篇

Docker-搭建minio 下一篇