Java S3 檔案下載教學 - 使用 AWS SDK 的逐步指南

<dependency>
    <groupId>com.amazonaws</groupId>
    <artifactId>aws-java-sdk-s3</artifactId>
    <version>1.12.118</version>
</dependency>

implementation 'com.amazonaws:aws-java-sdk-s3:1.12.118'

<dependency>
    <groupId>com.groupdocs</groupId>
    <artifactId>groupdocs-signature</artifactId>
    <version>23.12</version>
</dependency>

implementation 'com.groupdocs:groupdocs-signature:23.12'

import com.groupdocs.signature.Signature;

public class SignatureSetup {
    public static void main(String[] args) {
        // Initialize with a document path
        Signature signature = new Signature("sample.pdf");
        // You can now add signatures, verify documents, etc.
    }
}

export AWS_ACCESS_KEY_ID=your_access_key_id
export AWS_SECRET_ACCESS_KEY=your_secret_access_key

import com.amazonaws.auth.AWSStaticCredentialsProvider;
import com.amazonaws.auth.BasicAWSCredentials;
import com.amazonaws.services.s3.AmazonS3;
import com.amazonaws.services.s3.AmazonS3ClientBuilder;
import com.amazonaws.regions.Regions;

public class S3FileDownloader {
    private static final String ACCESS_KEY = "<AWS access key>";
    private static final String SECRET_KEY = "<AWS secret key>";

    public static void main(String[] args) {
        // Create credentials object
        BasicAWSCredentials awsCreds = new BasicAWSCredentials(ACCESS_KEY, SECRET_KEY);
        
        // Build S3 client with credentials and region
        AmazonS3 s3Client = AmazonS3ClientBuilder.standard()
                .withRegion(Regions.US_EAST_1)  // Change to your bucket's region
                .withCredentials(new AWSStaticCredentialsProvider(awsCreds))
                .build();

        // Now we're ready to download files
    }
}

import com.amazonaws.services.s3.model.S3Object;
import com.amazonaws.services.s3.model.S3ObjectInputStream;
import java.io.FileOutputStream;
import java.io.IOException;

public class S3FileDownloader {
    public static void main(String[] args) {
        // ... previous credential and client setup code ...

        String bucketName = "your-bucket-name";
        String fileKey = "path/to/your/file.pdf";  // The file's key (path) in S3
        String localFilePath = "downloaded-file.pdf";

        try {
            // Get the S3 object
            S3Object s3Object = s3Client.getObject(bucketName, fileKey);
            S3ObjectInputStream inputStream = s3Object.getObjectContent();

            // Save to local file
            FileOutputStream outputStream = new FileOutputStream(localFilePath);
            byte[] readBuffer = new byte[1024];
            int readLength;

            while ((readLength = inputStream.read(readBuffer)) > 0) {
                outputStream.write(readBuffer, 0, readLength);
            }

            // Clean up
            inputStream.close();
            outputStream.close();

            System.out.println("File downloaded successfully to: " + localFilePath);

        } catch (IOException e) {
            System.err.println("Error downloading file: " + e.getMessage());
            e.printStackTrace();
        }
    }
}

import com.amazonaws.services.s3.model.S3Object;
import com.amazonaws.services.s3.model.S3ObjectInputStream;
import com.amazonaws.AmazonServiceException;
import java.io.FileOutputStream;
import java.io.IOException;

public class S3FileDownloader {
    public static void downloadFile(AmazonS3 s3Client, String bucketName, 
                                   String fileKey, String localFilePath) {
        try (S3Object s3Object = s3Client.getObject(bucketName, fileKey);
             S3ObjectInputStream inputStream = s3Object.getObjectContent();
             FileOutputStream outputStream = new FileOutputStream(localFilePath)) {
            
            byte[] readBuffer = new byte[4096];  // Larger buffer for better performance
            int readLength;
            
            while ((readLength = inputStream.read(readBuffer)) > 0) {
                outputStream.write(readBuffer, 0, readLength);
            }
            
            System.out.println("Successfully downloaded: " + fileKey);
            
        } catch (AmazonServiceException e) {
            // AWS service error (wrong bucket, no permissions, etc.)
            System.err.println("AWS Error: " + e.getErrorMessage());
            System.err.println("Error Code: " + e.getErrorCode());
        } catch (IOException e) {
            // File I/O error
            System.err.println("File I/O Error: " + e.getMessage());
        }
    }
}

// Don't just default to US_EAST_1
.withRegion(Regions.US_EAST_1)  // ❌ Might be wrong

