intitle java oss 分片上传 并返回进度条 代码

以下是一个基于Java OSS SDK实现的文件分片上传并返回进度条的代码示例：

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;

import com.aliyun.oss.ClientConfiguration;
import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClientBuilder;
import com.aliyun.oss.model.CompleteMultipartUploadRequest;
import com.aliyun.oss.model.CompleteMultipartUploadResult;
import com.aliyun.oss.model.InitiateMultipartUploadRequest;
import com.aliyun.oss.model.InitiateMultipartUploadResult;
import com.aliyun.oss.model.PartETag;
import com.aliyun.oss.model.UploadPartRequest;
import com.aliyun.oss.model.UploadPartResult;

public class OSSUploader {
    private static final String endpoint = "yourEndpoint";
    private static final String accessKeyId = "yourAccessKeyId";
    private static final String accessKeySecret = "yourAccessKeySecret";
    private static final String bucketName = "yourBucketName";
    private static final String objectName = "yourObjectName";
    private static final int partSize = 1024 * 1024 * 5; // 分片大小

    public static void main(String[] args) throws IOException {
        // 初始化OSS客户端
        ClientConfiguration conf = new ClientConfiguration();
        conf.setConnectionTimeout(5000);
        conf.setMaxErrorRetry(3);
        OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret, conf);

        // 初始化分片上传
        InitiateMultipartUploadRequest initRequest = new InitiateMultipartUploadRequest(bucketName, objectName);
        InitiateMultipartUploadResult initResult = ossClient.initiateMultipartUpload(initRequest);
        String uploadId = initResult.getUploadId();

        // 计算文件分片数
        File file = new File("yourFilePath");
        long fileLength = file.length();
        int partCount = (int) Math.ceil((double) fileLength / partSize);

        // 上传分片并记录分片上传结果
        List<PartETag> partETags = new ArrayList<>();
        for (int i = 0; i < partCount; i++) {
            FileInputStream fis = new FileInputStream(file);
            fis.skip(i * partSize);
            UploadPartRequest uploadPartRequest = new UploadPartRequest();
            uploadPartRequest.setBucketName(bucketName);
            uploadPartRequest.setKey(objectName);
            uploadPartRequest.setUploadId(uploadId);
            uploadPartRequest.setInputStream(fis);
            uploadPartRequest.setPartSize(partSize);
            uploadPartRequest.setPartNumber(i + 1);
            UploadPartResult uploadPartResult = ossClient.uploadPart(uploadPartRequest);
            partETags.add(uploadPartResult.getPartETag());
            fis.close();
            // 计算上传进度并输出
            double progress = (double) (i + 1) / partCount;
            System.out.println("Upload progress: " + progress);
        }

        // 完成分片上传
        CompleteMultipartUploadRequest completeRequest = new CompleteMultipartUploadRequest(bucketName, objectName, uploadId, partETags);
        CompleteMultipartUploadResult completeResult = ossClient.completeMultipartUpload(completeRequest);
        System.out.println("Upload complete!");

        // 关闭OSS客户端
        ossClient.shutdown();
    }
}

该代码示例中，我们使用了阿里云Java OSS SDK来实现文件分片上传。在初始化分片上传时，我们需要调用`ossClient.initiateMultipartUpload()`方法来初始化一个分片上传任务，并获取`uploadId`。在上传分片时，我们需要计算文件的分片数，并循环执行`ossClient.uploadPart()`方法来上传每个分片，并记录每个分片上传的结果。在完成分片上传时，我们需要调用`ossClient.completeMultipartUpload()`方法来完成分片上传任务。

在上传分片时，我们还计算了上传进度，并输出到控制台。这里的上传进度是指已上传的分片数占总分片数的比例。