package com.gear.common.utils.oss;
|
import com.aliyun.oss.OSS;
|
import com.aliyun.oss.model.GetObjectRequest;
|
import com.aliyun.oss.model.OSSObject;
|
import com.aliyun.oss.model.PutObjectRequest;
|
import com.gear.common.config.OssConfig;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
import org.springframework.web.multipart.MultipartFile;
|
import javax.annotation.PostConstruct;
|
import java.io.*;
|
|
@Component
|
public class AliyunOssUtil {
|
/**
|
* 此处的oss是将配置文件中的参数配置后生成bean，通过自动注入来获取配置参数后的对象oss
|
*/
|
@Autowired
|
private OSS oss;
|
/**
|
* 为了能在每个方法中使用配置号参数的oss对象，需要将其静态化，如果oss被static修饰，则每次调用时oss都是空，所以这里需要做一下转换
|
* 通过postConstruct注解将oss转为静态的ossP,这样在每次调用时都是配置好的参数的一个oss对象
|
* @PostConstruct是Java自带的注解，在方法上加该注解会在项目启动的时候执行该方法，也可以理解为在spring容器初始化的时候执行该方法。
|
* @postConstruct可以修饰一个非静态的void方法，使用场景为：在生成对象时想完成某些初始化操作，初始化又依赖于自动注入，构造方法中无法实现时
|
* 使用此注解修饰一个方法来实现初始化操作，注解的方法会在自动注入完成后被调用-----执行顺序--》construct构造函数-》@Autowired自动注入-》@PostConstruct
|
*/
|
private static OSS ossP;
|
|
/**
|
* 默认的oss桶位置
|
*/
|
public static final String fixedBucket = "sax-bucket-1";
|
|
|
@PostConstruct
|
public void ossTransfer(){
|
//该方法会在上面的依赖注入后自动被调用
|
ossP = oss;
|
}
|
|
|
/**
|
* 上传字符串
|
* @param objectName oss文件全路径名-默认是桶位置加全路径名，如桶位置为ossbucket，全路径名为upload/string/str.json，则数据会放到ossbucket下的upload/string包中，文件名为str.json
|
* @param content 上传内容
|
*/
|
public static void uploadString(String objectName, String content){
|
PutObjectRequest putObjectRequest = new PutObjectRequest(fixedBucket, objectName, new ByteArrayInputStream(content.getBytes()));
|
ossP.putObject(putObjectRequest);
|
}
|
|
/**
|
* 上传字符串
|
* @param bucketName 文件存在oss的桶名称
|
* @param objectName 文件在oss中的全路径
|
* @param content 上传内容
|
*/
|
public static void uploadString(String bucketName, String objectName, String content){
|
PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, objectName, new ByteArrayInputStream(content.getBytes()));
|
ossP.putObject(putObjectRequest);
|
}
|
|
/**
|
* 上传文件
|
* @param objectName 文件在oss中的全路径
|
* @param filePath 上传文件的本地路径
|
*/
|
public static void uploadFile(String objectName, String filePath){
|
PutObjectRequest putObjectRequest = new PutObjectRequest(fixedBucket, objectName, new File(filePath));
|
ossP.putObject(putObjectRequest);
|
}
|
|
/**
|
* 上传文件
|
* @param bucketName 文件所在oss桶名称
|
* @param objectName 文件在oss中的全路径
|
* @param filePath 上传文件的本地路径
|
*/
|
public static void uploadFile(String bucketName, String objectName, String filePath){
|
PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, objectName, new File(filePath));
|
ossP.putObject(putObjectRequest);
|
}
|
|
/**
|
* 上传multi文件
|
* @param objectName 文件全路径
|
* @param multipartFile 上传的文件
|
*/
|
public static void uploadMultipartFile(String objectName, MultipartFile multipartFile){
|
byte[] bytes = new byte[0];
|
try {
|
bytes = multipartFile.getBytes();
|
} catch (IOException e) {
|
throw new RuntimeException(e);
|
}
|
InputStream inputStream = new ByteArrayInputStream(bytes);
|
PutObjectRequest putObjectRequest = new PutObjectRequest(fixedBucket, objectName, inputStream);
|
ossP.putObject(putObjectRequest);
|
}
|
|
/**
|
* multi方式上传文件
|
* @param bucketName oss中桶名称
|
* @param objectName 文件在oss中的全路径
|
* @param multipartFile 上传的文件
|
*/
|
public static void uploadMultipartFile(String bucketName, String objectName, MultipartFile multipartFile){
|
byte[] bytes = new byte[0];
|
try {
|
bytes = multipartFile.getBytes();
|
} catch (IOException e) {
|
throw new RuntimeException(e);
|
}
|
InputStream inputStream = new ByteArrayInputStream(bytes);
|
PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, objectName, inputStream);
|
ossP.putObject(putObjectRequest);
|
}
|
|
/**
|
* 上传流数据
|
* @param objectName 数据在oss中的全路径
|
* @param inputStream 流数据内容
|
*/
|
public static void uploadStream(String objectName, InputStream inputStream){
|
PutObjectRequest putObjectRequest = new PutObjectRequest(fixedBucket, objectName, inputStream);
|
ossP.putObject(putObjectRequest);
|
}
|
|
/**
|
* 上传流数据
|
* @param bucketName oss桶名称
|
* @param objectName 数据所在oss中的全路径
|
* @param inputStream 流数据
|
*/
|
public static void uploadStream(String bucketName, String objectName, InputStream inputStream){
|
PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, objectName, inputStream);
|
ossP.putObject(putObjectRequest);
|
}
|
|
/**
|
* 下载字符串数据
|
* @param objectName 数据所在oss的全路径
|
* @return 字符串
|
* @throws IOException
|
*/
|
public static String downloadString(String objectName) throws IOException {
|
OSSObject ossObject = ossP.getObject(fixedBucket, objectName);
|
BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(ossObject.getObjectContent()));
|
StringBuilder stringBuilder = new StringBuilder();
|
while (true){
|
String line = bufferedReader.readLine();
|
if(line==null){
|
break;
|
}else {
|
stringBuilder.append(line);
|
}
|
}
|
bufferedReader.close();
|
return stringBuilder.toString();
|
}
|
|
/**
|
* 下载字符串数据
|
* @param bucketName oss桶位置
|
* @param objectName 数据所在oss中的全路径
|
* @return 返回字符串
|
* @throws IOException
|
*/
|
public static String downloadString(String bucketName, String objectName) throws IOException {
|
OSSObject ossObject = ossP.getObject(bucketName, objectName);
|
BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(ossObject.getObjectContent()));
|
StringBuilder stringBuilder = new StringBuilder();
|
while (true){
|
String line = bufferedReader.readLine();
|
if(line==null){
|
break;
|
}else {
|
stringBuilder.append(line);
|
}
|
}
|
bufferedReader.close();
|
return stringBuilder.toString();
|
}
|
|
/**
|
* 下载文件
|
* @param objectName 数据所在oss全路径
|
* @param fileName 文件名
|
*/
|
public static void downloadFile(String objectName, String fileName){
|
ossP.getObject(new GetObjectRequest(fixedBucket, objectName),new File(fileName));
|
}
|
|
/**
|
* 下载文件
|
* @param bucketName 文件所在oss桶名称
|
* @param objectName 文件所在oss中的全路径
|
* @param fileName 文件名
|
*/
|
public static void downloadFile(String bucketName, String objectName, String fileName){
|
ossP.getObject(new GetObjectRequest(bucketName, objectName),new File(fileName));
|
}
|
|
/**
|
* 删除数据
|
* @param objectName 删除文件的全路径
|
*/
|
public static void delete(String objectName){
|
ossP.deleteObject(fixedBucket, objectName);
|
}
|
|
/**
|
* 删除数据
|
* @param bucketName 桶名称
|
* @param objectName 删除文件的全路径
|
*/
|
public static void delete(String bucketName, String objectName){
|
ossP.deleteObject(bucketName, objectName);
|
}
|
|
/**
|
* 检查文件是否存在
|
* @param objectName 文件所在oss中的全路径
|
* @return 返回是否
|
*/
|
public static boolean checkExist(String objectName){
|
boolean exist = ossP.doesObjectExist(fixedBucket, objectName);
|
return exist;
|
}
|
|
/**
|
* 检查文件是否存在
|
* @param bucketName 桶名称
|
* @param objectName 文件所在oss中的全路径
|
* @return 返回是否
|
*/
|
public static boolean checkExist(String bucketName, String objectName){
|
boolean exist = ossP.doesObjectExist(bucketName, objectName);
|
return exist;
|
}
|
|
|
}
|
