请用OSS的java SDK 进行多线程并发下载并通过内置的监听器来实现进度条效果具体代码+依赖坐标演示

以下是基于OSS的Java SDK实现多线程并发下载和进度条效果的示例代码和依赖坐标：

import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClientBuilder;
import com.aliyun.oss.event.ProgressEvent;
import com.aliyun.oss.event.ProgressEventType;
import com.aliyun.oss.event.ProgressListener;
import com.aliyun.oss.model.GetObjectRequest;
import com.aliyun.oss.model.OSSObject;

import java.io.File;
import java.io.IOException;
import java.io.RandomAccessFile;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class OSSMultiThreadDownloader {

    private static final int THREAD_COUNT = 5; // 线程数
    private static final int BUFFER_SIZE = 1024 * 1024; // 缓冲区大小

    private final OSS ossClient;
    private final String bucketName;
    private final String objectKey;
    private final String filePath;
    private final long objectSize;

    public OSSMultiThreadDownloader(String endpoint, String accessKeyId, String accessKeySecret,
                                     String bucketName, String objectKey, String filePath) {
        this.ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
        this.bucketName = bucketName;
        this.objectKey = objectKey;
        this.filePath = filePath;
        this.objectSize = ossClient.getObjectMetadata(bucketName, objectKey).getContentLength();
    }

    public void download() throws IOException {
        ExecutorService executorService = Executors.newFixedThreadPool(THREAD_COUNT);

        long blockSize = objectSize / THREAD_COUNT;
        long startPos = 0;
        long endPos = blockSize;
        for (int i = 0; i < THREAD_COUNT; i++) {
            if (i == THREAD_COUNT - 1) {
                endPos = objectSize;
            }
            DownloadTask task = new DownloadTask(i, startPos, endPos);
            executorService.execute(task);

            startPos = endPos + 1;
            endPos += blockSize;
        }

        executorService.shutdown();
    }

    private class DownloadTask implements Runnable {

        private final int threadIndex;
        private final long startPos;
        private final long endPos;

        public DownloadTask(int threadIndex, long startPos, long endPos) {
            this.threadIndex = threadIndex;
            this.startPos = startPos;
            this.endPos = endPos;
        }

        @Override
        public void run() {
            try {
                RandomAccessFile raf = new RandomAccessFile(new File(filePath), "rw");
                raf.seek(startPos);

                GetObjectRequest getObjectRequest = new GetObjectRequest(bucketName, objectKey);
                getObjectRequest.setRange(startPos, endPos);
                getObjectRequest.setProgressListener(new ProgressListener() {
                    @Override
                    public void progressChanged(ProgressEvent progressEvent) {
                        if (progressEvent.getEventType() == ProgressEventType.REQUEST_BYTE_TRANSFER_EVENT) {
                            System.out.println("Thread " + threadIndex + " downloaded " +
                                    progressEvent.getBytesTransferred() + " bytes");
                        }
                    }
                });

                OSSObject ossObject = ossClient.getObject(getObjectRequest);
                byte[] buffer = new byte[BUFFER_SIZE];
                int bytesRead;
                while ((bytesRead = ossObject.getObjectContent().read(buffer)) != -1) {
                    raf.write(buffer, 0, bytesRead);
                }

                ossObject.getObjectContent().close();
                raf.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    public static void main(String[] args) throws IOException {
        String endpoint = "your_endpoint";
        String accessKeyId = "your_access_key_id";
        String accessKeySecret = "your_access_key_secret";
        String bucketName = "your_bucket_name";
        String objectKey = "your_object_key";
        String filePath = "your_file_path";

        OSSMultiThreadDownloader downloader = new OSSMultiThreadDownloader(endpoint, accessKeyId, accessKeySecret,
                bucketName, objectKey, filePath);
        downloader.download();
    }
}

依赖坐标：

<dependency>
    <groupId>com.aliyun.oss</groupId>
    <artifactId>aliyun-sdk-oss</artifactId>
    <version>3.11.0</version>
</dependency>
``