最近更新时间：2024.02.04 18:31:01
首次发布时间：2022.12.01 16:31:40
对象大于 1GiB 时，建议您使用 uploadPartCopy 来进行分片拷贝。本文介绍分片拷贝的步骤和示例代码。
以下代码用于通过 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(); } }