Java Awssdk S3 Liệt kê các đối tượng trong S3 Bucket

import software.amazon.awssdk.auth.credentials.AwsBasicCredentials;
import software.amazon.awssdk.auth.credentials.AwsCredentials;
import software.amazon.awssdk.auth.credentials.AwsCredentialsProvider;
import software.amazon.awssdk.auth.credentials.StaticCredentialsProvider;
import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.s3.S3Client;

public class MyUtils {  

	public static S3Client createS3Client(Region region) {
		AwsCredentials credentials = AwsBasicCredentials.create("accessKeyId", "secretAccessKey");
		AwsCredentialsProvider credentialsProvider = StaticCredentialsProvider.create(credentials);

		S3Client client = S3Client.builder() //
				.credentialsProvider(credentialsProvider) //
				.region(region) //
				.build();

		return client;
	} 
}

<!-- https://mvnrepository.com/artifact/software.amazon.awssdk/s3 -->
<dependency>
	<groupId>software.amazon.awssdk</groupId>
	<artifactId>s3</artifactId>
	<version>2.21.10</version>
</dependency>

<!-- https://mvnrepository.com/artifact/software.amazon.awssdk/s3-transfer-manager -->
<dependency>
    <groupId>software.amazon.awssdk</groupId>
    <artifactId>s3-transfer-manager</artifactId>
    <version>2.21.10</version>
</dependency>

<!-- https://mvnrepository.com/artifact/software.amazon.awssdk.crt/aws-crt -->
<dependency>
    <groupId>software.amazon.awssdk.crt</groupId>
    <artifactId>aws-crt</artifactId>
    <version>0.28.0</version>
</dependency>

<!-- Log Library -->
<!-- https://mvnrepository.com/artifact/org.slf4j/slf4j-api -->
<dependency>
    <groupId>org.slf4j</groupId>
    <artifactId>slf4j-api</artifactId>
    <version>2.0.9</version>
</dependency>

<!-- Log Library -->
<!-- https://mvnrepository.com/artifact/org.slf4j/slf4j-simple -->
<dependency>
    <groupId>org.slf4j</groupId>
    <artifactId>slf4j-simple</artifactId>
    <version>2.0.9</version> 
</dependency>  

package org.o7planning.java_14211_awssdk_s3;

import java.util.List;

import org.o7planning.awssdks3.utils.MyUtils;

import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.s3.S3Client;
import software.amazon.awssdk.services.s3.model.ListObjectsV2Request;
import software.amazon.awssdk.services.s3.model.ListObjectsV2Response;
import software.amazon.awssdk.services.s3.model.S3Exception;
import software.amazon.awssdk.services.s3.model.S3Object;

public class ListObjectV2TokenExample {
	private static Region myRegion = Region.EU_CENTRAL_1;
	private static String myBucket = "test1.o7planning.org"; // Change to your bucket name

	private static final int MAX_KEYS_PER_REQUEST = 10;

	private static void listAllObjectsInBucket(S3Client s3Client, String bucketName) {
		String nextContinuationToken = null;

		int requestNo = 0;
		do {
			requestNo++;
			ListObjectsV2Request.Builder requestBuilder = ListObjectsV2Request.builder() //
					.bucket(bucketName) //
					.maxKeys(MAX_KEYS_PER_REQUEST) // Optional (Default 1000).
					.continuationToken(nextContinuationToken);

			ListObjectsV2Response response = s3Client.listObjectsV2(requestBuilder.build());
			List<S3Object> s3Objects = response.contents();

			nextContinuationToken = response.nextContinuationToken();

			System.out.println("Request " + requestNo + " returns " + s3Objects.size() + " keys");
			System.out.println(" - nextContinuationToken: " + nextContinuationToken);
		} while (nextContinuationToken != null);
	}

	public static void main(String[] args) {
		S3Client s3Client = MyUtils.createS3Client(myRegion);

		try {
			listAllObjectsInBucket(s3Client, myBucket);
		} catch (S3Exception e) {
			System.err.println(e.awsErrorDetails().errorMessage());
			e.printStackTrace();
			System.exit(1);
		}
	}
}

package org.o7planning.java_14211_awssdk_s3;

import java.util.Iterator;
import java.util.List;

import org.o7planning.awssdks3.utils.MyUtils;

import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.s3.S3Client;
import software.amazon.awssdk.services.s3.model.ListObjectsV2Request;
import software.amazon.awssdk.services.s3.model.ListObjectsV2Response;
import software.amazon.awssdk.services.s3.model.S3Exception;
import software.amazon.awssdk.services.s3.model.S3Object;
import software.amazon.awssdk.services.s3.paginators.ListObjectsV2Iterable;

public class ListObjectsV2Example1 {
	private static Region myRegion = Region.EU_CENTRAL_1;
	private static String myBucket = "test1.o7planning.org"; // Change to your bucket name

	private static final int MAX_KEYS_PER_REQUEST = 10;

