引入依赖
<qiniu.java.sdk.version>7.2.12</qiniu.java.sdk.version>
<dependency>
<groupId>com.qiniu</groupId>
<artifactId>qiniu-java-sdk</artifactId>
<version>${qiniu.java.sdk.version}</version>
</dependency>
七牛工具类
public class QiNiuUtil {
protected final static Logger logger = LoggerFactory.getLogger(QiNiuUtil.class);
public static void upload(QiNiuBean bean,byte[] content,String fileName) throws Exception{
try {
UploadManager uploadManager = bean.getUploadManager(null);
Response res = uploadManager.put(content, fileName, bean.getUpToken());
logger.info(String.format("upload success.result = %s.", res.toString()));
} catch (QiniuException e) {
Response r = e.response;
logger.error(String.format("upload error! result = %s.", r.toString()),e);
throw e;
}
}
public static String getDownloadUrl(QiNiuBean bean,String fileName) {
String downloadUrl = StringUtils.EMPTY;
try {
BucketManager bucketManager = bean.getBucketManager(null);
String[] domainList = bucketManager.domainList(bean.getBucketName());
String domainOfBucket = domainList[0];
String encodedFileName = URLEncoder.encode(fileName, "utf-8");
downloadUrl = String.format("http://%s/%s", domainOfBucket, encodedFileName);
logger.info(String.format("get download url success.result = %s.", downloadUrl));
} catch (QiniuException e) {
Response r = e.response;
logger.error(String.format("get download url error! result = %s.", r.toString()),e);
} catch (UnsupportedEncodingException e) {
logger.error("get download url error!",e);
}
return downloadUrl;
}
public static List<FileInfoVo> getBucketListFile(QiNiuBean bean){
String prefix = StringUtils.EMPTY;
int limit = 1000;
String delimiter = StringUtils.EMPTY;
BucketManager bucketManager = bean.getBucketManager(null);
BucketManager.FileListIterator fileListIterator = bucketManager.createFileListIterator(bean.getBucketName(), prefix, limit, delimiter);
List<FileInfo> fileInfos = new ArrayList<FileInfo>();
while (fileListIterator.hasNext()) {
fileInfos.addAll(Arrays.asList(fileListIterator.next()));
}
List<FileInfoVo> result = new ArrayList<FileInfoVo>();
for(FileInfo info : fileInfos) {
FileInfoVo vo = new FileInfoVo(info);
result.add(vo);
}
return result;
}
public static void delete(QiNiuBean bean,String fileName) throws Exception {
try {
BucketManager bucketManager = bean.getBucketManager(null);
bucketManager.delete(bean.getBucketName(), fileName);
logger.info(String.format("delete file sucess. fileName =%s .", fileName));
} catch (QiniuException e) {
Response r = e.response;
logger.error(String.format("delete file error! result = %s.", r.toString()),e);
throw e;
}
}
}