com.aliyun.oss.OSSException: The specified bucket does not exist.

import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClientBuilder;
import com.aliyun.oss.model.Bucket;

public class OssBucketValidator {
    public static void validateAndCreateBucket(String endpoint, String accessKeyId, String accessKeySecret, String bucketName) {
        OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
        try {
            if (!ossClient.doesBucketExist(bucketName)) {
                // 創(chuàng)建存儲桶
                ossClient.createBucket(bucketName);
                System.out.println("存儲桶 " + bucketName + " 創(chuàng)建成功。");
            } else {
                System.out.println("存儲桶 " + bucketName + " 已存在。");
            }
        } finally {
            ossClient.shutdown();
        }
    }
}

import com.aliyun.oss.OSSException;
import org.springframework.http.HttpStatus;
import org.springframework.web.bind.annotation.ControllerAdvice;
import org.springframework.web.bind.annotation.ExceptionHandler;
import org.springframework.web.bind.annotation.ResponseBody;

@ControllerAdvice
public class OssExceptionAdvice {

    @ExceptionHandler(OSSException.class)
    @ResponseBody
    public String handleOssException(OSSException ex) {
        return "OSS服務(wù)異常: " + ex.getMessage();
    }
}

# application.yml
oss:
  endpoint: oss-cn-hangzhou.aliyuncs.com
  accessKeyId: your-access-key-id
  accessKeySecret: your-access-key-secret
  bucketName: my-demo-bucket

import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;

@Component
@ConfigurationProperties(prefix = "oss")
public class OssProperties {
    private String endpoint;
    private String accessKeyId;
    private String accessKeySecret;
    private String bucketName;

    // Getters and Setters
}

import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClientBuilder;

public class OssClientFactory {
    public static OSS createOssClient(String endpoint, String accessKeyId, String accessKeySecret) {
        return new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
    }
}

public interface ObjectStorageStrategy {
    void upload(String objectKey, InputStream inputStream);
}

public class AliyunOssStrategy implements ObjectStorageStrategy {
    @Override
    public void upload(String objectKey, InputStream inputStream) {
        // 阿里云OSS上傳邏輯
    }
}

public class HuaWeiObsStrategy implements ObjectStorageStrategy {
    @Override
    public void upload(String objectKey, InputStream inputStream) {
        // 華為云OBS上傳邏輯
    }
}

import com.aliyun.oss.OSS;
import org.junit.jupiter.api.Test;
import org.mockito.Mockito;

import static org.junit.jupiter.api.Assertions.*;

public class OssBucketValidatorTest {

    @Test
    public void testBucketExists() {
        OSS mockOss = Mockito.mock(OSS.class);
        Mockito.when(mockOss.doesBucketExist("my-demo-bucket")).thenReturn(true);
        assertTrue(OssBucketValidator.validateBucketExists(mockOss, "my-demo-bucket"));
    }
}