SpringBoot整合七牛云qiniu

SpringBoot整合七牛云qiniu

 一、参考项

七牛云 COS(官网): 对象存储 Kodo_云存储_海量安全高可靠云存储_oss - 七牛云

qiniu SDK for Java(官网): Java SDK_SDK 下载_对象存储 - 七牛开发者中心

二、引入Pom文件

<!-- .qiniu/qiniu-java-sdk -->
<dependency><groupId>com.qiniu</groupId><artifactId>qiniu-java-sdk</artifactId><version>7.1.0</version>
</dependency>

三、定义抽象类

public abstract class BaseObjectStorage {/*** 上传文件** @param pathAndName* @param file*/public abstract void upload(String pathAndName, File file);/*** 授权** @param pathAndName* @param time* @return*/public abstract String authorize(String pathAndName, long time);/*** 授权(路径全)** @param pathAndName* @param time* @return*/public abstract String authorizeAllName(String pathAndName, long time);/*** 临时上传文件授权** @param dir* @return*/public abstract Map<String, Object> tokens(String dir);/*** 删除文件** @param pathAndName*/public abstract void deleteFile(String pathAndName);public String getFilePathPrefix();}

四、COS实现类

package cn.bjectstorage;import java.io.File;
import java.util.Map;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
llect.Maps;
import com.qiniumon.QiniuException;
import com.qiniu.http.Response;
import com.qiniu.storage.UploadManager;
import com.qiniu.util.Auth;public class QiNiuObjectStorage implements BaseObjectStorage {private static final Logger logger = Logger(QiNiuObjectStorage.class);private Auth auth;private static UploadManager uploadManager = new UploadManager();private String accessKeyId;private String accessKeySecret;private String bucketName;public QiNiuObjectStorage(ObjectStorageInfo objectStorageInfo) {this.accessKeyId = AccessKeyId();this.accessKeySecret = AccessKeySecret();this.bucketName = BucketName();auth = ate(accessKeyId, accessKeySecret);}@Overridepublic void upload(String pathAndName, File file) {try {Response response = uploadManager.AbsolutePath(), pathAndName,auth.uploadToken(bucketName, pathAndName));if (response.isOK()) {logger.info("{} 七牛上传成功", pathAndName);} else {logger.info("{} 七牛上传失败,详情{}", pathAndName, response.bodyString());}} catch (QiniuException e) {("七牛上传失败", e);}}@Overridepublic String authorize(String pathAndName, long time) {return "";}@Overridepublic String authorizeAllName(String pathAndName, long time) {return "";}@Overridepublic Map<String, Object> tokens(String dir) {Map<String, Object> result = wHashMap();return result;}@Overridepublic void deleteFile(String pathAndName) {}@Overridepublic String getFilePathPrefix() {return bucketName+"/";}
}

五、application配置文件