UploadPartRequestFactory.java
1.87 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
package com.cnlive.demo.rdupload;
import java.io.File;
import java.io.Serializable;
import com.ksyun.ks3.services.request.UploadPartRequest;
/**
*
* UploadPartRequest工厂，用于分块上传操作
*
*/
public class UploadPartRequestFactory implements Serializable{
private static final long serialVersionUID = 1L;
private String bucketName;
private String key;
private String uploadId;
private File file;
public int partNumber = 1;
private long offset = 0L;
private long remainingBytes;
public long partSize ;
private long uploadedSize;
public UploadPartRequestFactory(String bucketName ,String objectKey , String uploadId , File file , long partSize ) {
this.uploadId = uploadId;
this.bucketName = bucketName;
this.key = objectKey;
this.file = file;
this.remainingBytes = file.length();
this.partSize = partSize;
this.partNumber = 1;
this.uploadedSize = 0;
}
public synchronized boolean hasMoreRequests() {
return this.remainingBytes > 0L;
}
// 计算下一个UploadPartRequest配置参数，并返回对象
public synchronized UploadPartRequest getNextUploadPartRequest() {
boolean bool = this.remainingBytes - this.partSize <= 0L;
UploadPartRequest localUploadPartRequest = null;
uploadedSize = file.length() - this.remainingBytes ;
localUploadPartRequest = new UploadPartRequest(bucketName, key,uploadId, file, offset, partNumber++, partSize);
this.offset += partSize;
this.remainingBytes -= partSize;
localUploadPartRequest.setLastPart(bool);
return localUploadPartRequest;
}
public synchronized long getUploadedSize (){
return this.uploadedSize;
}
public synchronized File getFile(){
return this.file;
}
public synchronized String getBucketName(){
return this.bucketName;
}
public synchronized String getUploadId(){
return this.uploadId;
}
public synchronized String getObjectKey() {
return this.key;
}
}