OssUtil.java
@Slf4j
@Component
public class OssUtil {
/**
* EtpConfig->service模块
* util无法获取
*/
private static String endpoint = "http://oss-cn-qingdao.aliyuncs.com";
private static String accessKeyId = "accessKeyId ";
private static String accessKeySecret = "accessKeySecret ";
private static String bucketName = "bucketName ";
/**
* 上传文件-文件夹拼接(a/b/c/+filename)(流的形式-ecs免流量)
* @param inputStream 文件流
* @param folder 文件夹
* @param fileName 文件名字(保留后缀)
* @return 保存的文件key
*/
public static String uploadObjectByInputStream(InputStream inputStream, String folder, String fileName){
OSS client = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
//folder+/+fileName
String key;
if(StringUtils.isEmpty(folder)){
key = fileName;
}else{
key = folder + fileName;
}
try{
client.putObject(bucketName, key, inputStream);
}catch (Exception e){
throw e;
}finally {
client.shutdown();
}
return key;
}
/**
* 上传文件-全路径(a/b/c/filename)(流的形式-ecs免流量)
* @param inputStream 文件流
* @param fileFullPath 文件全路径(保留后缀)
* @return 保存的文件key
*/
public static String uploadObjectByInputStream(InputStream inputStream, String fileFullPath) throws Exception{
OSS client = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
try{
client.putObject(bucketName, fileFullPath, inputStream);
}catch (Exception e){
throw e;
}finally {
client.shutdown();
}
return fileFullPath;
}
/**
* 通过oss->File->key值 获取对应文件的流(字节-网络传输)
* @param fileKey
* @return
*/
public static byte[] getFileByteByKey(String fileKey) throws Exception {
OSS client = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
InputStream inputStream = null;
byte[] result = null;
try {
OSSObject ossObject = client.getObject(bucketName, fileKey);
inputStream = ossObject.getObjectContent();
result = toByteArray(inputStream);
}catch (Exception e){
throw e;
}finally {
try{
if(inputStream!=null){
inputStream.close();
}
}catch (Exception e){
e.printStackTrace();
}
client.shutdown();
}
return result;
}
/**
* 通过key值 获取对应文件的流(InputStream)
* 实际上这个方法是无效的(client.shutdwon()会将流关闭 )
* 所以可以这里进行流的操作 (比如可以参见:getFileByteByKey())
* 把流读取到可以被保存的数据媒介中
* @param fileKey
* @return
*/
@Deprecated
public static InputStream getFileInputStreamByKey(String fileKey) {
OSS client = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
InputStream inputStream = null;
try {
OSSObject ossObject = client.getObject(bucketName, fileKey);
inputStream = ossObject.getObjectContent();
}catch (Exception e){
throw e;
}finally {
try{
if(inputStream!=null){
inputStream.close();
}
}catch (Exception e){
e.printStackTrace();
}
client.shutdown();
}
return inputStream;
}
/**
* 根据文件名获取文件访问URL(外网访问-下行收费)
* @param ossFileKey 文件名
* @param expires URL有效时间（小时）
* @return
*/
public static String getFileUrl(String ossFileKey, int expires) {
OSS client = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
URL url = client.generatePresignedUrl(bucketName, ossFileKey, dateAfter(new Date(), expires, Calendar.HOUR));
String path = url.toString();
return path;
}
/**
* 原图生成缩略图url
* @param ossFileKey
* @return
*/
public static String getSltFileUrl(String ossFileKey,String centerName) throws IOException {
OSS client = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
/**
* 控制台设置的图片处理的style或者默认style
*/
String style = "image/auto-orient,1/resize,m_lfit,w_100/quality,q_90";
GetObjectRequest request = new GetObjectRequest(bucketName,ossFileKey);
request.setProcess(style);
OSSObject ossObject = client.getObject(request);
InputStream inputStream = ossObject.getObjectContent();
String suffix = ossFileKey.substring(ossFileKey.lastIndexOf("."));
String name = ossFileKey.substring(0,ossFileKey.lastIndexOf("."));
String sltName = name+centerName+suffix;
System.out.println(sltName);
try{
client.putObject(bucketName, sltName, inputStream);
}catch (Exception e){
throw e;
}finally {
client.shutdown();
}
return sltName;
}
/**
* (private)input转字节
* @param input
* @return
* @throws Exception
*/
private static byte[] toByteArray(InputStream input) throws Exception {
ByteArrayOutputStream output = new ByteArrayOutputStream();
byte[] buffer = new byte[4096];
int n = 0;
while (-1 != (n = input.read(buffer))) {
output.write(buffer, 0, n);
}
return output.toByteArray();
}
/**
* (private)获得指定日期之后一段时期的日期。例如某日期之后3天的日期等。
* @param origDate 基准日期
* @param amount 基准日期
* @param timeUnit 时间单位，如年、月、日等。用Calendar中的常量代表
* @return
*/
private static final Date dateAfter(Date origDate, int amount, int timeUnit) {
Calendar calendar = Calendar.getInstance();
calendar.setTime(origDate);
calendar.add(timeUnit, amount);
return calendar.getTime();
}
}
controller
@RestController
@RequestMapping("/fileOss")
@Slf4j
public class FileOssController {
@Autowired
private OssUtil ossUtil;
@RequestMapping("/upload")
@ResponseBody
public R uploadFile(@RequestParam("images") MultipartFile file) throws Exception {
String filename = file.getOriginalFilename();
//String caselsh = filename.substring(0,filename.lastIndexOf("."));
//String suffix = filename.substring(filename.lastIndexOf(".")+1);
String fileKey = ossUtil.uploadObjectByInputStream(file.getInputStream(),filename);
Map<String,Object> params = new HashMap<>();
params.put("fileKey",fileKey);
return R.ok(params);
}
/**
* 通过fileKey获取oss流数据并返回
* @param ossFileKey
* @return
*/
@RequestMapping("/getByteByOssFileKey")
@ResponseBody
public byte[] getByteByOssFileKey(@RequestParam("ossFileKey") String ossFileKey) throws Exception{
return ossUtil.getFileByteByKey(ossFileKey);
}
/**
* 通过fileKey获取oss文件的url 测试接口3
* @param ossFileKey
* @return
*/
@RequestMapping("/getUrlByOssFileKey")
@ResponseBody
public R getUrlByOssFileKey(@RequestParam String ossFileKey){
String url = ossUtil.getFileUrl(ossFileKey,24);
Map<String,Object> params = new HashMap<>();
params.put("fileurl",url);
return R.ok(params);
}
}
部分接口访问的例子 .html
<img id="imgReturn" src="/fileOss/getByteByOssFileKey?ossFileKey=XXX">
