文档中心

名称

描述

public   static void multiUpload(AmazonS3 ossClient) {

try {

String bucketName = "bkt-hhhhtest";;

String key = "object_test1.pdf"   ;

String uploadFile =   "D:\\tmp\\2.txt";

// 通过UploadFileRequest设置多个参数

UploadFileRequest request = new   UploadFileRequest(bucketName, key);

// 上传的本地文件

request.setUploadFile(uploadFile);

// 分片上传并发线程数，默认为1，最多为1000

request.setTaskNum(2);

/*每个分片的大小，默认5MB，若partSize小于5MB，除了最后一个分片以外，会将partSize调整至5MB */

request.setPartSize(5 * 1024 * 1024);

// 开启断点续传功能，默认关闭

request.setEnableCheckpoint(true);

/*记录本地分片上传结果的文件。开启断点续传功能时需要设置此参数，上传过程中的进度信息会保存在该文件中，如果某一分片上传失败，再次上传时会根据文件中记录的点继续上传。*/

// 上传完成后，该文件会被删除。默认与待上传的本地文件同目录，为uploadFile.ucp

// request.setCheckpointFile("");

MultipleUpload multiUpload = new MultipleUpload(request, ossClient);

// 断点续传上传

CompleteMultipartUploadResult result = multiUpload.upload();

//System.out.println("location:    "+result.getLocation());

System.out.println("Upload   complete. Upload object name:" + result.getKey());

} catch (AmazonServiceException ase)   {

System.out.println("Caught   an AmazonServiceException, which means your request made it " + "to   OOS, but was rejected with an error response for some reason.");

System.out.println("Error   Message:    " + ase.getMessage());

System.out.println("HTTP   Status Code: " + ase.getStatusCode());

System.out.println("OOS   Error Code:   " +   ase.getErrorCode());

System.out.println("Request   ID:       " + ase.getRequestId());

} catch (AmazonClientException ace) {

System.out.println("Caught   an AmazonClientException, which means the client encountered "

+ "a serious   internal problem while trying to communicate with OOS, "

+ "such as not being   able to access the network.");

System.out.println("Error   Message: " + ace.getMessage());

}

}