package jnpf.fileStorage;
|
|
import io.minio.BucketExistsArgs;
|
import org.dromara.x.file.storage.core.platform.MinioFileStorage;
|
import org.springframework.stereotype.Component;
|
|
@Component
|
public class SeaweedFsBucketVerifier {
|
|
public void verify(MinioFileStorage storage) {
|
String bucketName = storage.getBucketName();
|
try {
|
boolean exists = storage.getClient().bucketExists(BucketExistsArgs.builder()
|
.bucket(bucketName)
|
.build());
|
if (!exists) {
|
throw new IllegalStateException("SeaweedFS bucket 不存在: " + bucketName);
|
}
|
} catch (IllegalStateException exception) {
|
throw exception;
|
} catch (Exception exception) {
|
throw new IllegalStateException("SeaweedFS bucket 无法访问: " + bucketName, exception);
|
}
|
}
|
}
|
