Amazon S3 对象存储Java API操作记录（Minio与S3 SDK两种实现）

迷南。 2024-03-22 18:03 83阅读 0赞

### S3对象存储的基本概念 ###

#### S3是什么？ ####

Amazon S3(Simple Storage Service)对象存储出现得比较早且使用简单的RESTful API，于是成为了对象存储服务(Object Storage Service，OSS)业内的标准接口规范。

#### S3的逻辑模型 ####

如下图，我们可以把S3的存储空间想象成无限的，想存储一个任意格式的文件到S3服务中，只需要知道要把它放到哪个桶(Bucket)中，它的名字（Object Id）应该是什么。

![7e18efb5274ba30175f54f6f1aff39e7.png][]

按图中的模型，可简单理解为S3是由若干个桶（Bucket）组成，每个桶中包含若干个不同标识的对象（Object），还有就是统一的访问入口(RESTful API)，这样基本就足够了。

### Minio客户端方式操作S3 ###

详细API文档：[Java Client API Reference — MinIO Object Storage for Linux][Java Client API Reference _ MinIO Object Storage for Linux]

以下代码异常处理做了简化，真实使用时请注意捕获异常做处理。

#### 引入依赖 ####

Maven:

<table> 
 <tbody> 
  <tr> 
   <td></td> 
   <td><code>&lt;dependency&gt;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>&lt;groupId&gt;io.minio&lt;/groupId&gt;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>&lt;artifactId&gt;minio&lt;/artifactId&gt;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>&lt;version&gt;8.5.2&lt;/version&gt;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>&lt;/dependency&gt;</code></td> 
  </tr> 
 </tbody> 
</table>

Gradle:

<table> 
 <tbody> 
  <tr> 
   <td></td> 
   <td><code>dependencies { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>implementation("io.minio:minio:8.5.2")</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
 </tbody> 
</table>

#### 初始化客户端 ####

<table> 
 <tbody> 
  <tr> 
   <td></td> 
   <td><code>private static final String HTTP_PROTOCOL = "http";</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>private MinioClient minioClient;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>private String endpoint = "http://192.168.0.8:9200";</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>private String accessKey = "testKey";</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>private String secretKey = "testSecretKey";</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>public void init() throws MalformedURLException { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>URL endpointUrl = new URL(endpoint);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>try { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>// url上无端口号时，识别http为80端口，https为443端口</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>int port = endpointUrl.getPort() != -1 ? endpointUrl.getPort() : endpointUrl.getDefaultPort();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>boolean security = HTTP_PROTOCOL.equals(endpointUrl.getProtocol()) ? false : true;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>//@formatter:off</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>this.minioClient = MinioClient.builder().endpoint(endpointUrl.getHost(), port, security)</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>.credentials(accessKey, secretKey).build();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>//@formatter:on</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>// 忽略证书校验，防止自签名证书校验失败导致无法建立连接</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>this.minioClient.ignoreCertCheck();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>} catch (Exception e) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>e.printStackTrace();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
 </tbody> 
</table>

#### 建桶 ####

<table> 
 <tbody> 
  <tr> 
   <td></td> 
   <td><code>public boolean createBucket(String bucket) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>try { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucket).build());</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>} catch (Exception e) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>e.printStackTrace();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return false;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return true;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
 </tbody> 
</table>

#### 删桶 ####

<table> 
 <tbody> 
  <tr> 
   <td></td> 
   <td><code>public boolean deleteBucket(String bucket) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>try { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>minioClient.removeBucket(RemoveBucketArgs.builder().bucket(bucket).build());</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>logger.info("删除桶[{}]成功", bucket);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>} catch (Exception e) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>e.printStackTrace();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return false;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return true;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
 </tbody> 
</table>

#### 判断桶是否存在 ####

<table> 
 <tbody> 
  <tr> 
   <td></td> 
   <td><code>public boolean bucketExists(String bucket) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>try { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucket).build());</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>} catch (Exception e) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>e.printStackTrace();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return false;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
 </tbody> 
</table>

#### 上传对象 ####

