Springboot集成阿里云对象存储OSS

一、对象存储OSS阿里云对象存储OSS(Object Storage Service)具有丰富的安全防护能力,支持服务器端加密、客户端加密、防盗链白名单、细粒度权限管控、日志审计、合规保留策略(WORM)等特性 。OSS为您的云端数据安全进行全方位的保驾护航,并满足您企业数据的安全与合规要求 。
二、应用场景数据签迁移、数据湖、企业数据存储和管理、数据处理、容灾与备份

Springboot集成阿里云对象存储OSS

文章插图
 
三、开通阿里云OSS1、(1)申请阿里云账号
(2)实名认证
(3)开通“对象存储OSS”服务
(4)进入管理控制台
Springboot集成阿里云对象存储OSS

文章插图
 
 
Springboot集成阿里云对象存储OSS

文章插图
 
2、创建Bucket
 
选择:标准存储、公共读、不开通
Springboot集成阿里云对象存储OSS

文章插图
 
3、上传图片
创建文件夹avatar,上传默认的用户图片
Springboot集成阿里云对象存储OSS

文章插图
 
【Springboot集成阿里云对象存储OSS】4、创建RAM子用户、用于程序访问对象存储OSS
Springboot集成阿里云对象存储OSS

文章插图
 
四、使用SDK
Springboot集成阿里云对象存储OSS

文章插图
 
1,创建Maven项目
com.atguigu aliyun-oss
2,pom
<dependencies><!-- 阿里云oss依赖 --><dependency><groupId>com.aliyun.oss</groupId><artifactId>aliyun-sdk-oss</artifactId></dependency><!-- 日期工具栏依赖 --><dependency><groupId>joda-time</groupId><artifactId>joda-time</artifactId></dependency></dependencies>3,找到编码用的常量配置
(1)endpoint (2)bucketName (3)accessKeyId (4)accessKeySecret
4,测试Bucket连接
public class OSSTest {// Endpoint以杭州为例,其它Region请按实际情况填写 。String endpoint = "oss-cn-beijing.aliyuncs.com";// 阿里云主账号AccessKey拥有所有API的访问权限,风险很高 。强烈建议您创建并使用RAM账号进行API访问或日常运维,请登录 https://ram.console.aliyun.com 创建RAM账号 。String accessKeyId = "LTAI5tSjEbLtaqn8HMe4zF4G";String accessKeySecret = "mGgEO1ueh5WdVK4oK4kJOSPQgHPR5m";String bucketName = "fire-file";@Testpublic void testCreateBucket() {// 创建OSSClient实例 。OSSClient ossClient = new OSSClient(endpoint, accessKeyId, accessKeySecret);// 创建存储空间 。ossClient.createBucket(bucketName);// 关闭OSSClient 。System.out.println(ossClient.listBuckets());//ossClient.shutdown();}@Testpublic void testExist() {// 创建OSSClient实例 。OSSClient ossClient = new OSSClient(endpoint, accessKeyId, accessKeySecret);boolean exists = ossClient.doesBucketExist(bucketName);System.out.println(exists);// 关闭OSSClient 。ossClient.shutdown();}}五、Springboot集成阿里云OSS1,在service模块下创建子模块service-oss
Springboot集成阿里云对象存储OSS

文章插图
 
2,配置Pom.xml
service-oss上级模块service已经引入service的公共依赖,所以service-oss模块只需引入阿里云oss相关依赖即可,service父模块已经引入了service-base模块,所以Swagger相关默认已经引入,上边已经引过了
3,配置Application.properties
#服务端口server.port=8002#服务名spring.application.name=service-oss#环境设置:dev、test、prodspring.profiles.active=dev#阿里云 OSS#不同的服务器,地址不同aliyun.oss.file.endpoint=oss-cn-beijing.aliyuncs.comaliyun.oss.file.keyid=LTAI5tSjEbLtaqn8HMe4zF4Galiyun.oss.file.keysecret=mGgEO1ueh5WdVK4oK4kJOSPQgHPR5m#bucket可以在控制台创建,也可以使用JAVA代码创建aliyun.oss.file.bucketname=fire-file5,创建启动类
@ComponentScan({"com.atguigu"})@SpringBootApplication(exclude = DataSourceAutoConfiguration.class)public class OssApplication {public static void main(String[] args) {SpringApplication.run(OssApplication.class,args);}}6,实现文件上传
创建常量读取工具类:
ConstantPropertiesUtil.java,使用@Value读取application.properties里的配置内容用spring的 InitializingBean 的 afterPropertiesSet 来初始化配置信息,这个方法将在所有的属性被初始化后调用 。
@Componentpublic class ConstantPropertiesUtil implements InitializingBean {@Value("${aliyun.oss.file.endpoint}")private String endpoint;@Value("${aliyun.oss.file.keyid}")private String keyId;@Value("${aliyun.oss.file.keysecret}")private String keySecret;@Value("${aliyun.oss.file.bucketname}")private String bucketName;public static String END_POINT;public static String ACCESS_KEY_ID;public static String ACCESS_KEY_SECRET;public static String BUCKET_NAME;@Overridepublic void afterPropertiesSet() throws Exception {END_POINT = endpoint;ACCESS_KEY_ID = keyId;System.out.println(ACCESS_KEY_ID+"==========================");ACCESS_KEY_SECRET = keySecret;BUCKET_NAME = bucketName;}}


推荐阅读