import com.qiniu.util.StringMap; //导入依赖的package包/类
private Response multipartPost(String url,
                               StringMap fields,
                               String name,
                               String fileName,
                               RequestBody file,
                               StringMap headers) throws QiniuException {
    final MultipartBuilder mb = new MultipartBuilder();
    mb.addFormDataPart(name, fileName, file);

    fields.forEach(new StringMap.Consumer() {
        @Override
        public void accept(String key, Object value) {
            mb.addFormDataPart(key, value.toString());
        }
    });
    mb.type(MediaType.parse("multipart/form-data"));
    RequestBody body = mb.build();
    Request.Builder requestBuilder = new Request.Builder().url(url).post(body);
    return send(requestBuilder, headers);
}
 

import com.qiniu.util.StringMap; //导入依赖的package包/类
ResumeUploader(Client client, String upToken, String key, File file,
               StringMap params, String mime, Recorder recorder, String recorderKey) {
    this.client = client;
    this.upToken = upToken;
    this.key = key;
    this.f = file;
    this.size = file.length();
    this.params = params;
    this.mime = mime == null ? Client.DefaultMime : mime;
    this.host = Config.zone.upHost;
    long count = (size + Config.BLOCK_SIZE - 1) / Config.BLOCK_SIZE;
    this.contexts = new String[(int) count];
    this.blockBuffer = new byte[Config.BLOCK_SIZE];
    this.recorder = recorder;
    this.recorderKey = recorderKey;
    this.modifyTime = f.lastModified();
    helper = new RecordHelper();
}
 

import com.qiniu.util.StringMap; //导入依赖的package包/类
/**
 * 过滤用户自定义参数，只有参数名以<code>x:</code>开头的参数才会被使用
 *
 * @param params 待过滤的用户自定义参数
 * @return 过滤后的用户自定义参数
 */
private static StringMap filterParam(StringMap params) {
    final StringMap ret = new StringMap();
    if (params == null) {
        return ret;
    }

    params.forEach(new StringMap.Consumer() {
        @Override
        public void accept(String key, Object value) {
            if (value == null) {
                return;
            }
            String val = value.toString();
            if (key.startsWith("x:") && !val.equals("")) {
                ret.put(key, val);
            }
        }
    });

    return ret;
}
 

import com.qiniu.util.StringMap; //导入依赖的package包/类
/**
 * 上传文件
 *
 * @param file     上传的文件对象
 * @param key      上传文件保存的文件名
 * @param token    上传凭证
 * @param mime     指定文件mimetype
 * @param checkCrc 是否验证crc32
 */
public Response put(File file, String key, String token, StringMap params,
                    String mime, boolean checkCrc) throws QiniuException {
    checkArgs(key, null, file, token);
    if (mime == null) {
        mime = Client.DefaultMime;
    }
    params = filterParam(params);
    long size = file.length();
    if (size <= Config.PUT_THRESHOLD) {
        return new FormUploader(client, token, key, file, params, mime, checkCrc).upload();
    }

    String recorderKey = key;
    if (keyGen != null) {
        recorderKey = keyGen.gen(key, file);
    }
    ResumeUploader uploader = new ResumeUploader(client, token, key, file,
            params, mime, recorder, recorderKey);
    return uploader.upload();
}
 

import com.qiniu.util.StringMap; //导入依赖的package包/类
ResumeUploader(
        Client client,
        String upToken,
        String key,
        File file,
        StringMap params,
        String mime
) {
    this.client = client;
    this.upToken = upToken;
    this.key = key;
    this.f = file;
    this.size = file.length();
    this.params = params;
    this.mime = mime == null ? Client.DefaultMime : mime;
    this.host = Config.UP_HOST;
    long count = (size + Config.BLOCK_SIZE - 1) / Config.BLOCK_SIZE;
    this.contexts = new String[(int) count];
    this.blockBuffer = new byte[Config.BLOCK_SIZE];
}
 

