【前言】

       我们上家公司的存储系统用的是FastDFS（）；现在在职的公司用的是阿里云的OSS（），在工作的时候整理一个上传OSS文件的工具类，现在与大家分享一下。

【工具类】

       1、工具类的代码：

package zhanghan.oss.utils;

import com.aliyun.oss.ClientException;

import com.aliyun.oss.OSSClient;

import com.aliyun.oss.OSSException;

import com.aliyun.oss.model.ObjectMetadata;

import com.aliyun.oss.model.PutObjectResult;

import com.fasterxml.jackson.annotation.JsonValue;

import org.apache.commons.io.FilenameUtils;

import org.apache.commons.lang3.time.DateUtils;

import org.springframework.util.StringUtils;

import org.springframework.web.multipart.MultipartFile;

import zhanghan.oss.exception.OSSCreateBucketRuntimeException;

import zhanghan.oss.exception.OSSGeneratePresignedUrlRuntimeException;

import zhanghan.oss.exception.OssPutObjectRuntimeException;

import java.io.InputStream;

import java.net.URL;

import java.util.Date;

import java.util.UUID;

/**

* OSS上传工具类-张晗-2017/10/10

*/

public class OSSUtil {

private volatile static OSSClient instance;

private OSSUtil() {

}

/**

* 单例

* @return OSS工具类实例

*/

private static OSSClient getOSSClient() {

if (instance == null) {

synchronized (OSSUtil.class) {

if (instance == null) {

instance = new OSSClient(OSS_END_POINT, OSS_ACCESS_KEY_ID, OSS_ACCESS_KEY_SECRET);

}

}

}

return instance;

}

//定义日志

private final static LogUtils logger = LogUtils.getLogger(OSSUtil.class);

//OSS 的地址

private final static String OSS_END_POINT = "http://oss-cn-qingdao.aliyuncs.com";

//OSS 的key值

private final static String OSS_ACCESS_KEY_ID = "OSSKEY";

//OSS 的secret值

private final static String OSS_ACCESS_KEY_SECRET = "OSSSECRET";

//OSS 的bucket名字

private final static String OSS_BUCKET_NAME = "zhanghan-test";

//设置URL过期时间为10年

private final static Date OSS_URL_EXPIRATION = DateUtils.addDays(new Date(), 365 * 10);

//文件路径的枚举

public enum FileDirType {

ZHANGHAN_TEST("test");

private String dir;

FileDirType(String dir) {

this.dir = dir;

}

@JsonValue

public String getDir() {

return dir;

}

}

/**

* 上传文件---去除URL中的？后的时间戳

* @param file 文件

* @param fileDir 上传到OSS上文件的路径

* @return 文件的访问地址

*/

public static String upload(MultipartFile file, FileDirType fileDir) {

OSSUtil.createBucket();

String fileName = OSSUtil.uploadFile(file, fileDir);

String fileOssURL = OSSUtil.getImgUrl(fileName, fileDir);

int firstChar = fileOssURL.indexOf("?");

if (firstChar > 0) {

fileOssURL = fileOssURL.substring(0, firstChar);

}

return fileOssURL;

}

/**

* 当Bucket不存在时创建Bucket

*

* @throws OSSException 异常

* @throws ClientException Bucket命名规则：

* 1.只能包含小写字母、数字和短横线，

* 2.必须以小写字母和数字开头和结尾

* 3.长度在3-63之间

*/

private static void createBucket() {

try {

if (!OSSUtil.getOSSClient().doesBucketExist(OSS_BUCKET_NAME)) {

//判断是否存在该Bucket，不存在时再重新创建

OSSUtil.getOSSClient().createBucket(OSS_BUCKET_NAME);

}

} catch (Exception e) {

logger.error("{}", "创建Bucket失败,请核对Bucket名称(规则：只能包含小写字母、数字和短横线，必须以小写字母和数字开头和结尾，长度在3-63之间)");

throw new OSSCreateBucketRuntimeException("创建Bucket失败,请核对Bucket名称(规则：只能包含小写字母、数字和短横线，必须以小写字母和数字开头和结尾，长度在3-63之间)");

}

}

/**

* 上传到OSS服务器 如果同名文件会覆盖服务器上的

* @param file 文件

* @param fileDir 上传到OSS上文件的路径

* @return 文件的访问地址

*/

private static String uploadFile(MultipartFile file, FileDirType fileDir) {

String fileName = String.format(

"%s.%s",

UUID.randomUUID().toString(),

FilenameUtils.getExtension(file.getOriginalFilename()));

try (InputStream inputStream = file.getInputStream()) {

//创建上传Object的Metadata

ObjectMetadata objectMetadata = new ObjectMetadata();

objectMetadata.setContentLength(inputStream.available());

objectMetadata.setCacheControl("no-cache");

objectMetadata.setHeader("Pragma", "no-cache");

objectMetadata.setContentType(getContentType(FilenameUtils.getExtension("." + file.getOriginalFilename())));

objectMetadata.setContentDisposition("inline;filename=" + fileName);

//上传文件

PutObjectResult putResult = OSSUtil.getOSSClient().putObject(OSS_BUCKET_NAME, fileDir.getDir() + fileName, inputStream, objectMetadata);

return fileName;

} catch (Exception e) {

logger.error("{}", "上传文件失败");

throw new OssPutObjectRuntimeException("上传文件失败");

}

}

/**

* 获得文件路径

* @param fileUrl 文件的URL

* @param fileDir 文件在OSS上的路径

* @return 文件的路径

*/

private static String getImgUrl(String fileUrl, FileDirType fileDir) {

if (StringUtils.isEmpty(fileUrl)) {

logger.error("{}", "文件地址为空");

throw new RuntimeException("文件地址为空");

}

String[] split = fileUrl.split("/");

//获取oss图片URL失败

URL url = OSSUtil.getOSSClient().generatePresignedUrl(OSS_BUCKET_NAME, fileDir.getDir() + split[split.length - 1], OSS_URL_EXPIRATION);

if (url == null) {

logger.error("{}", "获取oss文件URL失败");

throw new OSSGeneratePresignedUrlRuntimeException("获取oss文件URL失败");

}

return url.toString();

}

/**

* 判断OSS服务文件上传时文件的contentType

*

* @param FilenameExtension 文件后缀

* @return 后缀

*/

private static String getContentType(String FilenameExtension) {

if (FilenameExtension.equalsIgnoreCase("bmp")) {

return "image/bmp";

}

if (FilenameExtension.equalsIgnoreCase("gif")) {

return "image/gif";

}

if (FilenameExtension.equalsIgnoreCase("jpeg") ||

FilenameExtension.equalsIgnoreCase("jpg") ||

FilenameExtension.equalsIgnoreCase("png")) {

return "image/jpeg";

}

if (FilenameExtension.equalsIgnoreCase("html")) {

return "text/html";

}

if (FilenameExtension.equalsIgnoreCase("txt")) {

return "text/plain";

}

if (FilenameExtension.equalsIgnoreCase("vsd")) {

return "application/vnd.visio";

}

if (FilenameExtension.equalsIgnoreCase("pptx") ||

FilenameExtension.equalsIgnoreCase("ppt")) {

return "application/vnd.ms-powerpoint";

}

if (FilenameExtension.equalsIgnoreCase("docx") ||

FilenameExtension.equalsIgnoreCase("doc")) {

return "application/msword";

}

if (FilenameExtension.equalsIgnoreCase("xml")) {

return "text/xml";

}

return "image/jpeg";

}

}

       2、调用工具类的代码：

/**

* 上传文件测试

* @param multipartFile 待上传的文件

* @return 上传在OSS文件的访问路径

* @throws BusinessException 上传异常

*/

public String uploadTest(MultipartFile multipartFile) throws BusinessException{

try {

uploadResult = OSSUtil.upload(multipartFile, OSSUtil.FileDirType.ZHANGHAN_TEST);

} catch (Exception e) {

LoggerUtil.logService(LoggerUtil.spManualLoan, "SPManualLoanServiceImpl-submitLoan", "call OSSUtil.upload; Exception:" + e.getMessage());

throw new BusinessException(WrongMessageEnum.EXCEPTION_STORE);

}

return uploadResult;

}

       3、问题&解决：

          （1） 问题：通过URL在浏览器中访问时报如下错：

  

          （2）解决方案：在阿里云的控制台上，进入OSS的设置界面，将Bucket的访问权限由 私有 设置为 公共读

【总结】

       阿里云现在很多公司都在用，阿里云稳定，安全，相对来说成本更低；给自己更多思考的是如何让项目减少成本，以及阿里云等带来的商业模式。