分块上传（Android）

Initiate Multipart Upload 初始化一个分块上传

以下为实现初始化分块上传代码：

InitiateMultipartUploadRequest request = new InitiateMultipartUploadRequest("<bucketName>", "<fileName>");

client.initiateMultipartUpload(request, new InitiateMultipartUploadResponceHeader() {
    @Override
    public void onSuccess(int statesCode, Header[] responceHeaders, InitiateMultipartUploadResult result){
        // 请求成功后 会返回一个InitiateMultipartUploadResult实例对象，通过该对象可以获取上传的uploadId，用于后续的Upload Part 请求。
    }

    @Override
    public void onFailure(int statesCode, Ks3Error error, Header[] responceHeaders, String response, Throwable paramThrowable) {
        // 请求异常
    }
});

Upload Part 分块上传

以下为分块上传文件示例代码：

// file：需要上传的文件
// PART_SIZE： 此分块的大小，单位为Byte
UploadPartRequestFactory requestFactory = new UploadPartRequestFactory("<bucketName>", "<ObjectKey>","<uploadId>", file, PART_SIZE);

UploadPartRequest request = requestFactory.getNextUploadPartRequest();

client.uploadPart(request, new UploadPartResponceHandler() {

    @Override
    public void onTaskProgress(double progress) {
	//上传进度
    }

    @Override
    public void onSuccess(int statesCode, Header[] responceHeaders, PartETag result) {
	// 上传成功时返回PartETag结果实体类，包含partNumber以及Etag信息
    }

    @Override
    public void onFailure(int statesCode, Ks3Error error, Header[] responceHeaders, String response, Throwable throwable) {
	//上传异常
    }
});


// 当然你也可以自行上传文件，以下为参数说明:
// bucketname：指定的Bucket名称
// objectKey：指定的Object键
// uploadId：初始化时得到的uploadId
// file：需要上传的file
// offset：此分块在文件中内容的起始位置
// partNumber：此分块是第几块
// partSize：此分块的大小，单位为Byte
client.uploadPart("<bucketName>", "<objectKey>", "<uploadId>", "<file>", "<offset>", "<partNumber>", "<partSize>", new UploadPartResponceHandler() {...});

注：该接口请求实现将对象按照分块的方式上传到 KS3。最多支持10000分块，当所有块总大小大于5M时，除了最后一个块没有大小限制外，其余的块的大小均要求在5MB以上。当所有块总大小小于5M时，除了最后一个块没有大小限制外，其余的块的大小均要求在100K以上。如果不符合上述要求，会返回413状态码。

List Parts 已上传分块信息

以下为获取已经上传的块信息：

ListPartsRequest request = new ListPartsRequest("<bucketName>", "<objectKey>", "<uploadId>");

client.listParts(request, new ListPartsResponseHandler() {
    @Override
    public void onSuccess(int statesCode, Header[] responceHeaders, ListPartsResult result) {
	// 请求成功返回ListPartsResult结果实体类,包含Owner及一个Parts容器类
    }

    @Override
    public void onFailure(int statesCode, Ks3Error error, Header[] responceHeaders, String response, Throwable paramThrowable) {
	//请求异常
    }
});

Abort Multipart Upload 取消分块上传

以下为取消分块上传的示例代码：

AbortMultipartUploadRequest request = new AbortMultipartUploadRequest( "<bucketName>", "<objectKey>", "<uploadId>");

client.abortMultipartUpload(request, new AbortMultipartUploadResponseHandler() {
    @Override
    public void onSuccess(int statesCode, Header[] responceHeaders) {
	// responceHeaders: Http请求响应报头
    }

    @Override
    public void onFailure(int statesCode, Ks3Error error, Header[] responceHeaders, String response, Throwable paramThrowable) {
	//请求失败
    }
});

注：当任务被放弃后，使用相应的上传ID则会无法实现任何块的上传。存储中已经上传的块将会被释放。

Complete Multipart Upload 组装所有分块上传的文件

以下为组装之前上传的块示例代码：

// listResult为ListPartsResult实例对象
CompleteMultipartUploadRequest request = new CompleteMultipartUploadRequest(listResult);

client.completeMultipartUpload(request, new CompleteMultipartUploadResponseHandler() {
    @Override
    public void onSuccess(int statesCode, Header[] responceHeaders, CompleteMultipartUploadResult result){
	// 组装成功 可以通过result获取当前bucket、eTag、key、location信息
    }

    @Override
    public void onFailure(int statesCode, Ks3Error error, Header[] responceHeaders, String response, Throwable paramThrowable) {
       // 请求异常 
    }
});

注：该操作执行成功后，对应的uploadId将会失效。同一个Object可以拥有不同的uploadId，当组装操作完成后，该Object的其他uploadId不受影响。

Multipart Upload Example Code 分块上传代码示例

