[ 云计算 | AWS 实践 ] Java 应用中使用 Amazon S3 举行存储桶和对象操作完 ...

本文收录于【#云计算入门与实践 - AWS】专栏中，收录 AWS 入门与实践相关博文。
本文同步于个人公众号：【云计算洞察】
更多关于云计算技术内容敬请关注：CSDN【#云计算入门与实践 - AWS】专栏。
本系列已更新博文：

• [ 云计算 | AWS 实践 ] Java 应用中使用 Amazon S3 举行存储桶和对象操作完全指南
  
• [ 云计算 | AWS 实践 ] Java 如何重命名 Amazon S3 中的文件和文件夹
  
• [ 云计算 | AWS 实践 ] 使用 Java 列出存储桶中的全部 AWS S3 对象
  
• [ 云计算 | AWS 实践 ] 使用 Java 更新现有 Amazon S3 对象
  
• [ 云计算 | AWS 实践 ] 基于 Amazon S3 协议搭建个人云存储服务
  
• [ 云计算 | AWS 实践 ] 使用 Java 查抄指定的密钥是否存在于给定的 Amazon S3 存储桶中
  

  
一、前言

在本文中，我们将探索如何利用 Java 编程与 Amazon S3（即简朴存储服务）存储体系举行互动。
必要牢记，S3 的结构非常简朴：每个存储桶能够容纳大量的对象，这些对象可以通过 SOAP 接口或 REST 风格的 API 举行访问。
接下来，我们将使用实用于Java的AWS开发工具包来实现S3存储桶的创建、枚举以及删除。同时，我们还将学会如何上传、枚举、下载、复制、移动、重命名以及删除这些存储桶内的各个对象。
二、所需 Maven 依赖

在开始之前，我们必要在项目中声明 AWS SDK 依赖项：

1. <dependency>
2.     <groupId>software.amazon.awssdk</groupId>
3.     <artifactId>s3</artifactId>
4.     <version>2.20.52</version>
5. </dependency>

复制代码

  要查看最新版本，我们可以查抄 Maven Central，大概其他的国内 Maven 堆栈。
  三、先决须要的几个条件信息

要使用AWS SDK，我们必要一些东西：

• AWS 帐户：我们必要一个 Amazon Web Services 帐户。如果我们没有，我们可以直接在 AWS 控制台创建一个帐户。
  
• AWS 安全凭据：这些是我们的访问密钥，允许我们以编程方式调用 AWS API 操作。我们可以通过两种方式获取这些凭据：使用“安全凭据”页面的访问密钥部门中的 AWS 根账户凭据，大概使用IAM控制台中的 IAM 用户凭据。
  
• 选择 AWS 地区（Region）：我们还必须选择要存储 Amazon S3 数据的 AWS 地区。请记着，S3 存储代价因地区而异。有关更多具体信息，请参阅官方文档。
  

四、创建客户端毗连

起首，我们必要创建一个客户端毗连来访问 Amazon S3 Web 服务。为此，我们将使用 Amazon S3 接口：

1. AWSCredentials credentials = new BasicAWSCredentials(
2.   "<AWS accesskey>",
3.   "<AWS secretkey>"
4. );

复制代码

然后我们将配置客户端：

1. AmazonS3 s3client = AmazonS3ClientBuilder
2.   .standard()
3.   .withCredentials(new AWSStaticCredentialsProvider(credentials))
4.   .withRegion(Regions.US_EAST_2)
5.   .build();

复制代码

五、Amazon S3 存储桶操作

5.1. 创建桶

必要留意的是，存储桶命名空间是由体系的全部用户共享的。因此，我们的存储桶名称在 Amazon S3 中的全部现有存储桶名称中必须是唯一的（稍后我们将了解如何查抄这一点）。
别的，根据官方文档规定，Bucket 名称必须符合以下要求：

• 名称不应包含下划线
  
• 名称长度应介于 3 到 63 个字符之间
  
• 名称不应以破折号结尾
  
• 名称不能包含相邻的句点
  
• 名称后面不能包含破折号（比方，“my-.bucket.com”和“my.-bucket”无效）
  
• 名称不能包含大写字符
  