import com.qiniu.util.StringMap; //导入依赖的package包/类
/**
 * 上传文件
 *
 * @param file  上传的文件对象
 * @param key   上传文件保存的文件名
 * @param token 上传凭证
 * @param mime 指定文件mimetype
 * @param checkCrc 是否验证crc32
 */
public Response put(File file, String key, String token, StringMap params,
                    String mime, boolean checkCrc) throws QiniuException {
    checkArgs(key, null, file, token);
    if (mime == null) {
        mime = Client.DefaultMime;
    }
    params = filterParam(params);
    long size = file.length();
    if (size <= Config.PUT_THRESHOLD) {
        return new FormUploader(client, token, key, file, params, mime, checkCrc).upload();
    }

    ResumeUploader uploader = new ResumeUploader(client, token, key, file, params, mime);
    return uploader.upload();
}
 

import com.qiniu.util.StringMap; //导入依赖的package包/类
@Override
public void createBucket(String bucketName) {
    String codedBucketName = UrlSafeBase64.encodeToString(bucketName);
    String url = String.format("%s/mkbucketv2/%s", this.qiniuCfg.rsHost(), codedBucketName);
    StringMap headers = this.auth.authorization(url);
    try {
        this.client.post(url, null, headers, "application/x-www-form-urlencoded");
    } catch (QiniuException e) {
        e.printStackTrace();
    }
}
 

import com.qiniu.util.StringMap; //导入依赖的package包/类
@Override
public void deleteBucket(String bucketName) {
    String url = String.format("%s/drop/%s", this.qiniuCfg.rsHost(), bucketName);
    StringMap headers = this.auth.authorization(url);
    try {
        this.client.post(url, null, headers, "application/x-www-form-urlencoded");
    } catch (QiniuException e) {
        e.printStackTrace();
    }
}
 

import com.qiniu.util.StringMap; //导入依赖的package包/类
public Response post(String url, StringMap params, StringMap headers) throws QiniuException {
    final FormEncodingBuilder f = new FormEncodingBuilder();
    params.forEach(new StringMap.Consumer() {
        @Override
        public void accept(String key, Object value) {
            f.add(key, value.toString());
        }
    });
    return post(url, f.build(), headers);
}
 

import com.qiniu.util.StringMap; //导入依赖的package包/类
public Response send(final Request.Builder requestBuilder, StringMap headers) throws QiniuException {
    if (headers != null) {
        headers.forEach(new StringMap.Consumer() {
            @Override
            public void accept(String key, Object value) {
                requestBuilder.header(key, value.toString());
            }
        });
    }

    requestBuilder.header("User-Agent", userAgent());
    long start = System.currentTimeMillis();
    com.squareup.okhttp.Response res = null;
    Response r;
    double duration = (System.currentTimeMillis() - start) / 1000.0;
    IpTag tag = new IpTag();
    try {
        res = httpClient.newCall(requestBuilder.tag(tag).build()).execute();
    } catch (IOException e) {
        e.printStackTrace();
        throw new QiniuException(e);
    }
    r = Response.create(res, tag.ip, duration);
    if (r.statusCode >= 300) {
        throw new QiniuException(r);
    }

    return r;
}
 

import com.qiniu.util.StringMap; //导入依赖的package包/类
public StringMap jsonToMap() throws QiniuException {
    if (!isJson()) {
        return null;
    }
    String b = bodyString();
    return Json.decode(b);
}
 

import com.qiniu.util.StringMap; //导入依赖的package包/类
private FormUploader(Client client, String upToken, String key, byte[] data, File file, StringMap params,
                     String mime, boolean checkCrc) {
    this.client = client;
    token = upToken;
    this.key = key;
    this.file = file;
    this.data = data;
    this.params = params;
    this.mime = mime;
    this.checkCrc = checkCrc;
}
 

import com.qiniu.util.StringMap; //导入依赖的package包/类
Response upload() throws QiniuException {
    buildParams();
    if (data != null) {
        return client.multipartPost(Config.zone.upHost, params, "file", fileName, data, mime, new StringMap());
    }
    return client.multipartPost(Config.zone.upHost, params, "file", fileName, file, mime, new StringMap());
}
 