<table> 
 <tbody> 
  <tr> 
   <td></td> 
   <td><code>public void upload(String bucket, String objectId, InputStream input) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>try { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>//@formatter:off</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>minioClient.putObject(PutObjectArgs.builder().bucket(bucket).object(objectId)</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>.stream(input, input.available(), -1)</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>.build());</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>//@formatter:on</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>} catch (Exception e) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>e.printStackTrace();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
 </tbody> 
</table>

#### 下载对象 ####

提供两个下载方法，一个将输入流返回，另一个用参数输出流写出

<table> 
 <tbody> 
  <tr> 
   <td></td> 
   <td><code>public InputStream download(String bucket, String objectId) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>try { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return minioClient.getObject(GetObjectArgs.builder().bucket(bucket).object(objectId).build());</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>} catch (Exception e) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>e.printStackTrace();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return null;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>public void download(String bucket, String objectId, OutputStream output) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>//@formatter:off</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>try (InputStream input = minioClient.getObject(</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>GetObjectArgs.builder().bucket(bucket).object(objectId).build())) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>IOUtils.copyLarge(input, output);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>} catch (Exception e) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>e.printStackTrace();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>//@formatter:on</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
 </tbody> 
</table>

#### 删除对象 ####

<table> 
 <tbody> 
  <tr> 
   <td></td> 
   <td><code>public boolean deleteObject(String bucket, String objectId) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>//@formatter:off</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>try { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>minioClient.removeObject(RemoveObjectArgs.builder()</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>.bucket(bucket).object(objectId).build());</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>} catch (Exception e) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>e.printStackTrace();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>//@formatter:on</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return true;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
 </tbody> 
</table>

#### 判断对象是否存在 ####

<table> 
 <tbody> 
  <tr> 
   <td></td> 
   <td><code>public boolean objectExists(String bucket, String key) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>//@formatter:off</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>try { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>// minio客户端未提供判断对象是否存在的方法，此方法中调用出现异常时说明对象不存在</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>minioClient.statObject(StatObjectArgs.builder()</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>.bucket(bucket).object(key).build());</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>} catch (Exception e) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return false;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>//@formatter:on</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return true;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
 </tbody> 
</table>

#### 完整代码 ####

<table> 
 <tbody> 
  <tr> 
   <td></td> 
   <td><code>import java.io.InputStream;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>import java.io.OutputStream;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>import java.net.MalformedURLException;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>import java.net.URL;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>import org.apache.tomcat.util.http.fileupload.IOUtils;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>import org.slf4j.Logger;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>import org.slf4j.LoggerFactory;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>import io.minio.BucketExistsArgs;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>import io.minio.GetObjectArgs;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>import io.minio.MakeBucketArgs;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>import io.minio.MinioClient;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>import io.minio.PutObjectArgs;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>import io.minio.RemoveBucketArgs;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>import io.minio.RemoveObjectArgs;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>import io.minio.StatObjectArgs;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>public class S3MinioClientDemo { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>private static final Logger logger = LoggerFactory.getLogger(S3MinioClientDemo.class);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>private static final String HTTP_PROTOCOL = "http";</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>private MinioClient minioClient;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>private String endpoint = "http://192.168.0.8:9200";</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>private String accessKey = "testKey";</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>private String secretKey = "testSecretKey";</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>public void init() throws MalformedURLException { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>URL endpointUrl = new URL(endpoint);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>try { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>// url上无端口号时，识别http为80端口，https为443端口</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>int port = endpointUrl.getPort() != -1 ? endpointUrl.getPort() : endpointUrl.getDefaultPort();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>boolean security = HTTP_PROTOCOL.equals(endpointUrl.getProtocol()) ? false : true;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>//@formatter:off</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>this.minioClient = MinioClient.builder().endpoint(endpointUrl.getHost(), port, security)</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>.credentials(accessKey, secretKey).build();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>//@formatter:on</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>// 忽略证书校验，防止自签名证书校验失败导致无法建立连接</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>this.minioClient.ignoreCertCheck();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>} catch (Exception e) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>e.printStackTrace();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>public boolean createBucket(String bucket) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>try { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>boolean found = minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucket).build());</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>if (found) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>logger.info("桶名[{}]已存在", bucket);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return false;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucket).build());</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>} catch (Exception e) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>e.printStackTrace();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return true;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>public boolean deleteBucket(String bucket) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>try { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>minioClient.removeBucket(RemoveBucketArgs.builder().bucket(bucket).build());</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>logger.info("删除桶[{}]成功", bucket);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>} catch (Exception e) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>e.printStackTrace();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return false;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return true;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>public boolean bucketExists(String bucket) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>try { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucket).build());</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>} catch (Exception e) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>e.printStackTrace();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return false;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>public void upload(String bucket, String objectId, InputStream input) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>try { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>//@formatter:off</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>minioClient.putObject(PutObjectArgs.builder().bucket(bucket).object(objectId)</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>.stream(input, input.available(), -1)</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>.build());</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>//@formatter:on</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>} catch (Exception e) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>e.printStackTrace();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>public InputStream download(String bucket, String objectId) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>try { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return minioClient.getObject(GetObjectArgs.builder().bucket(bucket).object(objectId).build());</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>} catch (Exception e) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>e.printStackTrace();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return null;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>public void download(String bucket, String objectId, OutputStream output) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>//@formatter:off</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>try (InputStream input = minioClient.getObject(</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>GetObjectArgs.builder().bucket(bucket).object(objectId).build())) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>IOUtils.copyLarge(input, output);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>} catch (Exception e) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>e.printStackTrace();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>//@formatter:on</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>public boolean objectExists(String bucket, String objectId) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>//@formatter:off</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>try { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>// minio客户端未提供判断对象是否存在的方法，此方法中调用出现异常时说明对象不存在</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>minioClient.statObject(StatObjectArgs.builder()</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>.bucket(bucket).object(objectId).build());</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>} catch (Exception e) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return false;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>//@formatter:on</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return true;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>public boolean deleteObject(String bucket, String objectId) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>//@formatter:off</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>try { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>minioClient.removeObject(RemoveObjectArgs.builder()</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>.bucket(bucket).object(objectId).build());</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>} catch (Exception e) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>e.printStackTrace();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>//@formatter:on</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return true;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>public void close() { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>minioClient = null;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
 </tbody> 
</table>

### Amazon S3 SDK方式操作S3 ###

官方API文档：[What is Amazon S3? - Amazon Simple Storage Service][What is Amazon S3_ - Amazon Simple Storage Service]

这里由于项目上提供的SDK和文档都是1.x的，这里就暂时只提供1.x的代码

#### 引入依赖 ####

Maven:

<table> 
 <tbody> 
  <tr> 
   <td></td> 
   <td><code>&lt;dependency&gt;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>&lt;groupId&gt;com.amazonaws&lt;/groupId&gt;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>&lt;artifactId&gt;aws-java-sdk-s3&lt;/artifactId&gt;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>&lt;version&gt;1.11.300&lt;/version&gt;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>&lt;/dependency&gt;</code></td> 
  </tr> 
 </tbody> 
</table>

Gradle:

<table> 
 <tbody> 
  <tr> 
   <td></td> 
   <td><code>dependencies { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>implementation 'com.amazonaws:aws-java-sdk-s3:1.11.300'</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
 </tbody> 
</table>

#### 初始化客户端 ####

<table> 
 <tbody> 
  <tr> 
   <td></td> 
   <td><code>private static final Logger logger = LoggerFactory.getLogger(S3SdkDemo.class);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>private AmazonS3 s3client;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>private String endpoint = "http://192.168.0.8:9200";</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>private String accessKey = "testKey";</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>private String secretKey = "testSecretKey";</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>public void init() throws MalformedURLException { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>URL endpointUrl = new URL(endpoint);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>String protocol = endpointUrl.getProtocol();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>int port = endpointUrl.getPort() == -1 ? endpointUrl.getDefaultPort() : endpointUrl.getPort();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>ClientConfiguration clientConfig = new ClientConfiguration();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>clientConfig.setSignerOverride("S3SignerType");</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>clientConfig.setProtocol(Protocol.valueOf(protocol.toUpperCase()));</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>// 禁用证书检查，避免https自签证书校验失败</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>System.setProperty("com.amazonaws.sdk.disableCertChecking", "true");</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>// 屏蔽 AWS 的 MD5 校验，避免校验导致的下载抛出异常问题</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>System.setProperty("com.amazonaws.services.s3.disableGetObjectMD5Validation", "true");</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>AWSCredentials awsCredentials = new BasicAWSCredentials(accessKey, secretKey);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>// 创建 S3Client 实例</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>AmazonS3 s3client = new AmazonS3Client(awsCredentials, clientConfig);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>s3client.setEndpoint(endpointUrl.getHost() + ":" + port);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>s3client.setS3ClientOptions(S3ClientOptions.builder().setPathStyleAccess(true).build());</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>this.s3client = s3client;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
 </tbody> 
</table>

#### 建桶 ####

<table> 
 <tbody> 
  <tr> 
   <td></td> 
   <td><code>public boolean createBucket(String bucket) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>String bucketName = parseBucketName(bucket);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>try { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>if (s3client.doesBucketExist(bucketName)) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>logger.warn("bucket[{}]已存在", bucketName);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return false;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>s3client.createBucket(bucketName);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>} catch (Exception e) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>e.printStackTrace();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return true;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
 </tbody> 
</table>

#### 删桶 ####

<table> 
 <tbody> 
  <tr> 
   <td></td> 
   <td><code>public boolean deleteBucket(String bucket) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>try { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>s3client.deleteBucket(bucket);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>logger.info("删除bucket[{}]成功", bucket);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>} catch (Exception e) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>e.printStackTrace();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return false;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return true;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
 </tbody> 
</table>

#### 判断桶是否存在 ####

<table> 
 <tbody> 
  <tr> 
   <td></td> 
   <td><code>public boolean bucketExists(String bucket) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>try { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return s3client.doesBucketExist(bucket);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>} catch (Exception e) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>e.printStackTrace();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return false;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
 </tbody> 
</table>

#### 上传对象 ####

<table> 
 <tbody> 
  <tr> 
   <td></td> 
   <td><code>public void upload(String bucket, String objectId, InputStream input) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>try { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>// 创建文件上传的元数据</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>ObjectMetadata meta = new ObjectMetadata();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>// 设置文件上传长度</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>meta.setContentLength(input.available());</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>// 上传</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>s3client.putObject(bucket, objectId, input, meta);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>} catch (Exception e) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>e.printStackTrace();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
 </tbody> 
</table>

#### 下载对象 ####

<table> 
 <tbody> 
  <tr> 
   <td></td> 
   <td><code>public InputStream download(String bucket, String objectId) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>try { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>S3Object o = s3client.getObject(bucket, objectId);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return o.getObjectContent();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>} catch (Exception e) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>e.printStackTrace();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return null;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>public void download(String bucket, String objectId, OutputStream out) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>S3Object o = s3client.getObject(bucket, objectId);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>try (InputStream in = o.getObjectContent()) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>IOUtils.copyLarge(in, out);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>} catch (Exception e) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>e.printStackTrace();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
 </tbody> 
</table>

#### 删除对象 ####

<table> 
 <tbody> 
  <tr> 
   <td></td> 
   <td><code>public boolean deleteObject(String bucket, String objectId) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>try { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>s3client.deleteObject(bucket, objectId);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>} catch (Exception e) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>e.printStackTrace();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return false;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return true;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
 </tbody> 
</table>

#### 判断对象是否存在 ####

<table> 
 <tbody> 
  <tr> 
   <td></td> 
   <td><code>public boolean existObject(String bucket, String objectId) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>try { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return s3client.doesObjectExist(bucket, objectId);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>} catch (Exception e) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>e.printStackTrace();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return false;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
 </tbody> 
</table>

#### 完整代码 ####

<table> 
 <tbody> 
  <tr> 
   <td></td> 
   <td><code>import java.io.InputStream;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>import java.io.OutputStream;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>import java.net.MalformedURLException;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>import java.net.URL;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>import org.apache.tomcat.util.http.fileupload.IOUtils;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>import org.slf4j.Logger;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>import org.slf4j.LoggerFactory;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>import com.amazonaws.ClientConfiguration;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>import com.amazonaws.Protocol;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>import com.amazonaws.auth.AWSCredentials;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>import com.amazonaws.auth.BasicAWSCredentials;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>import com.amazonaws.services.s3.AmazonS3;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>import com.amazonaws.services.s3.AmazonS3Client;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>import com.amazonaws.services.s3.S3ClientOptions;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>import com.amazonaws.services.s3.model.ObjectMetadata;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>import com.amazonaws.services.s3.model.S3Object;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>/**</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>* S3对象存储官方SDK实现</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>*</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>* @author ZhangChenguang</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>* @date 2023年2月2日</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>*/</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>@SuppressWarnings("deprecation")</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>public class S3SdkDemo { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>private static final Logger logger = LoggerFactory.getLogger(S3SdkDemo.class);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>private AmazonS3 s3client;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>private String endpoint = "http://192.168.0.8:9200";</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>private String accessKey = "testKey";</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>private String secretKey = "testSecretKey";</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>public void init() throws MalformedURLException { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>URL endpointUrl = new URL(endpoint);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>String protocol = endpointUrl.getProtocol();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>int port = endpointUrl.getPort() == -1 ? endpointUrl.getDefaultPort() : endpointUrl.getPort();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>ClientConfiguration clientConfig = new ClientConfiguration();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>clientConfig.setSignerOverride("S3SignerType");</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>clientConfig.setProtocol(Protocol.valueOf(protocol.toUpperCase()));</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>// 禁用证书检查，避免https自签证书校验失败</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>System.setProperty("com.amazonaws.sdk.disableCertChecking", "true");</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>// 屏蔽 AWS 的 MD5 校验，避免校验导致的下载抛出异常问题</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>System.setProperty("com.amazonaws.services.s3.disableGetObjectMD5Validation", "true");</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>AWSCredentials awsCredentials = new BasicAWSCredentials(accessKey, secretKey);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>// 创建 S3Client 实例</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>AmazonS3 s3client = new AmazonS3Client(awsCredentials, clientConfig);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>s3client.setEndpoint(endpointUrl.getHost() + ":" + port);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>s3client.setS3ClientOptions(S3ClientOptions.builder().setPathStyleAccess(true).build());</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>this.s3client = s3client;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>public boolean createBucket(String bucket) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>try { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>s3client.createBucket(bucket);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>} catch (Exception e) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>e.printStackTrace();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return true;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>public boolean deleteBucket(String bucket) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>try { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>s3client.deleteBucket(bucket);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>logger.info("删除bucket[{}]成功", bucket);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>} catch (Exception e) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>e.printStackTrace();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return false;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return true;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>public boolean bucketExists(String bucket) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>try { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return s3client.doesBucketExist(bucket);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>} catch (Exception e) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>e.printStackTrace();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return false;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>public void upload(String bucket, String objectId, InputStream input) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>try { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>// 创建文件上传的元数据</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>ObjectMetadata meta = new ObjectMetadata();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>// 设置文件上传长度</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>meta.setContentLength(input.available());</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>// 上传</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>s3client.putObject(bucket, objectId, input, meta);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>} catch (Exception e) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>e.printStackTrace();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>public InputStream download(String bucket, String objectId) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>try { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>S3Object o = s3client.getObject(bucket, objectId);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return o.getObjectContent();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>} catch (Exception e) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>e.printStackTrace();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return null;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>public void download(String bucket, String objectId, OutputStream out) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>S3Object o = s3client.getObject(bucket, objectId);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>try (InputStream in = o.getObjectContent()) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>IOUtils.copyLarge(in, out);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>} catch (Exception e) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>e.printStackTrace();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>public boolean existObject(String bucket, String objectId) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>try { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return s3client.doesObjectExist(bucket, objectId);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>} catch (Exception e) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>e.printStackTrace();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return false;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>public boolean deleteObject(String bucket, String objectId) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>try { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>s3client.deleteObject(bucket, objectId);</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>} catch (Exception e) { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>e.printStackTrace();</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return false;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>return true;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>public void close() { </code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>s3client = null;</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>}</code></td> 
  </tr> 
 </tbody> 
</table>

### 遇到的问题 ###

**1、bucket名称必须是小写，不支持下划线**

*  处理方式：写方法转换下bucket名称，将大写转小写，将下划线替换为中划线。

**2、minio客户端下载非官方S3存储的文件时，如果响应头的Content-Length与实际文件大小不符，会导致minio客户端包装的okhttp3报错**

报错信息：

<table> 
 <tbody> 
  <tr> 
   <td></td> 
   <td><code>Caused by: java.net.ProtocolException: unexpected end of stream</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>at okhttp3.internal.http1.Http1ExchangeCodec$FixedLengthSource.read(Http1ExchangeCodec.java:430) ~[okhttp-3.14.9.jar:?]</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>at okhttp3.internal.connection.Exchange$ResponseBodySource.read(Exchange.java:286) ~[okhttp-3.14.9.jar:?]</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>at okio.RealBufferedSource$1.read(RealBufferedSource.java:447) ~[okio-1.17.2.jar:?]</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>at com.jiuqi.nr.file.utils.FileUtils.writeInput2Output(FileUtils.java:83) ~[nr.file-2.5.7.jar:?]</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>at com.jiuqi.nr.file.impl.FileAreaServiceImpl.download(FileAreaServiceImpl.java:395) ~[nr.file-2.5.7.jar:?]</code></td> 
  </tr> 
  <tr> 
   <td></td> 
   <td><code>... 122 more</code></td> 
  </tr> 
 </tbody> 
</table>

抓包发现问题的图：

![750bd7b90559215814f15835cccb1661.png][]

最终换成了S3官方SDK可用了。

PS：客户现场部署的S3是浪潮公司提供的，如果现场遇到这个情况，就不要固执去找对方对线了，完全没用。。

[7e18efb5274ba30175f54f6f1aff39e7.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/18/b2956ebe66084fe2b39a2359514052d9.png
[Java Client API Reference _ MinIO Object Storage for Linux]: https://min.io/docs/minio/linux/developers/java/API.html
[What is Amazon S3_ - Amazon Simple Storage Service]: https://docs.aws.amazon.com/AmazonS3/latest/userguide/Welcome.html
[750bd7b90559215814f15835cccb1661.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/18/caa28662b51d40d7be0f1ff353d7dedb.png