现在让我们创建一个存储桶：

1. String bucketName = "baeldung-bucket";
3. if(s3client.doesBucketExist(bucketName)) {
4.     LOG.info("Bucket name is not available."
5.       + " Try again with a different Bucket name.");
6.     return;
7. }

复制代码

1. CreateBucketRequest bucketRequest = CreateBucketRequest.builder()
2.     .bucket(bucketName)
3.     .build();
5. s3Client.createBucket(bucketRequest);

复制代码

在创建存储桶之前，我们必须使用doesBucketExist()方法查抄存储桶名称是否可用。如果名称可用，那么我们将构建一个CreateBucketRequest 并提供存储桶名称。最后一步是将bucketRequest传递给 S3Client 的CreateBucketRequest createBucketRequest的createBucket。
5.2. 列出桶

现在我们已经创建了一些存储桶，让我们使用listBuckets ()方法打印 S3 环境中可用的全部存储桶的列表。此方法将返回一个ListBucketsResponse， 其中包含有关存储桶的信息。

1. ListBucketsResponse listBucketsResponse = s3Client.listBuckets();
3. // Display the bucket names
4. List<Bucket> buckets = listBucketsResponse.buckets();
5. System.out.println("Buckets:");
6. for (Bucket bucket : buckets) {
7.     System.out.println(bucket.name());
8. }

复制代码

这将列出 S3 环境中存在的全部存储桶：

1. baeldung-bucket
2. baeldung-bucket-test2
3. elasticbeanstalk-us-east-2

复制代码

5.3. 删除桶

在删除存储桶之前，确生存储桶是空的非常重要。 否则，将会抛出非常。
起首，我们必要构建一个DeleBucketRequest实例并向其传递存储桶名称。然后，我们调用 s3Client 对象上的deleteBucket方法，并将哀求作为参数传递。
另请留意，只有存储桶的全部者才能删除它，无论其权限如何（访问控制策略）：

1. try {
2.     DeleteBucketRequest deleteBucketRequest = DeleteBucketRequest.builder()
3.         .bucket(bucketName)
4.         .build();
6.     s3Client.deleteBucket(deleteBucketRequest);
7.     System.out.println("Successfully deleted bucket : " + bucketName);
8. } catch (S3Exception e) {
9.     System.err.println(e.getMessage());
10.     System.exit(1);
11. }

复制代码

六、Amazon S3 对象操作

Amazon S3 存储桶内的文件或数据集合称为对象。我们可以对对象执行多种操作，比方上传、列出、下载、复制、移动、重命名和删除。
6.1. 上传对象

上传对象是一个非常简朴的过程。起首，我们将构建一个PutObjectRequest实例，指定存储桶名称和密钥。然后，我们将该哀求和包含数据的文件的路径传递给 s3Client 的putObject方法：

1. PutObjectRequest request = PutObjectRequest.builder()
2.     .bucket(bucketName)
3.     .key(key)
4.     .build();
6. return s3Client.putObject(request, Path.of(file.toURI()) );

复制代码

6.2. 列出对象

我们将使用listObjects()方法列出 S3 存储桶中的全部可用对象：

1. ListObjectsV2Request listObjectsV2Request = ListObjectsV2Request.builder()
2.     .bucket(bucketName)
3.     .build();
4. ListObjectsV2Response listObjectsV2Response = s3Client.listObjectsV2(listObjectsV2Request);
6. List<S3Object> contents = listObjectsV2Response.contents();
8. System.out.println("Number of objects in the bucket: " + contents.stream().count());
9. contents.stream().forEach(System.out::println);

复制代码

要列出 AWS S3 存储桶中的对象，我们必要创建一个ListObjectsV2Request实例并指定存储桶名称。然后，我们在 s3Client 对象上调用 listObjectsV2方法，并将哀求作为参数传递。此方法返回一个ListObjectsV2Response，其中包含有关存储桶中对象的信息。
6.3. 下载对象

要下载对象，我们起首创建一个GetObjectRequest实例并将存储桶名称和密钥作为输入参数传递给它。然后，我们将其提供给 getObjectAsBytes()方法并获取相应。一旦我们得到相应，我们就可以提取字节数组。最后一步是处置惩罚字节数组：

