这篇文章主要介绍SpringBoot整合阿里云OSS对象存储服务的方法是什么，文中介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们一定要看完！
一、配置OSS服务
先在阿里云开通对象存储服务，拿到AccessKeyId、AccessKeySecret。
创建你的bucket(存储空间)，相当于一个一个的文件夹目录。按业务需求分类存储你的文件，图片，音频，app包等等。创建bucket是要选择该bucket的权限，私有，公共读，公共读写，按需求选择。创建bucket时对应的endpoint要记住，上传文件需要用到。
可以配置bucket的生命周期，比如说某些文件有过期时间的，可以配置一下。
二、代码实现
引入依赖包
<dependency> <groupId>com.aliyun.oss</groupId> <artifactId>aliyun-sdk-oss</artifactId> <version>2.8.3</version> </dependency>
配置文件application.yml
aliyun-oss: #bucket名称 bucketApp: xxx-app domainApp: https://xxx-app.oss-cn-shenzhen.aliyuncs.com/ region: oss-cn-shenzhen endpoint : https://oss-cn-shenzhen.aliyuncs.com accessKeyId: 你的accessKeyId accessKeySecret: 你的accessKeySecret
对应上面配置文件的properties类
package com.example.file.config;
import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;
@Component
@ConfigurationProperties(prefix = "aliyun-oss")
@Data
public class AliyunOSSProperties {
/**
* 服务器地点
*/
private String region;
/**
* 服务器地址
*/
private String endpoint;
/**
* OSS身份id
*/
private String accessKeyId;
/**
* 身份密钥
*/
private String accessKeySecret;
/**
* App文件bucketName
*/
private String bucketApp;
/**
* App包文件地址前缀
*/
private String domainApp;
}上传文件工具类
package com.example.file.utils;
import com.aliyun.oss.OSSClient;
import com.aliyun.oss.OSSException;
import com.aliyun.oss.model.ObjectMetadata;
import com.aliyun.oss.model.PutObjectResult;
import com.example.common.exception.BusinessErrorCode;
import com.example.common.exception.BusinessException;
import com.example.common.utils.FileIdUtils;
import com.example.file.config.AliyunOSSProperties;
import com.example.file.config.FileTypeEnum;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.lang3.Validate;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.web.multipart.MultipartFile;
import java.io.IOException;
import java.io.InputStream;
import java.util.ArrayList;
import java.util.List;
@Component
public class AliyunOSSUtil {
@Autowired
private AliyunOSSProperties aliyunOSSProperties;
private static Logger logger = LoggerFactory.getLogger(AliyunOSSUtil.class);
/**
* 文件不存在
*/
private final String NO_SUCH_KEY = "NoSuchKey";
/**
* 存储空间不存在
*/
private final String NO_SUCH_BUCKET = "NoSuchBucket";
/**
* 上传文件到阿里云 OSS 服务器
*
* @param files
* @param fileTypeEnum
* @param bucketName
* @param storagePath
* @return
*/
public List<String> uploadFile(MultipartFile[] files, FileTypeEnum fileTypeEnum, String bucketName, String storagePath, String prefix) {
//创建OSSClient实例
OSSClient ossClient = new OSSClient(aliyunOSSProperties.getEndpoint(), aliyunOSSProperties.getAccessKeyId(), aliyunOSSProperties.getAccessKeySecret());
List<String> fileIds = new ArrayList<>();
try {
for (MultipartFile file : files) {
//创建一个唯一的文件名，类似于id，就是保存在OSS服务器上文件的文件名(自定义文件名)
String fileName = FileIdUtils.creater(fileTypeEnum.getCode());
InputStream inputStream = file.getInputStream();
ObjectMetadata objectMetadata = new ObjectMetadata();
//设置数据流里有多少个字节可以读取
objectMetadata.setContentLength(inputStream.available());
objectMetadata.setCacheControl("no-cache");
objectMetadata.setHeader("Pragma", "no-cache");
objectMetadata.setContentType(file.getContentType());
objectMetadata.setContentDisposition("inline;filename=" + fileName);
fileName = StringUtils.isNotBlank(storagePath) ? storagePath + "/" + fileName : fileName;
//上传文件
PutObjectResult result = ossClient.putObject(bucketName, fileName, inputStream, objectMetadata);
logger.info("Aliyun OSS AliyunOSSUtil.uploadFileToAliyunOSS,result:{}", result);
fileIds.add(prefix + fileName);
}
} catch (IOException e) {
logger.error("Aliyun OSS AliyunOSSUtil.uploadFileToAliyunOSS fail,reason:{}", e);
} finally {
ossClient.shutdown();
}
return fileIds;
}
/**
* 删除文件
*
* @param fileName
* @param bucketName
*/
public void deleteFile(String fileName, String bucketName) {
OSSClient ossClient = new OSSClient(aliyunOSSProperties.getEndpoint(), aliyunOSSProperties.getAccessKeyId(), aliyunOSSProperties.getAccessKeySecret());
ossClient.deleteObject(bucketName, fileName);
shutdown(ossClient);
}
/**
* 根据图片全路径删除就图片
*
* @param imgUrl 图片全路径
* @param bucketName 存储路径
*/
public void delImg(String imgUrl, String bucketName) {
if (StringUtils.isBlank(imgUrl)) {
return;
}
//问号
int index = imgUrl.indexOf('?');
if (index != -1) {
imgUrl = imgUrl.substring(0, index);
}
int slashIndex = imgUrl.lastIndexOf('/');
String fileId = imgUrl.substring(slashIndex + 1);
OSSClient ossClient = new OSSClient(aliyunOSSProperties.getEndpoint(), aliyunOSSProperties.getAccessKeyId(), aliyunOSSProperties.getAccessKeySecret());
ossClient.deleteObject(bucketName, fileId);
shutdown(ossClient);
}
/**
* 判断文件是否存在
*
* @param fileName 文件名称
* @param bucketName 文件储存空间名称
* @return true:存在,false:不存在
*/
public boolean doesObjectExist(String fileName, String bucketName) {
Validate.notEmpty(fileName, "fileName can be not empty");
Validate.notEmpty(bucketName, "bucketName can be not empty");
OSSClient ossClient = new OSSClient(aliyunOSSProperties.getEndpoint(), aliyunOSSProperties.getAccessKeyId(), aliyunOSSProperties.getAccessKeySecret());
try {
boolean found = ossClient.doesObjectExist(bucketName, fileName);
return found;
} finally {
shutdown(ossClient);
}
}
/**
* 复制文件
*
* @param fileName 源文件名称
* @param bucketName 源储存空间名称
* @param destinationBucketName 目标储存空间名称
* @param destinationObjectName 目标文件名称
*/
public void ossCopyObject(String fileName, String bucketName, String destinationBucketName, String destinationObjectName) {
Validate.notEmpty(fileName, "fileName can be not empty");
Validate.notEmpty(bucketName, "bucketName can be not empty");
Validate.notEmpty(destinationBucketName, "destinationBucketName can be not empty");
Validate.notEmpty(destinationObjectName, "destinationObjectName can be not empty");
OSSClient ossClient = new OSSClient(aliyunOSSProperties.getEndpoint(), aliyunOSSProperties.getAccessKeyId(), aliyunOSSProperties.getAccessKeySecret());
// 拷贝文件。
try {
ossClient.copyObject(bucketName, fileName, destinationBucketName, destinationObjectName);
} catch (OSSException oe) {
logger.error("errorCode:{},Message:{},requestID:{}", oe.getErrorCode(), oe.getMessage(), oe.getRequestId());
if (oe.getErrorCode().equals(NO_SUCH_KEY)) {
throw new BusinessException(BusinessErrorCode.NO_SUCH_KEY);
} else if (oe.getErrorCode().equals(NO_SUCH_BUCKET)) {
throw new BusinessException(BusinessErrorCode.NO_SUCH_BUCKET);
} else {
throw new BusinessException(BusinessErrorCode.FAIL);
}
} finally {
shutdown(ossClient);
}
}
/**
* 关闭oos
*
* @param ossClient ossClient
*/
private void shutdown(OSSClient ossClient) {
ossClient.shutdown();
}
}文件类型枚举
package com.example.file.config;
public enum FileTypeEnum {
IMG(1, "图片"),
AUDIO(2, "音频"),
VIDEO(3, "视频"),
APP(4, "App包"),
OTHER(5, "其他");
private Integer code;
private String message;
FileTypeEnum(Integer code, String message) {
this.code = code;
this.message = message;
}
public Integer getCode() {
return code;
}
public String getMessage() {
return message;
}
}调用工具类上传文件
@Override
public List<String> uploadImg(MultipartFile[] files) {
if (files == null) {
throw new BusinessException(BusinessErrorCode.OPT_UPLOAD_FILE);
}
try {
return aliyunOSSUtil.uploadFile(files, FileTypeEnum.IMG, aliyunOSSProperties.getBucketProduct(), null, aliyunOSSProperties.getDomainProduct());
} catch (Exception e) {
logger.error("uploadImg error e:{}", e);
throw new BusinessException(BusinessErrorCode.UPLOAD_FAIL);
}
}返回的List是文件上传之后文件的文件名集合。
以上是SpringBoot整合阿里云OSS对象存储服务的方法是什么的所有内容，感谢各位的阅读！希望分享的内容对大家有帮助，更多相关知识，欢迎关注亿速云行业资讯频道！
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