UploadPartHandler handler = new UploadPartHandler();
client.initiateMultipartUpload(new InitiateMultipartUploadRequest("<bucketName>", "<objectKey>"), new InitiateMultipartUploadResponceHandler() {

        @Override
        public void onSuccess(int statesCode, Header[] responceHeaders, InitiateMultipartUploadResult result) {
            String uploadId = result.getUploadId();
          	// 初始化分块上传 得到uploadId
          	// 发送消息 执行下一步操作
            handler.sendEmptyMessage(TransferManager.STATE_UPLOAD_NEXT);
        }

        @Override
        public void onFailure(int statesCode, Header[] responceHeaders, String response, Throwable paramThrowable) {
	    // 请求异常
        }
    }
);

public class UploadPartHandler extends Handler {

    @Override
    public void handleMessage(Message msg) {
        super.handleMessage(msg);
        switch (msg.what) {
        case TransferManager.STATE_UPLOAD_NEXT:
	    // 如果有未完成的请求 则继续执行
            if (localUploadPartRequestFactory.hasMoreRequests()) {
                UploadPartRequest uploadPartRequest = localUploadPartRequestFactory.getNextUploadPartRequest();
                client.uploadPart(uploadPartRequest, new UploadPartResponceHandler() {
                    @Override
                    public void onSuccess(int statesCode, Header[] responceHeaders, UploadPartResult result) {
			//请求成功
                        Log.d("eflake", "upload part success , partnumber = " + result.getPartNumber() + ",etag = " + result.getETag());
                      	handler.sendEmptyMessage(TransferManager.STATE_UPLOAD_NEXT);
                    }

                    @Override
                    public void onFailure(int statesCode, Header[] responceHeaders, String response, Throwable throwable) {
			//请求异常
                        Log.d("eflake", "upload part failed ,responce = " + response);
                        handler.sendEmptyMessage(TransferManager.STATE_UPLOAD_FAILED);
                    }
                });
            } else {
                // 发送完成消息
                handler.sendEmptyMessage(TransferManager.STATE_UPLOAD_FINISH);
            }
            break;
        case TransferManager.STATE_UPLOAD_FINISH:
            // 获取分块信息
            client.ListParts(bucketName, objectKey, transferResponceHandler.getMultipartUoloadId(), new ListPartsResponseHandler() {

                @Override
                public void onSuccess(int statesCode, Header[] responceHeaders, ListPartsResult listPartsResult) {
		    //请求成功
                    mLastListPartResul = listPartsResult;
                    handler.sendEmptyMessage(TransferManager.STATE_UPLOAD_COMPLETE);
                }

                @Override
                public void onFailure(int statesCode, Header[] responceHeaders, String response, Throwable paramThrowable) {
		    //请求异常
                    Log.d("eflake", "listPart failed, reason :" + response);

                }
            });
            break;
        case TransferManager.STATE_UPLOAD_FAILED:
            break;
        case TransferManager.STATE_UPLOAD_COMPLETE:
            if (mLastListPartResul != null) {
                // 将分块数据进行合并处理
                client.completeMultipartUpload(new CompleteMultipartUploadRequest(mLastListPartResul),new CompleteMultipartUploadResponseHandler() {

                    @Override
                    public void onSuccess(int statesCode, Header[] responceHeaders, CompleteMultipartUploadResult result) {
			//请求成功
                        Log.d("eflake", "completeMultipartUpload success, result = " + result.getBucket());
                        }

                     @Override
                     public void onFailure(int statesCode, Header[] responceHeaders, String response, Throwable paramThrowable) {
			//请求异常
                         Log.d("eflake", "completeMultipartUpload failed, reason =  " + response);
                     }
                });
            }
            break;
        default:
            break;
        }
    }
}

MultiUploader 分块上传的更高层封装接口

以上接口是比较底层的，需要自行创建uploadid，上传每一块。com.ksyun.ks3.services.MultiUploader这个类是更高层封装。一般大于10M的文件才使用分块。本接口是按5M一块分块的。以下为示例代码：

Ks3Client client = Ks3ClientFactory.getDefaultClient(MultiUploadActivity.this);

MultiUploader uploader = new MultiUploader(client, "<bucketName>", "<objectKey>", file, "<uploadId>");
// 设置回调函数 监听是否成功
uploader.setHandler(new CompleteMultipartUploadResponseHandler() {
    @Override
    public void onFailure(int statesCode, Ks3Error error, Header[] responceHeaders, String response, Throwable paramThrowable) {
        // 整个上传过程中 如果任意环节出现异常 都会执行到此处
    }

    @Override
    public void onSuccess(int statesCode, Header[] responceHeaders, CompleteMultipartUploadResult result) {
	// 最终的成功 才会执行到此
    }
});
uploader.upload();

注：可以参考sdk源码中的com.ksyun.ks3.services.MultiUploader.java自行实现，也可以将该类拷贝到自己的目录下，修改partSize变量、log输出格式等之后再使用。