1. GetObjectRequest objectRequest = GetObjectRequest.builder()
2.     .bucket(bucketName)
3.     .key(objectKey)
4.     .build();
6. ResponseBytes<GetObjectResponse> responseResponseBytes = s3Client.getObjectAsBytes(objectRequest);
8. byte[] data = responseResponseBytes.asByteArray();
10. // Write the data to a local file.
11. java.io.File myFile = new java.io.File("/Users/user/Desktop/hello.txt" );
12. OutputStream os = new FileOutputStream(myFile);
13. os.write(data);
14. System.out.println("Successfully obtained bytes from an S3 object");
15. os.close();

复制代码

6.4. 复制、重命名和移动对象

我们可以通过调用 s3client 上的copyObject()方法来复制对象，该方法担当CopyObjectRequest实例。因此，CopyObjectRequest担当四个参数：

• 源存储桶名称
  
• 源存储桶中的对象键
  
• 目标存储桶名称（可以与源存储桶名称相同）
  
• 目标存储桶中的对象键
  

1. CopyObjectRequest copyObjectRequest = CopyObjectRequest.builder()
2.     .sourceBucket(sourceBucketName)
3.     .sourceKey(sourceKey)
4.     .destinationBucket(destinationBucketName)
5.     .destinationKey(destinationKey)
6.     .build();
8. return s3Client.copyObject(copyObjectRequest);

复制代码

留意：我们可以结合使用copyObject()方法和deleteObject()来执行移动和重命名任务。这将涉及起首复制对象，然后将其从旧位置删除。
6.5. 删除对象

要删除对象，我们将在s3client上调用deleteObject()方法并传递DeleteObjectRequest实例。为了创建DeleteObjectRequest实例，我们必要传递要删除的对象的键和存储桶名称：

1. DeleteObjectRequest deleteObjectRequest = DeleteObjectRequest.builder()
2.     .bucket(bucketName)
3.     .key(objectKey)
4.     .build();
6. s3Client.deleteObject(deleteObjectRequest);

复制代码

6.6. 删除多个对象

要一次删除多个对象，我们起首创建DeleteObjectsRequest对象并传递存储桶。然后我们将传递一个包含全部要删除的对象键的 ArrayList。
一旦我们有了这个DeleteObjectsRequest对象，我们就可以将它作为参数传递给我们的 s3client 的deleteObjects()方法。如果成功，它将删除我们提供的全部对象：

1. ArrayList<ObjectIdentifier> toDelete = new ArrayList<>();
2. for(String objKey : keys) {
3.     toDelete.add(ObjectIdentifier.builder()
4.         .key(objKey)
5.         .build());
6. }
8. DeleteObjectsRequest deleteObjectRequest = DeleteObjectsRequest.builder()
9.     .bucket(bucketName)
10.     .delete(Delete.builder()
11.         .objects(toDelete).build())
12.     .build();
14. s3Client.deleteObjects(deleteObjectRequest);

复制代码

七、文末总结

在本文中，我们重点介绍了在存储桶级别和对象级别与 Amazon S3 Web 服务交互的基础知识。重点在 Java 应用中使用 Amazon S3（Simple Storage Service）举行存储桶和对象操作的方法、具体阐明白如何举行存储桶操作，包括创建桶和列出桶。在对象操作部门，我们涵盖了上传、列出和下载对象的过程，还介绍了复制、重命名、移动对象以及删除对象的方法。别的，我们还提供了删除多个对象的操作步调。通过本文，小同伴们可以了解如何通过 Java 代码有用地与 Amazon S3 举行交互，实现对存储桶和对象的各种操作。

1. [ 本文作者 ]   bluetata
2. [ 原文链接 ]   https://bluetata.blog.csdn.net/article/details/132531011
3. [ 最后更新 ]   11/19/2023 23:45
4. [ 版权声明 ]   如果您在非 CSDN 网站内看到这一行，
5. 说明网络爬虫可能在本人还没有完整发布的时候就抓走了我的文章，
6. 可能导致内容不完整，请去上述的原文链接查看原文。

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。