scopesystem来依赖_来吧，展示！SpringBootOSS整合全过程，没见过比这更详细的了...

前言

阿里云对象存储服务(Object Storage Service&＃xff0c;简称 OSS)&＃xff0c;是阿里云提供的海量、安全、低成本、高可靠的云存储服务。其数据设计持久性不低于 99.9999999999%(12 个 9)&＃xff0c;服务设计可用性(或业务连续性)不低于 99.995%。

OSS 具有与平台无关的 RESTful API 接口&＃xff0c;您可以在任何应用、任何时间、任何地点存储和访问任意类型的数据。

您可以使用阿里云提供的 API、SDK 接口或者 OSS 迁移工具轻松地将海量数据移入或移出阿里云 OSS。数据存储到阿里云 OSS 以后&＃xff0c;您可以选择标准存储(Standard)作为移动应用、大型网站、图片分享或热点音视频的主要存储方式&＃xff0c;也可以选择成本更低、存储期限更长的低频访问存储(Infrequent Access)和归档存储(Archive)作为不经常访问数据的存储方式。

登录阿里云&＃xff0c;进入到控制台

点击确定&＃xff0c;就建好了。

1. 接下来就开始附代码
   新建一个springboot项目
   导入依赖 pom.xml



4.0.0modelVersion>

org.examplegroupId>
SpringOOSartifactId>
1.0-SNAPSHOTversion>



org.springframework.bootgroupId>
spring-boot-starter-webartifactId>
2.3.0.RELEASEversion>
dependency>


org.springframework.bootgroupId>
spring-boot-starter-testartifactId>
testscope>
2.3.0.RELEASEversion>
dependency>



com.aliyun.ossgroupId>
aliyun-sdk-ossartifactId>
3.4.2version>
dependency>


org.projectlombokgroupId>
lombokartifactId>
1.18.4version>
providedscope>
dependency>

joda-timegroupId>
joda-timeartifactId>
2.9.9version>
dependency>


org.apache.commonsgroupId>
commons-lang3artifactId>
3.8.1version>
dependency>

dependencies>
project>



application.yml

## aliyun oss
## 配置说明参考: com.ljq.demo.springboot.common.config.OSSConfig.class
oss:
endpoint: oss-cn-shenzhen.aliyuncs.com
url: https://oos-all.oss-cn-shenzhen.aliyuncs.com/
accessKeyId: #这里在个人中心里accesskeys查看
accessKeySecret: #这里在个人中心里accesskeys查看
bucketName: #这里写OSS里自己创建的OSS文件夹



写一个config配置类

package com.sykj.config;

import lombok.Data;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Configuration;

import java.io.Serializable;

/**
* &＃64;Description: 阿里云 OSS 配置信息
* &＃64;Author: jiangpengcheng
* &＃64;Date: 2020/07/15
*/
&＃64;Data
&＃64;Configuration
public class OSSConfig implements Serializable {

private static final long serialVersionUID &＃61; -119396871324982279L;

/**
* 阿里云 oss 站点
*/
&＃64;Value("${oss.endpoint}")
private String endpoint;

/**
* 阿里云 oss 资源访问 url
*/
&＃64;Value("${oss.url}")
private String url;

/**
* 阿里云 oss 公钥
*/
&＃64;Value("${oss.accessKeyId}")
private String accessKeyId;

/**
* 阿里云 oss 私钥
*/
&＃64;Value("${oss.accessKeySecret}")
private String accessKeySecret;

/**
* 阿里云 oss 文件根目录
*/
&＃64;Value("${oss.bucketName}")
private String bucketName;

}



工具类

package com.sykj.util;

import com.aliyun.oss.ClientConfiguration;
import com.aliyun.oss.OSSClient;
import com.aliyun.oss.common.auth.DefaultCredentialProvider;
import com.aliyun.oss.model.ObjectMetadata;
import com.sykj.config.OSSConfig;
import org.springframework.web.multipart.MultipartFile;

import java.io.IOException;
import java.util.UUID;

/**
* &＃64;Description: 阿里云 oss 上传工具类(高依赖版)
* &＃64;Author: &＃64;author jiangpengcheng
* &＃64;Date: 2020/7/15
*/