// Match your bucket's actual region
.withRegion(Regions.EU_WEST_1)  // ✅ Correct for EU buckets

{
  "Effect": "Allow",
  "Action": [
    "s3:GetObject",
    "s3:ListBucket"
  ],
  "Resource": [
    "arn:aws:s3:::your-bucket-name/*",
    "arn:aws:s3:::your-bucket-name"
  ]
}

String accessKey = System.getenv("AWS_ACCESS_KEY_ID");
String secretKey = System.getenv("AWS_SECRET_ACCESS_KEY");

// No credentials needed with IAM roles!
AmazonS3 s3Client = AmazonS3ClientBuilder.standard()
        .withRegion(Regions.US_EAST_1)
        .build();  // SDK uses IAM role automatically

public class BackupRetrieval {
    public void downloadTodaysBackup(AmazonS3 s3Client) {
        String today = LocalDate.now().format(DateTimeFormatter.ISO_DATE);
        String backupKey = "backups/database-" + today + ".sql.gz";
        downloadFile(s3Client, "backup-bucket", backupKey, "/local/backups/");
    }
}

public class CMSFileRetrieval {
    public File getUserUpload(AmazonS3 s3Client, String userId, String fileId) {
        String fileKey = "uploads/" + userId + "/" + fileId;
        String localPath = "/tmp/" + fileId;
        downloadFile(s3Client, "cms-uploads", fileKey, localPath);
        return new File(localPath);
    }
}

public class DocumentProcessor {
    public void processDocument(AmazonS3 s3Client, String documentKey) {
        String localPath = downloadFromS3(s3Client, documentKey);
        
        // Process with GroupDocs.Signature
        Signature signature = new Signature(localPath);
        // Add signatures, convert formats, extract text, etc.
        
        // Upload processed document back to S3 (if needed)
    }
}

public class DataProcessor {
    public void processDataset(AmazonS3 s3Client, List<String> fileKeys) {
        ExecutorService executor = Executors.newFixedThreadPool(5);
        
        for (String key : fileKeys) {
            executor.submit(() -> {
                downloadAndProcess(s3Client, key);
            });
        }
        
        executor.shutdown();
    }
}

byte[] buffer = new byte[8192];  // Good for most files
byte[] largeBuffer = new byte[16384];  // Better for large files

ExecutorService executor = Executors.newFixedThreadPool(10);

for (String fileKey : fileKeys) {
    executor.submit(() -> downloadFile(s3Client, bucketName, fileKey, localPath));
}

executor.shutdown();
executor.awaitTermination(1, TimeUnit.HOURS);

TransferManager transferManager = TransferManagerBuilder.standard()
        .withS3Client(s3Client)
        .build();

Download download = transferManager.download(bucketName, fileKey, new File(localPath));
download.waitForCompletion();

ClientConfiguration clientConfig = new ClientConfiguration();
clientConfig.setMaxConnections(50);  // Default is 50, increase if needed

AmazonS3 s3Client = AmazonS3ClientBuilder.standard()
        .withClientConfiguration(clientConfig)
        .build();

import com.groupdocs.signature.Signature;
import com.groupdocs.signature.domain.signatures.TextSignature;

public class S3DocumentSigning {
    public void signDocumentFromS3(AmazonS3 s3Client) {
        // 1. Download document from S3
        String documentKey = "contracts/agreement.pdf";
        String localPath = "temp-agreement.pdf";
        downloadFile(s3Client, "documents-bucket", documentKey, localPath);
        
        // 2. Initialize GroupDocs.Signature
        Signature signature = new Signature(localPath);
        
        // 3. Add signature
        TextSignature textSignature = new TextSignature("John Doe");
        signature.sign(localPath.replace(".pdf", "-signed.pdf"), textSignature);
        
        // 4. (Optional) Upload signed document back to S3
        // uploadToS3(s3Client, localPath.replace(".pdf", "-signed.pdf"));
    }
}

ClientConfiguration config = new ClientConfiguration();
config.setSocketTimeout(300000);  // 5 minutes

// Good: Automatic cleanup
try (S3Object s3Object = s3Client.getObject(bucket, key)) {
    // Process object
}  // Automatically closed

// Also good: Manual cleanup in finally block
S3Object s3Object = null;
try {
    s3Object = s3Client.getObject(bucket, key);
    // Process object
} finally {
    if (s3Object != null) {
        s3Object.close();
    }
}

S3Object s3Object = s3Client.getObject(bucket, key);
InputStream stream = s3Object.getObjectContent();
// Process stream directly without saving to disk