You need to enable JavaScript to run this app.
导航
对象存储
  • 文档首页
    • /对象存储/SDK 参考/Android/对象接口/拷贝对象/分片拷贝（Android SDK）
分片拷贝（Android SDK）
最近更新时间：2024.02.04 18:31:01首次发布时间：2022.12.01 16:31:40
我的收藏

对象大于 1GiB 时，建议您使用 uploadPartCopy 来进行分片拷贝。本文介绍分片拷贝的步骤和示例代码。

分片拷贝步骤

  1. 通过 createMultipartUpload 初始化分片拷贝任务；
  2. 通过 uploadPartCopy 进行分片拷贝；
  3. 通过 completeMultipartUpload 合并分片；

示例代码

以下代码用于通过 copyObject 拷贝 srcBucketName 桶中 srcObjectKey 对象到 bucketName 桶中，并设置对象名为 objectKey。

import android.os.Bundle;
import android.util.Log;

import androidx.appcompat.app.AppCompatActivity;

import com.volcengine.tos.TOSV2;
import com.volcengine.tos.TOSV2ClientBuilder;
import com.volcengine.tos.TosException;
import com.volcengine.tos.model.object.CompleteMultipartUploadV2Input;
import com.volcengine.tos.model.object.CompleteMultipartUploadV2Output;
import com.volcengine.tos.model.object.CreateMultipartUploadInput;
import com.volcengine.tos.model.object.CreateMultipartUploadOutput;
import com.volcengine.tos.model.object.HeadObjectV2Input;
import com.volcengine.tos.model.object.HeadObjectV2Output;
import com.volcengine.tos.model.object.UploadPartCopyV2Input;
import com.volcengine.tos.model.object.UploadPartCopyV2Output;
import com.volcengine.tos.model.object.UploadedPartV2;

import java.util.ArrayList;
import java.util.List;

public class UploadPartCopyExample extends AppCompatActivity {

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        String endpoint = "your endpoint";
        String region = "your region";
        String accessKey = "your access key";
        String secretKey = "your secret key";
        String securityToken = "your security token";

        String srcBucketName = "your src bucket name";
        String srcObjectKey = "your src object key";
        String bucketName = "your bucket name";
        String objectKey = "your object key";
        long partSize = 10 * 1024 * 1024;

        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_display_message);
        TOSV2 tos = new TOSV2ClientBuilder().build(region, endpoint, accessKey, secretKey, securityToken);

        Thread tosThread = new Thread(new Runnable() {
            @Override
            public void run() {
                try{
                    // 从源桶中获取待拷贝对象的大小
                    HeadObjectV2Output headInfo = tos.headObject(new HeadObjectV2Input().setBucket(srcBucketName).setKey(srcObjectKey));
                    long contentLength = headInfo.getHeadObjectBasicOutput().getContentLength();

                    // 初始化分片拷贝任务
                    CreateMultipartUploadInput create = new CreateMultipartUploadInput().setBucket(bucketName).setKey(objectKey);
                    CreateMultipartUploadOutput created = tos.createMultipartUpload(create);
                    String uploadID = created.getUploadID();

                    // 进行分片拷贝
                    List<UploadedPartV2> partList = new ArrayList<>();
                    // 从位置 0 开始拷贝
                    long rangeStart = 0, rangeEnd = 0;
                    int partNumber = 1;
                    while (rangeEnd < contentLength) {
                        // 最长不能超过源对象长度
                        rangeEnd = Math.min(rangeStart + partSize - 1, contentLength);
                        UploadPartCopyV2Input input = new UploadPartCopyV2Input().setBucket(bucketName).setKey(objectKey)
                                .setUploadID(uploadID).setSourceBucket(srcBucketName).setSourceKey(srcObjectKey)
                                .setPartNumber(partNumber).setCopySourceRange(rangeStart, rangeEnd);
                        UploadPartCopyV2Output output = tos.uploadPartCopy(input);
                        Log.i("uploadPartCopy", "uploadPartCopy succeed, part's etag is " + output.getEtag());
                        Log.i("uploadPartCopy", "uploadPartCopy succeed, part's partNumber is " + output.getPartNumber());
                        partList.add(new UploadedPartV2().setEtag(output.getEtag()).setPartNumber(output.getPartNumber()));
                        rangeStart = rangeEnd + 1;
                        partNumber++;
                    }
                    // 合并拷贝的分片
                    CompleteMultipartUploadV2Input complete = new CompleteMultipartUploadV2Input().setBucket(bucketName)
                            .setKey(objectKey).setUploadID(uploadID).setUploadedParts(partList);
                    CompleteMultipartUploadV2Output output = tos.completeMultipartUpload(complete);
                    Log.i("uploadPartCopy", "copyObject succeed, object's etag is " + output.getEtag());
                    Log.i("uploadPartCopy", "copyObject succeed, object's crc64 is " + output.getHashCrc64ecma());
                } catch (TosException e) {
                    Log.e("TosException", "copyObject failed");
                    e.printStackTrace();
                }
            }
        });

        tosThread.start();
    }
}

相关文档