import com.qiniu.util.StringMap; //导入依赖的package包/类
Response upload() throws QiniuException {
    buildParams();
    if (data != null) {
        return client.multipartPost(Config.UP_HOST, params, "file", fileName, data, mime, new StringMap());
    }
    return client.multipartPost(Config.UP_HOST, params, "file", fileName, file, mime, new StringMap());
}
 

import com.qiniu.util.StringMap; //导入依赖的package包/类
@Override
public String uploadToken(String bucket, String key, long expires,
		StringMap policy, boolean strict) {
	if (expires == -1)
		expires = Long.parseLong(CONFIG.getConf(bucket,
				QiniuConfig.UPLOAD_EXPIRE, "3600"));
	return AUTH.uploadToken(bucket, key, expires, policy, strict);
}
 

import com.qiniu.util.StringMap; //导入依赖的package包/类
public static String getUpToken() {
    return auth.uploadToken(bucket, null, 3600, new StringMap().put("insertOnly", 1));
}
 

import com.qiniu.util.StringMap; //导入依赖的package包/类
private String getUpToken() {
    return auth.uploadToken(this.bucketName, (String) null, 3600, new StringMap().putNotEmpty("returnBody",
            "{\"key\": $(key), \"hash\": $(etag), \"width\": $(imageInfo.width), \"height\": $(imageInfo.height)}"));
}
 

import com.qiniu.util.StringMap; //导入依赖的package包/类
private String getUpToken() {
    return auth.uploadToken("spring-abc", null, 3600, new StringMap().putNotEmpty("returnBody",
            "{\"key\": $(key), \"hash\": $(etag), \"width\": $(imageInfo.width), \"height\": $(imageInfo.height)}"));
}
 

import com.qiniu.util.StringMap; //导入依赖的package包/类
/**
 * 上传资源的最主要方法
 * 参数依次的含义： 点播云空间名(对应portal-->点播空间左上角的名字)，失效时间，上传文件类型（参考文档），要上传的文件路径（最好用绝对路径）
 * StringMap （params参数）可以put进  key, crc32, x:vod, accept, xvod  这些值进去
 */
public Map<String, Object> uploadResource(String hub, int deadline, String type, String path, Map<String, Object> params) {
    if (type == null || type.length() <= 0) {
        type = "video";
    }

    UptokenRet uptokenRet = getVodUptokenV2(hub, deadline, type);
    // 判空，能否获取token
    if (uptokenRet == null) {
        System.err.println("cann't get vod uptoken");
        return null;
    }

    Configuration cf = new Configuration(Zone.autoZone());

    // 创建上传对象
    UploadManager uploadManager = new UploadManager(cf);

    Map<String, Object> ret = new HashMap<String, Object>();
    try {
        // key 参数为空，则用uptokenRet里的key
        String k = uptokenRet.getKey();
        if (params.containsKey("key")) {
            k = params.get("key").toString();
            params.remove("key");
        }

        boolean checkCrc=false;
        if (params.containsKey("crc32")){
            checkCrc=(Boolean) params.get("crc32");
            params.remove("crc32");
        }

        // 调用put方法上传
        StringMap qparams=new StringMap();
        qparams.putAll(params);
        Response res=uploadManager.put(path,k,uptokenRet.getUptoken(),qparams,null,checkCrc);

        // 打印返回的信息
        System.out.println(res.bodyString());

        StringMap retMap = res.jsonToMap();

        ret.put("code", res.statusCode);
        ret.put("hash", retMap.get("hash"));
        ret.put("key", retMap.get("key"));

    } catch (QiniuException e) {
        Response r = e.response;
        // 请求失败时,返回错误码，由客户自己根据错误码，在前端显示相应的提示信息
        ret.put("code", r.statusCode);
        ret.put("msg", r.toString());  // 错误信息
        System.err.printf("upload file error:%s",e.toString());
    }
    return ret;
}
 

import com.qiniu.util.StringMap; //导入依赖的package包/类
public Response get(String url) throws QiniuException {
    return get(url, new StringMap());
}