如何使用AWS SDK for Java操作Minio Server

aws-sdk-java是Java语言版本的官方AWS SDK。本文我们将学习如何使用aws-sdk-java操作Minio Server。

1. 前提条件

从这里下载并安装Minio Server。

2. 设置依赖

你可以参考AWS Java SDK文档下载并安装aws-java-sdk，或者使用Apache Maven来获得相应的依赖。

  1. …
  2.     <properties>
  3.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  4.         <aws.sdk.version>1.11.106</aws.sdk.version>
  5.     </properties>
  7.     <dependencyManagement>
  8.         <dependencies>
  9.             <dependency>
  10.                 <groupId>com.amazonaws</groupId>
  11.                 <artifactId>aws-java-sdk-bom</artifactId>
  12.                 <version>${aws.sdk.version}</version>
  13.                 <type>pom</type>
  14.                 <scope>import</scope>
  15.             </dependency>
  16.         </dependencies>
  17.     </dependencyManagement>
  19.     <dependencies>
  20.         <dependency>
  21.             <groupId>com.amazonaws</groupId>
  22.             <artifactId>aws-java-sdk-s3</artifactId>
  23.         </dependency>
  24.     </dependencies>
  26.     <build>
  27.         <plugins>
  28.             <plugin>
  29.                 <groupId>org.apache.maven.plugins</groupId>
  30.                 <artifactId>maven-compiler-plugin</artifactId>
  31.                 <configuration>
  32.                     <source>1.8</source>
  33.                     <target>1.8</target>
  34.                 </configuration>
  35.             </plugin>
  36.         </plugins>
  37.     </build>
  38. …

3. 示例

使用下面的代码替换aws-java-sdk-1.11.213/samples/AmazonS3/S3Sample.java，并且修改Endpoint，BasicAWSCredentials，bucketName，uploadFileName和keyName成你的本地配置。

下面的示例描述的是如何使用asw-sdk-java来对Minio Server进行上传和下载操作。

  1. import java.io.BufferedReader;
  2. import java.io.File;
  3. import java.io.IOException;
  4. import java.io.InputStream;
  5. import java.io.InputStreamReader;
  7. import com.amazonaws.AmazonClientException;
  8. import com.amazonaws.AmazonServiceException;
  9. import com.amazonaws.ClientConfiguration;
  10. import com.amazonaws.auth.AWSCredentials;
  11. import com.amazonaws.auth.AWSStaticCredentialsProvider;
  12. import com.amazonaws.auth.BasicAWSCredentials;
  13. import com.amazonaws.client.builder.AwsClientBuilder;
  14. import com.amazonaws.regions.Regions;
  15. import com.amazonaws.services.s3.AmazonS3;
  16. import com.amazonaws.services.s3.AmazonS3ClientBuilder;
  17. import com.amazonaws.services.s3.model.GetObjectRequest;
  18. import com.amazonaws.services.s3.model.PutObjectRequest;
  19. import com.amazonaws.services.s3.model.S3Object;
  21. public class S3Sample {
  22.     private static String bucketName = "testbucket";
  23.     private static String keyName = "hosts";
  24.     private static String uploadFileName = "/etc/hosts";
  26.     public static void main(String[] args) throws IOException {
  27.         AWSCredentials credentials = new BasicAWSCredentials("YOUR-ACCESSKEYID", "OUR-SECREYTACCESSKEY");
  28.         ClientConfiguration clientConfiguration = new ClientConfiguration();
  29.         clientConfiguration.setSignerOverride("AWSS3V4SignerType");
  31.         AmazonS3 s3Client = AmazonS3ClientBuilder
  32.                 .standard()
  33.                 .withEndpointConfiguration(new AwsClientBuilder.EndpointConfiguration("http://localhost:9000", Regions.US_EAST_1.name()))
  34.                 .withPathStyleAccessEnabled(true)
  35.                 .withClientConfiguration(clientConfiguration)
  36.                 .withCredentials(new AWSStaticCredentialsProvider(credentials))
  37.                 .build();
  39.         try {
  40.             System.out.println("Uploading a new object to S3 from a file\n");
  41.             File file = new File(uploadFileName);
  42.             // 上传文件
  43.             s3Client.putObject(new PutObjectRequest(bucketName, keyName, file));
  45.             // 下载文件
  46.             GetObjectRequest rangeObjectRequest = new GetObjectRequest(bucketName, keyName);
  47.             S3Object objectPortion = s3Client.getObject(rangeObjectRequest);
  48.             System.out.println("Printing bytes retrieved:");
  49.             displayTextInputStream(objectPortion.getObjectContent());
  50.         } catch (AmazonServiceException ase) {
  51.             System.out.println("Caught an AmazonServiceException, which " + "means your request made it "
  52.                     + "to Amazon S3, but was rejected with an error response" + " for some reason.");
  53.             System.out.println("Error Message:    " + ase.getMessage());
  54.             System.out.println("HTTP Status Code: " + ase.getStatusCode());
  55.             System.out.println("AWS Error Code:   " + ase.getErrorCode());
  56.             System.out.println("Error Type:       " + ase.getErrorType());
  57.             System.out.println("Request ID:       " + ase.getRequestId());
  59.         } catch (AmazonClientException ace) {
  60.             System.out.println("Caught an AmazonClientException, which " + "means the client encountered " + "an internal error while trying to "
  61.                     + "communicate with S3, " + "such as not being able to access the network.");
  62.             System.out.println("Error Message: " + ace.getMessage());
  64.         }
  66.     }
  68.     private static void displayTextInputStream(InputStream input) throws IOException {
  69.         // 按行读取并打印。
  70.         BufferedReader reader = new BufferedReader(new InputStreamReader(input));
  71.         while (true) {
  72.             String line = reader.readLine();
  73.             if (line == null)
  74.                 break;
  76.             System.out.println("    " + line);
  77.         }
  78.         System.out.println();
  79.     }
  80. }

4. 运行程序

  1. ant
  2. Buildfile: /home/ubuntu/aws-java-sdk-1.11.213/samples/AmazonS3/build.xml
  4. run:
  5.      [java] Uploading a new object to S3 from a file
  6.      [java]
  7.      [java] Printing bytes retrieved:
  8.      [java]     127.0.0.1       localhost
  9.      [java]     127.0.1.1       minio
  10.      [java]     
  11.      [java]     # 对于支持IPv6的主机，会有以下几行输出。
  12.      [java]     ::1     localhost ip6-localhost ip6-loopback
  13.      [java]     ff02::1 ip6-allnodes
  14.      [java]     ff02::2 ip6-allrouters
  15.      [java]
  17. BUILD SUCCESSFUL
  18. Total time: 3 seconds

5. 了解更多

原文: https://docs.minio.io/cn/how-to-use-aws-sdk-for-java-with-minio-server.html