public class OSSBootUtil {

private OSSBootUtil(){}

/**
* oss 工具客户端
*/
private volatile static OSSClient ossClient &＃61; null;

/**
* 上传文件至阿里云 OSS
* 文件上传成功,返回文件完整访问路径
* 文件上传失败,返回 null
* &＃64;author jiangpengcheng
* &＃64;param ossConfig oss 配置信息
* &＃64;param file 待上传文件
* &＃64;param fileDir 文件保存目录
* &＃64;return oss 中的相对文件路径
*/

public static String upload(OSSConfig ossConfig, MultipartFile file, String fileDir){
initOSS(ossConfig);
StringBuilder fileUrl &＃61; new StringBuilder();
try {
String suffix &＃61; file.getOriginalFilename().substring(file.getOriginalFilename().lastIndexOf(&＃39;.&＃39;));
String fileName &＃61; System.currentTimeMillis() &＃43; "-" &＃43; UUID.randomUUID().toString().substring(0,18) &＃43; suffix;
if (!fileDir.endsWith("/")) {
fileDir &＃61; fileDir.concat("/");
}
fileUrl &＃61; fileUrl.append(fileDir &＃43; fileName);
System.out.println(fileUrl&＃43;"-----------------");
ObjectMetadata objectMetadata &＃61; new ObjectMetadata();
objectMetadata.setContentType("image/jpg");

ossClient.putObject(ossConfig.getBucketName(), fileUrl.toString(), file.getInputStream(),objectMetadata);
} catch (IOException e) {
e.printStackTrace();
return null;
}
fileUrl &＃61; fileUrl.insert(0,ossConfig.getUrl());
return fileUrl.toString();
}

/**
* 初始化 oss 客户端
* &＃64;param ossConfig
* &＃64;return
*/
private static OSSClient initOSS(OSSConfig ossConfig) {
if (ossClient &＃61;&＃61; null ) {
synchronized (OSSBootUtil.class) {
if (ossClient &＃61;&＃61; null) {
ossClient &＃61; new OSSClient(ossConfig.getEndpoint(),
new DefaultCredentialProvider(ossConfig.getAccessKeyId(), ossConfig.getAccessKeySecret()),
new ClientConfiguration());
}
}
}
return ossClient;
}

/**
* 根据前台传过来的文件地址 删除文件
* &＃64;author jiangpengcheng
* &＃64;param objectName
* &＃64;param ossConfig
* &＃64;return
*/
public static ResponseResult delete(String objectName,OSSConfig ossConfig) {
initOSS(ossConfig);
//将完整路径替换成 文件地址 因为yml里的url有了地址链接https: //oos-all.oss-cn-shenzhen.aliyuncs.com/
// 如果再加上地址 那么又拼接了 所以删除不了 要先把地址替换为 jpc/2020-07-16/1594857669731-51d057b0-9778-4aed.png
String fileName &＃61; objectName.replace("https://oos-all.oss-cn-shenzhen.aliyuncs.com/", "");
System.out.println(fileName&＃43;"******************************");
// 根据BucketName,objectName删除文件
ossClient.deleteObject(ossConfig.getBucketName(), fileName);

return ResponseResult.ok("删除成功",fileName);
}
}



数据返回工具类

package com.sykj.util;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

import java.io.Serializable;

/**
* &＃64;ClassName ResponseResult
* &＃64;Description TODO
* Author JiangPengCheng
* Date 2020/7/15 9:13
**/
&＃64;Data
&＃64;NoArgsConstructor
&＃64;AllArgsConstructor
public class ResponseResult implements Serializable {
private Integer code;
private String message;
private Object object;

public static ResponseResult ok(String message){
return new ResponseResult(200,message,null);
}

public static ResponseResult ok(String message, Object object){
return new ResponseResult(200,message,object);
}

public static ResponseResult error(String message){
return new ResponseResult(500,message,null);
}
public static ResponseResult error(String message, Object o){
return new ResponseResult(500,message,o);
}
}



Service类

package com.sykj.service;

