Commit 938237077079c3df61e1c0ddf63e27c39f65b74d

Authored by 王琳
1 parent 2b101206

修改初始化多块上传方法

.idea/vcs.xml 0 → 100644
  1 +<?xml version="1.0" encoding="UTF-8"?>
  2 +<project version="4">
  3 + <component name="VcsDirectoryMappings">
  4 + <mapping directory="$PROJECT_DIR$" vcs="Git" />
  5 + </component>
  6 +</project>
0 \ No newline at end of file 7 \ No newline at end of file
app/libs/libcnliveupload.jar
No preview for this file type
app/src/main/java/com/cnlive/demo/upload/Config.java 0 → 100644
  1 +package com.cnlive.demo.upload;
  2 +
  3 +/**
  4 + * Created by Lynn on 2017/8/14.
  5 + */
  6 +
  7 +public class Config {
  8 + public static final long PART_SIZE = 5 * 1024 * 1024;
  9 + public static final long MULTI_UPLOAD_THREADHOLD = 16 * 1024 * 1024;
  10 + public static String USER_ID = "";
  11 +}
app/src/main/java/com/cnlive/demo/upload/MultiUploader.java
@@ -90,6 +90,7 @@ public class MultiUploader { @@ -90,6 +90,7 @@ public class MultiUploader {
90 90
91 /** 91 /**
92 * 并发传的块数,默认就是2。一般不用改。根据你自测的性能状况来调整。 92 * 并发传的块数,默认就是2。一般不用改。根据你自测的性能状况来调整。
  93 + *
93 * @param no 94 * @param no
94 */ 95 */
95 public void setConcurrentNo(int no) { 96 public void setConcurrentNo(int no) {
@@ -129,7 +130,7 @@ public class MultiUploader { @@ -129,7 +130,7 @@ public class MultiUploader {
129 final CNInitiateMultipartUploadRequest request = new CNInitiateMultipartUploadRequest(bucketName, key); 130 final CNInitiateMultipartUploadRequest request = new CNInitiateMultipartUploadRequest(bucketName, key);
130 request.setCannedACL(CNCannedAccessControlList.PublicRead); 131 request.setCannedACL(CNCannedAccessControlList.PublicRead);
131 request.setContentType("video/mp4"); 132 request.setContentType("video/mp4");
132 - cnUpload.initiateMultipartUpload(name, des, userId, filePath, file, isHorizontalScreen, callback, request, new CNInitiateMultipartUploadResponseListener() { 133 + cnUpload.initiateMultipartUpload(request, userId, filePath, name, des, file, isHorizontalScreen, callback, new CNInitiateMultipartUploadResponseListener() {
133 @Override 134 @Override
134 public void onFailure(int i, UploadError uploadError, Header[] headers, String s, Throwable throwable) { 135 public void onFailure(int i, UploadError uploadError, Header[] headers, String s, Throwable throwable) {
135 Log.w(TAG, "init multiupload fail, statusCode = " + i, throwable); 136 Log.w(TAG, "init multiupload fail, statusCode = " + i, throwable);
@@ -338,7 +339,7 @@ public class MultiUploader { @@ -338,7 +339,7 @@ public class MultiUploader {
338 } 339 }
339 340
340 @Override 341 @Override
341 - public void onSuccess(int i, Header[] headers, CNCompleteMultipartUploadResult completeMultipartUploadResult) { 342 + public void onSuccess(int i, Header[] headers, CNCompleteMultipartUploadResult completeMultipartUploadResult, String videoId) {
342 Log.i(TAG, "complete upload, key = " + key + ", bucketName = " + bucketName + " , uploadId = " + uploadId + "\n" + completeMultipartUploadResult.toString()); 343 Log.i(TAG, "complete upload, key = " + key + ", bucketName = " + bucketName + " , uploadId = " + uploadId + "\n" + completeMultipartUploadResult.toString());
343 344
344 } 345 }
app/src/main/java/com/cnlive/demo/upload/activity/UploadActivity.java
@@ -15,6 +15,7 @@ import android.widget.ListView; @@ -15,6 +15,7 @@ import android.widget.ListView;
15 import android.widget.TextView; 15 import android.widget.TextView;
16 import android.widget.Toast; 16 import android.widget.Toast;
17 17
  18 +import com.cnlive.demo.upload.Config;
18 import com.cnlive.demo.upload.utils.DemoUtils; 19 import com.cnlive.demo.upload.utils.DemoUtils;
19 import com.cnlive.demo.upload.R; 20 import com.cnlive.demo.upload.R;
20 import com.cnlive.demo.upload.utils.UploadPartRequestFactory; 21 import com.cnlive.demo.upload.utils.UploadPartRequestFactory;
@@ -58,8 +59,7 @@ import static com.cnlive.demo.upload.model.UploadFile.STATUS_UPLOADING; @@ -58,8 +59,7 @@ import static com.cnlive.demo.upload.model.UploadFile.STATUS_UPLOADING;
58 59
59 public class UploadActivity extends Activity implements AdapterView.OnItemClickListener { 60 public class UploadActivity extends Activity implements AdapterView.OnItemClickListener {
60 private static final String TAG = "UploadActivity"; 61 private static final String TAG = "UploadActivity";
61 - public static final long PART_SIZE = 5 * 1024 * 1024;  
62 - public static final long MULTI_UPLOAD_THREADHOLD = 16 * 1024 * 1024; 62 +
63 private CNUpload cnUpload; 63 private CNUpload cnUpload;
64 private File currentDir; 64 private File currentDir;
65 private ListView listView; 65 private ListView listView;
@@ -150,7 +150,7 @@ public class UploadActivity extends Activity implements AdapterView.OnItemClickL @@ -150,7 +150,7 @@ public class UploadActivity extends Activity implements AdapterView.OnItemClickL
150 throw new IllegalArgumentException("file can not be null"); 150 throw new IllegalArgumentException("file can not be null");
151 } 151 }
152 152
153 - if (item.file.length() >= MULTI_UPLOAD_THREADHOLD) { 153 + if (item.file.length() >= Config.MULTI_UPLOAD_THREADHOLD) {
154 doMultipartUpload(item); 154 doMultipartUpload(item);
155 } else { 155 } else {
156 doSingleUpload(item); 156 doSingleUpload(item);
@@ -166,7 +166,7 @@ public class UploadActivity extends Activity implements AdapterView.OnItemClickL @@ -166,7 +166,7 @@ public class UploadActivity extends Activity implements AdapterView.OnItemClickL
166 CNPutObjectRequest request = new CNPutObjectRequest(); 166 CNPutObjectRequest request = new CNPutObjectRequest();
167 request.setCannedACL(CNCannedAccessControlList.PublicRead); 167 request.setCannedACL(CNCannedAccessControlList.PublicRead);
168 request.setContentType("video/mp4"); 168 request.setContentType("video/mp4");
169 - cnUpload.upload(request, "1342671", item.file.getPath(), item.file.getName(), "des", null, 1, null, new CNPutObjectResponseListener() { 169 + cnUpload.upload(request, Config.USER_ID, item.file.getPath(), item.file.getName(), "des", null, 1, null, new CNPutObjectResponseListener() {
170 @Override 170 @Override
171 public void onTaskFailure(int i, UploadError uploadError, Header[] headers, String s, Throwable throwable) { 171 public void onTaskFailure(int i, UploadError uploadError, Header[] headers, String s, Throwable throwable) {
172 Log.d(TAG, uploadError.getErrorMessage()); 172 Log.d(TAG, uploadError.getErrorMessage());
@@ -249,7 +249,7 @@ public class UploadActivity extends Activity implements AdapterView.OnItemClickL @@ -249,7 +249,7 @@ public class UploadActivity extends Activity implements AdapterView.OnItemClickL
249 CNInitiateMultipartUploadRequest request = new CNInitiateMultipartUploadRequest(); 249 CNInitiateMultipartUploadRequest request = new CNInitiateMultipartUploadRequest();
250 request.setContentType("video/mp4"); 250 request.setContentType("video/mp4");
251 request.setCannedACL(CNCannedAccessControlList.PublicRead); 251 request.setCannedACL(CNCannedAccessControlList.PublicRead);
252 - cnUpload.initiateMultipartUpload(item.file.getName(), "des", "1342671", item.file.getPath(), null, 1, null, request, new CNInitiateMultipartUploadResponseListener() { 252 + cnUpload.initiateMultipartUpload(request, Config.USER_ID, item.file.getPath(), item.file.getName(), "des", null, 1, null, new CNInitiateMultipartUploadResponseListener() {
253 @Override 253 @Override
254 public void onFailure(int i, UploadError uploadError, Header[] headers, String s, Throwable throwable) { 254 public void onFailure(int i, UploadError uploadError, Header[] headers, String s, Throwable throwable) {
255 List<UploadFile> uploadFiles = dataSource 255 List<UploadFile> uploadFiles = dataSource
@@ -288,7 +288,7 @@ public class UploadActivity extends Activity implements AdapterView.OnItemClickL @@ -288,7 +288,7 @@ public class UploadActivity extends Activity implements AdapterView.OnItemClickL
288 UploadFile item) { 288 UploadFile item) {
289 localUploadPartRequestFactory = new UploadPartRequestFactory( 289 localUploadPartRequestFactory = new UploadPartRequestFactory(
290 initResult.getBucket(), initResult.getKey(), 290 initResult.getBucket(), initResult.getKey(),
291 - initResult.getUploadId(), item.file, PART_SIZE); 291 + initResult.getUploadId(), item.file, Config.PART_SIZE);
292 Message message = myHandler.obtainMessage(); 292 Message message = myHandler.obtainMessage();
293 message.what = UPLOAD_NEXT_PART; 293 message.what = UPLOAD_NEXT_PART;
294 Bundle bundle = new Bundle(); 294 Bundle bundle = new Bundle();
@@ -434,7 +434,7 @@ public class UploadActivity extends Activity implements AdapterView.OnItemClickL @@ -434,7 +434,7 @@ public class UploadActivity extends Activity implements AdapterView.OnItemClickL
434 } 434 }
435 435
436 @Override 436 @Override
437 - public void onSuccess(int i, Header[] headers, CNCompleteMultipartUploadResult cnCompleteMultipartUploadResult) { 437 + public void onSuccess(int i, Header[] headers, CNCompleteMultipartUploadResult cnCompleteMultipartUploadResult, String videoId) {
438 List<UploadFile> uploadFiles = dataSource 438 List<UploadFile> uploadFiles = dataSource
439 .get(currentDir.getPath()); 439 .get(currentDir.getPath());
440 for (UploadFile file : uploadFiles) { 440 for (UploadFile file : uploadFiles) {
doc/视讯云上传SDK使用说明文档.pdf
No preview for this file type