JavaSDK實現資料流分區上傳的代碼範例 -

概述

OSS的Java SDK提供了分區上傳的範例，具體代碼中使用的是實現本地檔案的分區上傳。但是在實際使用過程中，服務端可能擷取的是網路流資料並用來進行分區上傳，該方法需要將網路流資料儲存為本地檔案後，再上傳該檔案，這便會涉及中轉儲存的再上傳步驟，即非即時的上傳。本文主要提供資料流分區上傳的實現範例。

詳細資料

資料流分區上傳中，需要對資料流進行clone操作。以下是資料流分區上傳的代碼範例。

說明

代碼中cloneInputStream是複製資料流的實現。

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.ArrayList;
import java.util.List;

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 MutilpartUpload {
    public static void main(String[] args) {
// Endpoint以杭州為例，其它Region請按實際情況填寫。
        String endpoint = "http://oss-cn-hangzhou.aliyuncs.com";
// 阿里雲主帳號AccessKey擁有所有API的存取權限，風險很高。強烈建議您建立並使用RAM帳號進行API訪問或日常營運，請登入RAM控制台建立RAM帳號。
        String accessKeyId = "xxx";
        String accessKeySecret = "xxx";
        String bucketName = "dahecs1";
// <yourObjectName>表示上傳檔案到OSS時需要指定包含檔案尾碼在內的完整路徑，例如abc/efg/123.jpg。
        String objectName = "11/aaaatest11123";

        String filePath = "/Users/wanghe/Downloads/aaaatest111";

// 建立OSSClient執行個體。
        OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);

// 建立InitiateMultipartUploadRequest對象。
        InitiateMultipartUploadRequest request = new InitiateMultipartUploadRequest(bucketName, objectName);

// 如果需要在初始化分區時設定檔案儲存體類型，請參考以下範例程式碼。
// ObjectMetadata metadata = new ObjectMetadata();
// metadata.setHeader(OSSHeaders.OSS_STORAGE_CLASS, StorageClass.Standard.toString());
// request.setObjectMetadata(metadata);

// 初始化分區。
        InitiateMultipartUploadResult upresult = ossClient.initiateMultipartUpload(request);
// 返回uploadId，它是分區上傳事件的唯一標識，您可以根據這個uploadId發起相關的操作，如取消分區上傳、查詢分區上傳等。
        String uploadId = upresult.getUploadId();

// partETags是PartETag的集合。PartETag由分區的ETag和分區號組成。
        List<PartETag> partETags = new ArrayList<PartETag>();
// 計算檔案有多少個分區。
        try {
            InputStream instream = new FileInputStream(filePath);

            final long partSize = 1 * 1024 * 1024L; // 1MB
            final File sampleFile = new File(filePath);
            long fileLength1 = sampleFile.length();
            long fileLength = instream.available();
            int partCount = (int) (fileLength / partSize);
            if (fileLength % partSize != 0) {
                partCount++;
            }
// 遍曆分區上傳。
            ByteArrayOutputStream baos = cloneInputStream(instream);
//InputStream stream2 = null;
            for (int i = 0; i < partCount; i++) {
                System.out.println("i= "+i);
                long startPos = i * partSize;
                long curPartSize = (i + 1 == partCount) ? (fileLength - startPos) : partSize;
                InputStream stream1 = new ByteArrayInputStream(baos.toByteArray());
                System.out.println("長度"+stream1.available());
//InputStream instream = new FileInputStream(sampleFile);
// 跳過已經上傳的分區。
                stream1.skip(startPos);
                UploadPartRequest uploadPartRequest = new UploadPartRequest();
                uploadPartRequest.setBucketName(bucketName);
                uploadPartRequest.setKey(objectName);
                uploadPartRequest.setUploadId(uploadId);
                uploadPartRequest.setInputStream(stream1);
// 設定分區大小。除了最後一個分區沒有大小限制，其他的分區最小為100 KB。
                uploadPartRequest.setPartSize(curPartSize);
// 設定分區號。每一個上傳的分區都有一個分區號，取值範圍是1~10000，如果超出這個範圍，OSS將返回InvalidArgument的錯誤碼。
                uploadPartRequest.setPartNumber( i + 1);
// 每個分區不需要按順序上傳，甚至可以在不同用戶端上傳，OSS會按照分區號排序組成完整的檔案。
                UploadPartResult uploadPartResult = ossClient.uploadPart(uploadPartRequest);
// 每次上傳分區之後，OSS的返回結果包含PartETag。PartETag將被儲存在partETags中。
                partETags.add(uploadPartResult.getPartETag());
                if (stream1 != null) {
                    try {
                        stream1.close();
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }
            }


// 建立CompleteMultipartUploadRequest對象。
// 在執行完成分區上傳操作時，需要提供所有有效partETags。OSS收到提交的partETags後，會逐一驗證每個分區的有效性。當所有的資料分區驗證通過後，OSS將把這些分區組合成一個完整的檔案。
            CompleteMultipartUploadRequest completeMultipartUploadRequest =
                    new CompleteMultipartUploadRequest(bucketName, objectName, uploadId, partETags);

// 如果需要在完成檔案上傳的同時設定檔案存取權限，請參考以下範例程式碼。
// completeMultipartUploadRequest.setObjectACL(CannedAccessControlList.PublicRead);

// 完成上傳。
            CompleteMultipartUploadResult completeMultipartUploadResult = ossClient.completeMultipartUpload(completeMultipartUploadRequest);
            baos.close();
// 關閉OSSClient。
            ossClient.shutdown();

        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    private static ByteArrayOutputStream cloneInputStream(InputStream input) {
        try {
            ByteArrayOutputStream baos = new ByteArrayOutputStream();
            byte[] buffer = new byte[1024];
            int len;
            while ((len = input.read(buffer)) > -1) {
                baos.write(buffer, 0, len);
            }
            baos.flush();
            return baos;
        } catch (IOException e) {
            e.printStackTrace();
            return null;
        }
    }
}

適用於

Object Storage Service

：JavaSDK實現資料流分區上傳的代碼範例

概述

詳細資料

相關文檔

適用於