七牛云私有空间指定目录大量文件压缩示例

最近使用到七牛云私有空间大量文件压缩功能，简单做下总结，大概步骤如下：
1.查询指定目录下所有文件。
2.循环进行链接加密，修改为公网可以访问资源。
3.按照七牛索引文件要求格式，拼接索引文件内容。
4.上传索引文件。
5.调用压缩接口。

七牛多文件压缩官方文档：
https://developer.qiniu.com/dora/manual/1667/mkzip
持久化数据处理官方文档：
https://developer.qiniu.com/dora/manual/1291/persistent-data-processing-pfop

import com.qiniu.common.QiniuException;
import com.qiniu.common.Zone;
import com.qiniu.http.Response;
import com.qiniu.processing.OperationManager;
import com.qiniu.storage.BucketManager;
import com.qiniu.storage.Configuration;
import com.qiniu.storage.UploadManager;
import com.qiniu.storage.model.FileInfo;
import com.qiniu.storage.model.FileListing;
import com.qiniu.util.Auth;
import com.qiniu.util.StringMap;
import com.qiniu.util.UrlSafeBase64;
import org.apache.commons.lang3.StringUtils;

/**
 * ClassName: QiNiuZipUtil 
 * @Description: 七牛云私有空间指定目录大量文件压缩示例
 * @author ljwang
 * @date 2017年9月5日
 */
public class QiNiuZipUtil {

    public static final String ACCESS_KEY = "*******";
    public static final String SECRET_KEY = "*******";
    public static final String BUCKET = "*******";
    public static final String DOMAIN = "*******";
    
    /**
     * 七牛回调URL
     */
    public static final String NOTIFY_URL = "*******";
    /**
     * 七牛间隔符
     */
    public static final String QN_SEPARATOR = "/";
    /**
     * txt换行符
     */
    public static final String QN_NEWLINE = "
";
    /**
     * 索引文件名称
     */
    public static final String TXT_NAME = "index.txt";    
    

    /**
     * @Description: 大量文件压缩
     * @author ljwang
     * @date 2017年9月5日
     */
    public static void mkzip(String prefix) {
        
        //密钥配置
        Auth auth = Auth.create(ACCESS_KEY, SECRET_KEY);
        
        //自动识别要上传的空间(bucket)的存储区域是华东、华北、华南。
        Zone z = Zone.autoZone();
        Configuration c = new Configuration(z);

        //实例化一个BucketManager对象
        BucketManager bucketManager = new BucketManager(auth, c);

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

        try {
            //调用listFiles方法列举指定空间的指定文件
            //参数一：bucket    空间名
            //参数二：prefix    文件名前缀
            //参数三：marker    上一次获取文件列表时返回的 marker
            //参数四：limit     每次迭代的长度限制，最大1000，推荐值 100
            //参数五：delimiter 指定目录分隔符，列出所有公共前缀（模拟列出目录效果）。缺省值为空字符串
            FileListing fileListing = bucketManager.listFiles(BUCKET, prefix, null, 100, null);
            FileInfo[] items = fileListing.items;
            
            //压缩索引文件内容
            String content = "";
            for(FileInfo fileInfo : items){
                //拼接原始链接
                String url = "http://" + DOMAIN + QN_SEPARATOR + fileInfo.key;
                //链接加密并进行Base64编码，别名去除前缀目录。
                String safeUrl = "/url/" + UrlSafeBase64.encodeToString(auth.privateDownloadUrl(url)) + "/alias/" + UrlSafeBase64.encodeToString(fileInfo.key.substring(prefix.length()));
                content += ((StringUtils.isBlank(content) ? "" : QN_NEWLINE) + safeUrl);
            }
//            System.out.println(content);
            
            //索引文件路径
            String txtKey = prefix + TXT_NAME;
            //生成索引文件token（覆盖上传）
            String uptoken = auth.uploadToken(BUCKET, txtKey, 3600, new StringMap().put("insertOnly", 0));
            //上传索引文件
            Response res = uploadManager.put(content.getBytes(), txtKey, uptoken);
           
            //默认utf-8，但是中文显示乱码，修改为gbk
            String fops = "mkzip/4/encoding/" + UrlSafeBase64.encodeToString("gbk") + "|saveas/" + UrlSafeBase64.encodeToString(BUCKET + ":"  + prefix + "压缩文件名.zip");

            OperationManager operater = new OperationManager(auth, c);
            
            StringMap params = new StringMap();
            //压缩完成后，七牛回调URL
            //params.put("notifyURL", NOTIFY_URL);
             
            String id = operater.pfop(BUCKET, txtKey, fops, params);
            String purl = "http://api.qiniu.com/status/get/prefop?id=" + id;
            System.out.println(purl);
        } catch (QiniuException e) {
            Response res = e.response;
            System.out.println(res);
            try {
                System.out.println(res.bodyString());
            } catch (QiniuException e1) {
                e1.printStackTrace();
            }
        }
    }
    
    public static void main(String[] args) {
        String prefix = "public/download/";
        mkzip(prefix);
    }
}