	private static void listBucketObjects(S3Client s3Client, String bucketName) { 
		ListObjectsV2Request listV2Request = ListObjectsV2Request.builder() //
				.bucket(bucketName) //
				.maxKeys(MAX_KEYS_PER_REQUEST) //
				.build();

		ListObjectsV2Iterable listResponse = s3Client.listObjectsV2Paginator(listV2Request);
		Iterator<ListObjectsV2Response> responseIterator = listResponse.iterator();

		int requestNo = 0;
		while (responseIterator.hasNext()) {
			requestNo++;
			ListObjectsV2Response response = responseIterator.next();
			List<S3Object> s3Objects = response.contents();
			System.out.println("Request " + requestNo + " returns " + s3Objects.size() + " keys");
		} 
	}

	public static void main(String[] args) {
		S3Client s3Client = MyUtils.createS3Client(myRegion);

		try {
			listBucketObjects(s3Client, myBucket);
		} catch (S3Exception e) {
			System.err.println(e.awsErrorDetails().errorMessage());
			e.printStackTrace();
			System.exit(1);
		}
	}
}

ListObjectsV2Request listReq = ListObjectsV2Request.builder() //
		.bucket(bucketName) //
		.maxKeys(MAX_KEYS_PER_REQUEST) //
		.prefix("static/images/") // Key Prefix
		.build();

package org.o7planning.java_14211_awssdk_s3;

import java.time.Instant;
import java.time.LocalDateTime;
import java.time.ZoneOffset;
import java.util.Iterator;
import java.util.List;
import java.util.Map;

import org.o7planning.awssdks3.utils.MyUtils;

import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.s3.S3Client;
import software.amazon.awssdk.services.s3.model.HeadObjectRequest;
import software.amazon.awssdk.services.s3.model.HeadObjectResponse;
import software.amazon.awssdk.services.s3.model.ListObjectsV2Request;
import software.amazon.awssdk.services.s3.model.ListObjectsV2Response;
import software.amazon.awssdk.services.s3.model.S3Exception;
import software.amazon.awssdk.services.s3.model.S3Object;
import software.amazon.awssdk.services.s3.paginators.ListObjectsV2Iterable;

public class ListObjectsV2Example2 {
	private static Region myRegion = Region.EU_CENTRAL_1;
	private static String myBucket = "test1.o7planning.org"; // Change to your bucket name

	private static final int MAX_KEYS_PER_REQUEST = 10;

	private static void listBucketObjects(S3Client s3Client, String bucketName) {
		ListObjectsV2Request listV2Request = ListObjectsV2Request.builder() //
				.bucket(bucketName) //
				.maxKeys(MAX_KEYS_PER_REQUEST) //
				.build();

		ListObjectsV2Iterable listResponse = s3Client.listObjectsV2Paginator(listV2Request);
		Iterator<ListObjectsV2Response> responseIterator = listResponse.iterator();

		while (responseIterator.hasNext()) {
			ListObjectsV2Response response = responseIterator.next();
			List<S3Object> s3Objects = response.contents();
			//
			for (S3Object s3Object : s3Objects) {
				System.out.println("\n\nObject Key: " + s3Object.key());
				System.out.println("Size: " + toKB(s3Object.size()) + " KB");
				System.out.println("Owner: " + s3Object.owner());
				//
				Instant instant = s3Object.lastModified();
				LocalDateTime lastModified = LocalDateTime.ofInstant(instant, ZoneOffset.UTC);
				System.out.println("Last Modified: " + lastModified);
				//
				moreInfo(s3Client, bucketName, s3Object.key());
			}
		}
	}

	private static void moreInfo(S3Client s3Client, String bucketName, String objectKey) {
		HeadObjectRequest headObjectRequest = HeadObjectRequest.builder() //
				.bucket(bucketName) //
				.key(objectKey) //
				.build();
		HeadObjectResponse headObjectResponse = s3Client.headObject(headObjectRequest);
		//
		System.out.println(" - contentType: " + headObjectResponse.contentType());
		System.out.println(" - cacheControl: " + headObjectResponse.cacheControl());
		System.out.println(" - websiteRedirectLocation: " + headObjectResponse.websiteRedirectLocation());
		//
		Map<String, String> metadata = headObjectResponse.metadata();
		System.out.println(" User Defined Metadata: " + metadata);
		for (String metaKey : metadata.keySet()) {
			System.out.println(" Metadata " + metaKey + " : " + metadata.get(metaKey));
		}
	}

	// Convert bytes to KB.
	private static long toKB(long bytes) {
		return bytes / 1024;
	}

	public static void main(String[] args) {
		S3Client s3Client = MyUtils.createS3Client(myRegion);

		try {
			listBucketObjects(s3Client, myBucket);
		} catch (S3Exception e) {
			System.err.println(e.awsErrorDetails().errorMessage());
			e.printStackTrace();
			System.exit(1);
		}
	}
}