相关推荐recommended
[ 云计算 | AWS 实践 ] Java 应用中使用 Amazon S3 进行存储桶和对象操作完全指南
作者:mmseoamin日期:2024-04-29

[ 云计算 | AWS 实践 ] Java 应用中使用 Amazon S3 进行存储桶和对象操作完全指南,在这里插入图片描述,第1张

本文收录于【#云计算入门与实践 - 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 存储桶中

    文章目录

      • 一、前言
      • 二、所需 Maven 依赖
      • 三、先决必要的几个条件信息
      • 四、创建客户端连接
      • 五、Amazon S3 存储桶操作
        • 5.1. 创建桶
        • 5.2. 列出桶
        • 5.3. 删除桶
        • 六、Amazon S3 对象操作
          • 6.1. 上传对象
          • 6.2. 列出对象
          • 6.3. 下载对象
          • 6.4. 复制、重命名和移动对象
          • 6.5. 删除对象
          • 6.6. 删除多个对象
          • 七、文末总结

            一、前言

            在本文中,我们将探索如何利用 Java 编程与 Amazon S3(即简单存储服务)存储系统进行互动。

            需要牢记,S3 的结构异常简单:每个存储桶能够容纳大量的对象,这些对象可以通过 SOAP 接口或 REST 风格的 API 进行访问。

            接下来,我们将使用适用于Java的AWS开发工具包来实现S3存储桶的创建、列举以及删除。同时,我们还将学会如何上传、列举、下载、复制、移动、重命名以及删除这些存储桶内的各个对象。

            二、所需 Maven 依赖

            在开始之前,我们需要在项目中声明 AWS SDK 依赖项:

            
                software.amazon.awssdk
                s3
                2.20.52
            
            

            要查看最新版本,我们可以检查 Maven Central,或者其他的国内 Maven 仓库。

            三、先决必要的几个条件信息

            要使用AWS SDK,我们需要一些东西:

            1. AWS 帐户:我们需要一个 Amazon Web Services 帐户。如果我们没有,我们可以直接在 AWS 控制台创建一个帐户。
            2. AWS 安全凭证:这些是我们的访问密钥,允许我们以编程方式调用 AWS API 操作。我们可以通过两种方式获取这些凭证:使用“安全凭证”页面的访问密钥部分中的 AWS 根账户凭证,或者使用IAM控制台中的 IAM 用户凭证。
            3. 选择 AWS 区域(Region):我们还必须选择要存储 Amazon S3 数据的 AWS 区域。请记住,S3 存储价格因地区而异。有关更多详细信息,请参阅官方文档。

            四、创建客户端连接

            首先,我们需要创建一个客户端连接来访问 Amazon S3 Web 服务。为此,我们将使用 Amazon S3 接口:

            AWSCredentials credentials = new BasicAWSCredentials(
              "", 
              ""
            );
            

            然后我们将配置客户端:

            AmazonS3 s3client = AmazonS3ClientBuilder
              .standard()
              .withCredentials(new AWSStaticCredentialsProvider(credentials))
              .withRegion(Regions.US_EAST_2)
              .build();
            

            五、Amazon S3 存储桶操作

            5.1. 创建桶

            需要注意的是,存储桶命名空间是由系统的所有用户共享的。因此,我们的存储桶名称在 Amazon S3 中的所有现有存储桶名称中必须是唯一的(稍后我们将了解如何检查这一点)。

            另外,根据官方文档规定,Bucket 名称必须符合以下要求:

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

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

              String bucketName = "baeldung-bucket";
              if(s3client.doesBucketExist(bucketName)) {
                  LOG.info("Bucket name is not available."
                    + " Try again with a different Bucket name.");
                  return;
              }
              
              CreateBucketRequest bucketRequest = CreateBucketRequest.builder()
                  .bucket(bucketName)
                  .build();
              s3Client.createBucket(bucketRequest);
              

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

              5.2. 列出桶

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

              ListBucketsResponse listBucketsResponse = s3Client.listBuckets();
              // Display the bucket names
              List buckets = listBucketsResponse.buckets();
              System.out.println("Buckets:");
              for (Bucket bucket : buckets) {
                  System.out.println(bucket.name());
              }
              

              这将列出 S3 环境中存在的所有存储桶:

              baeldung-bucket
              baeldung-bucket-test2
              elasticbeanstalk-us-east-2
              

              5.3. 删除桶

              在删除存储桶之前,确保存储桶是空的非常重要。 否则,将会抛出异常。

              首先,我们需要构建一个DeleBucketRequest实例并向其传递存储桶名称。然后,我们调用 s3Client 对象上的deleteBucket方法,并将请求作为参数传递。

              另请注意,只有存储桶的所有者才能删除它,无论其权限如何(访问控制策略):

              try {
                  DeleteBucketRequest deleteBucketRequest = DeleteBucketRequest.builder()
                      .bucket(bucketName)
                      .build();
                  s3Client.deleteBucket(deleteBucketRequest);
                  System.out.println("Successfully deleted bucket : " + bucketName);
              } catch (S3Exception e) {
                  System.err.println(e.getMessage());
                  System.exit(1);
              }
              

              六、Amazon S3 对象操作

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

              6.1. 上传对象

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

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

              6.2. 列出对象

              我们将使用listObjects()方法列出 S3 存储桶中的所有可用对象:

              ListObjectsV2Request listObjectsV2Request = ListObjectsV2Request.builder()
                  .bucket(bucketName)
                  .build();
              ListObjectsV2Response listObjectsV2Response = s3Client.listObjectsV2(listObjectsV2Request);
              List contents = listObjectsV2Response.contents();
              System.out.println("Number of objects in the bucket: " + contents.stream().count());
              contents.stream().forEach(System.out::println);
              

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

              6.3. 下载对象

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

              GetObjectRequest objectRequest = GetObjectRequest.builder()
                  .bucket(bucketName)
                  .key(objectKey)
                  .build();
              ResponseBytes responseResponseBytes = s3Client.getObjectAsBytes(objectRequest);
              byte[] data = responseResponseBytes.asByteArray();
              // Write the data to a local file.
              java.io.File myFile = new java.io.File("/Users/user/Desktop/hello.txt" );
              OutputStream os = new FileOutputStream(myFile);
              os.write(data);
              System.out.println("Successfully obtained bytes from an S3 object");
              os.close();
              

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

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

              1. 源存储桶名称
              2. 源存储桶中的对象键
              3. 目标存储桶名称(可以与源存储桶名称相同)
              4. 目标存储桶中的对象键
              CopyObjectRequest copyObjectRequest = CopyObjectRequest.builder()
                  .sourceBucket(sourceBucketName)
                  .sourceKey(sourceKey)
                  .destinationBucket(destinationBucketName)
                  .destinationKey(destinationKey)
                  .build();
              return s3Client.copyObject(copyObjectRequest);
              

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

              6.5. 删除对象

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

              DeleteObjectRequest deleteObjectRequest = DeleteObjectRequest.builder()
                  .bucket(bucketName)
                  .key(objectKey)
                  .build();
              s3Client.deleteObject(deleteObjectRequest);
              

              6.6. 删除多个对象

              要一次删除多个对象,我们首先创建DeleteObjectsRequest对象并传递存储桶。然后我们将传递一个包含所有要删除的对象键的 ArrayList。

              一旦我们有了这个DeleteObjectsRequest对象,我们就可以将它作为参数传递给我们的 s3client 的deleteObjects()方法。如果成功,它将删除我们提供的所有对象:

              ArrayList toDelete = new ArrayList<>();
              for(String objKey : keys) {
                  toDelete.add(ObjectIdentifier.builder()
                      .key(objKey)
                      .build());
              }
              DeleteObjectsRequest deleteObjectRequest = DeleteObjectsRequest.builder()
                  .bucket(bucketName)
                  .delete(Delete.builder()
                      .objects(toDelete).build())
                  .build();
              s3Client.deleteObjects(deleteObjectRequest);
              

              七、文末总结

              在本文中,我们重点介绍了在存储桶级别和对象级别与 Amazon S3 Web 服务交互的基础知识。重点在 Java 应用中使用 Amazon S3(Simple Storage Service)进行存储桶和对象操作的方法、详细说明了如何进行存储桶操作,包括创建桶和列出桶。在对象操作部分,我们涵盖了上传、列出和下载对象的过程,还介绍了复制、重命名、移动对象以及删除对象的方法。此外,我们还提供了删除多个对象的操作步骤。通过本文,小伙伴们可以了解如何通过 Java 代码有效地与 Amazon S3 进行交互,实现对存储桶和对象的各种操作。

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