import com.sykj.util.ResponseResult;
import org.springframework.http.ResponseEntity;
import org.springframework.web.multipart.MultipartFile;

/**
* &＃64;Description: 公共业务
* &＃64;Author: junqiang.lu
* &＃64;Date: 2018/12/24
*/
public interface CommonService {

/**
* 上传文件至阿里云 oss
*
* &＃64;param file
* &＃64;param
* &＃64;return
* &＃64;throws Exception
*/
ResponseResult uploadOSS(MultipartFile file) throws Exception;

ResponseResult delete(String objectName);
}



Service实现类

package com.sykj.service.impl;

import com.sykj.config.OSSConfig;
import com.sykj.service.CommonService;
import com.sykj.util.OSSBootUtil;
import com.sykj.util.ResponseResult;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpStatus;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;

import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;

/**
* &＃64;Description: 公共业务具体实现类
* &＃64;Author: junqiang.lu
* &＃64;Date: 2018/12/24
*/
&＃64;Service("commonService")
public class CommonServiceImpl implements CommonService {

&＃64;Autowired
private OSSConfig ossConfig;

/**
* 上传文件至阿里云 oss
*
* &＃64;param file
* &＃64;param
* &＃64;return
* &＃64;throws Exception
*/
&＃64;Override

public ResponseResult uploadOSS(MultipartFile file) throws Exception {

// 格式化时间
SimpleDateFormat simpleDateFormat&＃61;new SimpleDateFormat("yyyy-MM-dd");
String format &＃61; simpleDateFormat.format(new Date());
// 高依赖版本 oss 上传工具
String ossFileUrlBoot &＃61; null;
/**
* ossConfig 配置类
* file 文件
* "jpc/"&＃43;format 上传文件地址 加时间戳
*/
ossFileUrlBoot &＃61; OSSBootUtil.upload(ossConfig, file, "jpc/"&＃43;format);
System.out.println(ossFileUrlBoot);
Map resultMap &＃61; new HashMap<>(16);
// resultMap.put("ossFileUrlSingle", ossFileUrlSingle);
resultMap.put("ossFileUrlBoot", ossFileUrlBoot);

return ResponseResult.ok("上传成功~~",ossFileUrlBoot);
}

&＃64;Override
public ResponseResult delete(String objectName) {
ResponseResult delete &＃61; OSSBootUtil.delete(objectName, ossConfig);
return delete;
}
}



Controller类

package com.sykj.comtroller;
import com.sun.org.apache.regexp.internal.RE;
import com.sykj.service.CommonService;
import com.sykj.util.ResponseResult;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpStatus;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;

/**
* &＃64;Description: 公共模块控制中心
* &＃64;Author: junqiang.lu
* &＃64;Date: 2018/12/24
*/
&＃64;RestController
&＃64;RequestMapping("api/demo/common")
public class CommonController {

private static final Logger logger &＃61; LoggerFactory.getLogger(CommonController.class);

&＃64;Autowired
private CommonService commonService;

/**
* 上传文件至阿里云 oss
*
* &＃64;param file
* &＃64;param
* &＃64;return
* &＃64;throws Exception
*/
&＃64;RequestMapping(value &＃61; "/upload/oss", method &＃61; {RequestMethod.POST}, produces &＃61; {MediaType.APPLICATION_JSON_VALUE})
public ResponseResult uploadOSS(&＃64;RequestParam(value &＃61; "file") MultipartFile file) throws Exception {
System.out.println(file.getInputStream());
// ResponseResult responseResult &＃61; commonService.uploadOSS(file);

// HttpHeaders headers &＃61; new HttpHeaders();
// headers.setContentType(MediaType.APPLICATION_JSON_UTF8);
return ResponseResult.ok("ok");
}

&＃64;RequestMapping("/delete/oss")
public ResponseResult deltetOss(String objectName){
System.out.println(objectName&＃43;"-------------------------------");
ResponseResult delete &＃61; commonService.delete(objectName);
return delete;
}

}



注意postman选择file

这样就完成了

最后

感谢你看到这里&＃xff0c;每天都会分享java相关技术文章或行业资讯&＃xff0c;欢迎大家关注和转发文章&＃xff01;