@@ -62,7 +62,7 @@ public class RustfsS3Example {
62
62
private static final String SECRET_KEY = " your-secret-key" ;
63
63
private static final String ENDPOINT = " http://your-rustfs-endpoint:9000" ;
64
64
private static final String REGION = " us-east-1" ;
65
-
65
+
66
66
public static void main (String [] args ) {
67
67
// S3-Client konfigurieren
68
68
S3Client s3Client = S3Client . builder()
@@ -73,15 +73,15 @@ public class RustfsS3Example {
73
73
))
74
74
.forcePathStyle(true ) // Wichtig für S3-kompatible Dienste
75
75
.build();
76
-
76
+
77
77
// Grundlegende Operationen durchführen
78
78
listBuckets(s3Client);
79
79
createBucket(s3Client);
80
80
uploadObject(s3Client);
81
81
downloadObject(s3Client);
82
82
deleteObject(s3Client);
83
83
deleteBucket(s3Client);
84
-
84
+
85
85
s3Client. close();
86
86
}
87
87
}
@@ -108,12 +108,12 @@ private static void listBuckets(S3Client s3Client) {
108
108
``` java
109
109
private static void createBucket(S3Client s3Client) {
110
110
String bucketName = " mein-test-bucket" ;
111
-
111
+
112
112
try {
113
113
CreateBucketRequest request = CreateBucketRequest . builder()
114
114
.bucket(bucketName)
115
115
.build();
116
-
116
+
117
117
CreateBucketResponse response = s3Client. createBucket(request);
118
118
System . out. println(" Speicher-Bucket '" + bucketName + " ' erfolgreich erstellt." );
119
119
} catch (BucketAlreadyExistsException e) {
@@ -131,14 +131,14 @@ private static void uploadObject(S3Client s3Client) {
131
131
String bucketName = " mein-test-bucket" ;
132
132
String objectKey = " test-dokument.txt" ;
133
133
String content = " Hallo, RustFS! Dies ist ein Test-Dokument." ;
134
-
134
+
135
135
try {
136
136
PutObjectRequest request = PutObjectRequest . builder()
137
137
.bucket(bucketName)
138
138
.key(objectKey)
139
139
.contentType(" text/plain" )
140
140
.build();
141
-
141
+
142
142
s3Client. putObject(request, RequestBody . fromString(content));
143
143
System . out. println(" Objekt '" + objectKey + " ' erfolgreich hochgeladen." );
144
144
} catch (S3Exception e) {
@@ -153,13 +153,13 @@ private static void uploadObject(S3Client s3Client) {
153
153
private static void downloadObject(S3Client s3Client) {
154
154
String bucketName = " mein-test-bucket" ;
155
155
String objectKey = " test-dokument.txt" ;
156
-
156
+
157
157
try {
158
158
GetObjectRequest request = GetObjectRequest . builder()
159
159
.bucket(bucketName)
160
160
.key(objectKey)
161
161
.build();
162
-
162
+
163
163
GetObjectResponse response = s3Client. getObject(request);
164
164
String content = response. readUtf8String();
165
165
System . out. println(" Objekt-Inhalt: " + content);
@@ -175,13 +175,13 @@ private static void downloadObject(S3Client s3Client) {
175
175
private static void deleteObject(S3Client s3Client) {
176
176
String bucketName = " mein-test-bucket" ;
177
177
String objectKey = " test-dokument.txt" ;
178
-
178
+
179
179
try {
180
180
DeleteObjectRequest request = DeleteObjectRequest . builder()
181
181
.bucket(bucketName)
182
182
.key(objectKey)
183
183
.build();
184
-
184
+
185
185
s3Client. deleteObject(request);
186
186
System . out. println(" Objekt '" + objectKey + " ' erfolgreich gelöscht." );
187
187
} catch (S3Exception e) {
@@ -195,12 +195,12 @@ private static void deleteObject(S3Client s3Client) {
195
195
``` java
196
196
private static void deleteBucket(S3Client s3Client) {
197
197
String bucketName = " mein-test-bucket" ;
198
-
198
+
199
199
try {
200
200
DeleteBucketRequest request = DeleteBucketRequest . builder()
201
201
.bucket(bucketName)
202
202
.build();
203
-
203
+
204
204
s3Client. deleteBucket(request);
205
205
System . out. println(" Speicher-Bucket '" + bucketName + " ' erfolgreich gelöscht." );
206
206
} catch (S3Exception e) {
@@ -220,7 +220,7 @@ private static void getObjectMetadata(S3Client s3Client, String bucketName, Stri
220
220
.bucket(bucketName)
221
221
.key(objectKey)
222
222
.build();
223
-
223
+
224
224
HeadObjectResponse response = s3Client. headObject(request);
225
225
System . out. println(" Objekt-Metadaten:" );
226
226
System . out. println(" - Größe: " + response. contentLength() + " Bytes" );
@@ -242,7 +242,7 @@ private static void listObjects(S3Client s3Client, String bucketName) {
242
242
.bucket(bucketName)
243
243
.maxKeys(10 )
244
244
.build();
245
-
245
+
246
246
ListObjectsV2Response response = s3Client. listObjectsV2(request);
247
247
System . out. println(" Objekte im Speicher-Bucket '" + bucketName + " ':" );
248
248
for (S3Object object : response. contents()) {
@@ -263,14 +263,14 @@ private static void uploadObjectWithMetadata(S3Client s3Client, String bucketNam
263
263
metadata. put(" author" , " RustFS Benutzer" );
264
264
metadata. put(" version" , " 1.0" );
265
265
metadata. put(" description" , " Test-Dokument mit Metadaten" );
266
-
266
+
267
267
PutObjectRequest request = PutObjectRequest . builder()
268
268
.bucket(bucketName)
269
269
.key(objectKey)
270
270
.contentType(" text/plain" )
271
271
.metadata(metadata)
272
272
.build();
273
-
273
+
274
274
String content = " Dieses Objekt enthält benutzerdefinierte Metadaten." ;
275
275
s3Client. putObject(request, RequestBody . fromString(content));
276
276
System . out. println(" Objekt mit Metadaten erfolgreich hochgeladen." );
@@ -316,7 +316,7 @@ try (S3Client s3Client = S3Client.builder()
316
316
))
317
317
.forcePathStyle(true )
318
318
.build()) {
319
-
319
+
320
320
// S3-Operationen durchführen
321
321
// ...
322
322
} // Client wird automatisch geschlossen
0 commit comments