/*** 获取token 本地生成* * @return*/private String getToken() {Mac mac = new Mac(QiNiuConfig.QINIU_AK, QiNiuConfig.QINIU_SK);PutPolicy putPolicy = new PutPolicy(QiNiuConfig.QINIU_BUCKNAME);putPolicy.returnBody = "{\"name\": $(fname),\"size\": \"$(fsize)\",\"w\": \"$(imageInfo.width)\",\"h\": \"$(imageInfo.height)\",\"key\":$(etag)}";try {String uptoken = putPolicy.token(mac);System.out.println("debug:uptoken = " + uptoken);return uptoken;} catch (AuthException e) {e.printStackTrace();} catch (JSONException e) {e.printStackTrace();}return null;}

data = <File对象、或 文件路径、或 字节数组>
String key = <指定七牛服务上的文件名，或 null>;
String token = <从服务端SDK获取>;
UploadManager uploadManager = new UploadManager();
uploadManager.put(data, key, token,
new UpCompletionHandler() {@Overridepublic void complete(String key, ResponseInfo info, JSONObject response) {Log.i("qiniu", info);}
}, null);

uploadManager.put(data, key, token,handler,new UploadOptions(null, null, false,new UpProgressHandler(){public void progress(String key, double percent){Log.i("qiniu", key + ": " + percent);}}, null));

private volatile boolean isCancelled;
...
// 某方法中执行取消：isCancelled = true;
...
uploadManager.put(data, key, token,handler,new UploadOptions(null, null, false, progressHandler,new UpCancellationSignal(){public boolean isCancelled(){return isCancelled;}}));

String dirPath = <断点记录文件保存的文件夹位置>
FileRecorder fr = new FileRecorder(dirPath)
UploadManager uploadManager = new UploadManager(fr);
uploadManager.put(data, key, ...)//默认使用 key 的url_safe_base64编码字符串作为断点记录文件的文件名。避免记录文件冲突（特别是key指定为null时），也可自定义文件名：

UploadManager uploadManager = new UploadManager(fr, new KeyGenerator(){public String gen(String key, File file){// 不必使用url_safe_base64转换，uploadManager内部会处理// 该返回值可替换为基于key、文件内容、上下文的其它信息生成的文件名return key + file.getName();}
});

private void preUpload(Uri uri) {// 此参数会传递到回调String passObject = "test: " + uri.getEncodedPath() + "passObject";String qiniuKey = UUID.randomUUID().toString();PutExtra extra = null;Upload up = UpApi.build(getAuthorizer(), qiniuKey, uri, this, extra, passObject, uploadHandler);addUp(up);}

private synchronized void doUpload() {System.out.println("doup: 启动上传任务");for (Upload up : ups) {if (UpApi.isSliceUpload(up)) {String sourceId = generateSourceId(up.getUpParam(), up.getPassParam());List<Block> bls = null;try {bls = load(sourceId);} catch (IOException e) {e.printStackTrace();}// 设置以前上传的断点记录。 直传会忽略此参数
                up.setLastUploadBlocks(bls);}// UpApi.execute(up, bls);Executor executor = UpApi.execute(up);executors.add(executor);}System.out.println("doup: 启动上传任务完毕");start = System.currentTimeMillis();}

public void doResumableUpload(final Uri uri, PutExtra extra) {uploadUri = uri;final MyBlockRecord record = MyBlockRecord.genFromUri(this, uri);tvUploadInfo.setText("连接中");String key = null;if (extra != null) {extra.params = new HashMap<String, String>();extra.params.put("x:a", "bb");}List<Block> blks = record.loadBlocks();String s = "blks.size(): " + blks.size() + " ==> ";for (Block blk : blks) {s += blk.getIdx() + ", ";}final String pre = s + "\r\n";uploading = true;executor = ResumableIO.putFile(this, auth, key, uri, extra, blks, new CallBack() {@Overridepublic void onSuccess(UploadCallRet ret) {uploading = false;String key = ret.getKey();String redirect = "http://" + MyActivity.bucketName + ".qiniudn.com/" + key;String redirect2 = "http://" + MyActivity.bucketName + ".u.qiniudn.com/" + key;tvUploadInfo.setText(pre + "上传成功! ret: " + ret.toString() + "  \r\n可到" + redirect + " 或  " + redirect2 + " 访问");record.removeBlocks();clean();}@Overridepublic void onProcess(long current, long total) {int percent = (int) (current * 100 / total);tvUploadInfo.setText(pre + "上传中: " + current + "/" + total + "  " + current / 1024 + "K/" + total / 1024 + "K; "+ percent + "%");// int i = 3/0;progressBar.setProgress((int) percent);}@Overridepublic void onBlockSuccess(Block blk) {record.saveBlock(blk);}@Overridepublic void onFailure(CallRet ret) {uploading = false;clean();tvUploadInfo.setText(pre + "错误: " + ret.toString());}});}