import software.amazon.awssdk.services.s3.model.PutObjectResponse; //导入依赖的package包/类
public static void main(String[] args) {
	S3AsyncClient client = S3AsyncClient.create();
    CompletableFuture<PutObjectResponse> future = client.putObject(
            PutObjectRequest.builder()
                            .bucket(BUCKET)
                            .key(KEY)
                            .build(),
            AsyncRequestProvider.fromFile(Paths.get("myfile.in"))
    );
    future.whenComplete((resp, err) -> {
        try {
            if (resp != null) {
                System.out.println("my response: " + resp);
            } else {
                // Handle error
                err.printStackTrace();
            }
        } finally {
            // Lets the application shut down. Only close the client when you are completely done with it.
            FunctionalUtils.invokeSafely(client::close);
        }
    });
}
 

import software.amazon.awssdk.services.s3.model.PutObjectResponse; //导入依赖的package包/类
/**
 * {@inheritDoc}
 */
@Override
public PutObjectResponse putObject(final PutObjectRequest putObjectRequest, final RequestBody requestBody) {
    return this.s3Client.putObject(putObjectRequest, requestBody);
}
 

import software.amazon.awssdk.services.s3.model.PutObjectResponse; //导入依赖的package包/类
/**
 * Convenience method to synchronously upload from the given file to the
 * Amazon S3 object represented by this S3Link.
 *
 * @param source
 *            source file to upload from
 *
 * @return A {@link PutObjectResponse} object containing the information
 *         returned by Amazon S3 for the newly created object.
 */
public PutObjectResponse uploadFrom(final File source) {
    return getAmazonS3Client().putObject(PutObjectRequest.builder()
                                                         .bucket(bucketName())
                                                         .key(getKey())
                                                         .build(), RequestBody.of(source));
}