详解如何在Java中使用阿里云对象存储OSS

public static void uploadFile(String endpoint, String accessKeyId, String accessKeySecret, String bucketName, String objectName, String filePath) {
    // 创建 OSSClient 对象
    OSSClient ossClient = new OSSClient(endpoint, accessKeyId, accessKeySecret);
    try {
        // 判断 Bucket 是否存在，如果不存在则创建
        if (!ossClient.doesBucketExist(bucketName)) {
            ossClient.createBucket(bucketName);
        }
        // 上传文件
        ossClient.putObject(bucketName, objectName, new File(filePath));
    } catch (Exception e) {
        e.printStackTrace();
    } finally {
        // 关闭 OSSClient
        ossClient.shutdown();
    }
}

public static void uploadBigFile(String endpoint, String accessKeyId, String accessKeySecret, String bucketName, String objectName, String filePath) {
    // 创建 OSSClient 对象
    OSSClient ossClient = new OSSClient(endpoint, accessKeyId, accessKeySecret);
    try {
        // 判断 Bucket 是否存在，如果不存在则创建
        if (!ossClient.doesBucketExist(bucketName)) {
            ossClient.createBucket(bucketName);
        }
        // 设置分块大小为1MB
        long partSize = 1024 * 1024L;
        // 初始化分块上传
        InitiateMultipartUploadResult initiateMultipartUploadResult = ossClient.initiateMultipartUpload(bucketName, objectName);
        // 获取 UploadId
        String uploadId = initiateMultipartUploadResult.getUploadId();
        // 获取文件大小
        File file = new File(filePath);
        long fileSize = file.length();
        // 计算分块数
        int partCount = (int) (fileSize / partSize);
        if (fileSize % partSize != 0) {
            partCount++;
        }
        // 初始化 PartETag 数组
        List<PartETag> partETags = new ArrayList<>();
        // 分块上传
        for (int i = 0; i < partCount; i++) {
            // 计算分块大小和起始位置
            long startPos = i * partSize;
            long curPartSize = Math.min(partSize, fileSize - startPos);
            FileInputStream inputStream = new FileInputStream(file);
            inputStream.skip(startPos);
            // 上传分块
            UploadPartRequest uploadPartRequest = new UploadPartRequest();
            uploadPartRequest.setBucketName(bucketName);
            uploadPartRequest.setKey(objectName);
            uploadPartRequest.setUploadId(uploadId);
            uploadPartRequest.setInputStream(inputStream);
            uploadPartRequest.setPartSize(curPartSize);
            uploadPartRequest.setPartNumber(i + 1);
            UploadPartResult uploadPartResult = ossClient.uploadPart(uploadPartRequest);
            // 将 PartETag 添加到数组中
            partETags.add(uploadPartResult.getPartETag());
            // 关闭文件流
            inputStream.close();
        }
        // 完成分块上传
        CompleteMultipartUploadRequest completeMultipartUploadRequest = new CompleteMultipartUploadRequest(bucketName, objectName, uploadId, partETags);
        ossClient.completeMultipartUpload(completeMultipartUploadRequest);
    } catch (Exception e) {
        e.printStackTrace();
    } finally {
        // 关闭 OSSClient
        ossClient.shutdown();
    }
}

public static void downloadFile(String endpoint, String accessKeyId, String accessKeySecret, String bucketName, String objectName, String savePath) {
    // 创建 OSSClient 对象
    OSSClient ossClient = new OSSClient(endpoint, accessKeyId, accessKeySecret);
    try {
        // 下载文件
        ossClient.getObject(new GetObjectRequest(bucketName, objectName), new File(savePath));
    } catch (Exception e) {
        e.printStackTrace();
    } finally {
        // 关闭 OSSClient
        ossClient.shutdown();
    }
}