SpringBoot整合阿里云OSS

Posted 2021-12-29 LL.LEBRON

文章目录

• SpringBoot整合阿里云OSS
• • 1.准备工作
  • • 1.1 开通“对象存储OSS”服务
    • 1.2 创建Bucket
    • 1.3 创建RAM子用户
  • 2.SpringBoot整合阿里云OSS
  • • 2.1 创建SpringBoot项目
    • 2.2 配置application.properties
    • 2.3 创建常量读取工具类
    • 2.4 上传图片至阿里云
    • 2.5 使用swagger测试

SpringBoot整合阿里云OSS

为了解决海量数据存储与弹性扩容，项目中我们采用云存储的解决方案- 阿里云OSS

1.准备工作

1.1 开通“对象存储OSS”服务

步骤：

1. 申请阿里云账号
2. 实名认证
3. 开通“对象存储OSS”服务
4. 进入管理控制台

详细可以参考：OSS的购买和配置

1.2 创建Bucket

进入到管理控制台的Bucket列表创建一个Bucket：

如下：

1.3 创建RAM子用户

创建操作阿里云OSS许可证（阿里云颁发id和秘钥）：

创建AccessKey：

2.SpringBoot整合阿里云OSS

官方文档参考：对象存储OSS Java SDK

2.1 创建SpringBoot项目

导入依赖：

<dependencies>
    <!--aliyunOSS-->
    <dependency>
        <groupId>com.aliyun.oss</groupId>
        <artifactId>aliyun-sdk-oss</artifactId>
        <version>2.8.3</version>
    </dependency>
    <dependency>
        <groupId>junit</groupId>
        <artifactId>junit</artifactId>
        <version>4.12</version>
    </dependency>
</dependencies

2.2 配置application.properties

进入到对应的Bucket列表查看地域节点：

#服务端口
server.port=8002
#服务名
spring.application.name=service-oss
#环境设置：dev、test、prod
spring.profiles.active=dev

#阿里云 OSS
#不同的服务器，地址不同
aliyun.oss.file.endpoint=oss-cn-beijing.aliyuncs.com
aliyun.oss.file.keyid=LTAI5tGxxxxK4aAa
aliyun.oss.file.keysecret=zE4nEzmcUxxWRk0tytJKD
#bucket可以在控制台创建，也可以使用java代码创建
aliyun.oss.file.bucketname=xppll

2.3 创建常量读取工具类

创建常量读取工具类ConstantPropertiesUtils：

/**
 * @author xppll
 * @date 2021/12/2 19:11
 */
@Component
public class ConstantPropertiesUtils 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;

    @Override
    public void afterPropertiesSet() throws Exception 
        END_POINT = endpoint;
        ACCESS_KEY_ID = keyId;
        ACCESS_KEY_SECRET = keySecret;
        BUCKET_NAME = bucketName;
    

2.4 上传图片至阿里云

controller层：

/**
 * @author xppll
 * @date 2021/12/2 19:36
 */
@CrossOrigin
@RestController
@RequestMapping("eduoss/fileoss")
public class OssController 

    @Autowired
    private OssService ossService;
    //上传头像，返回图片的url给
    @PostMapping
    public R uploadOssFile(MultipartFile file)
        //获取上传文件 MultipartFile
        //返回图片在oss上的路径
        String url = ossService.uploadFileAvatar(file);
        return R.ok().data("url",url);
    

service层：

/**
 * @author xppll
 * @date 2021/12/2 19:36
 */
@Service
public class OssServiceImpl implements OssService 
    @Override
    public String uploadFileAvatar(MultipartFile file) 

        String endpoint = ConstantPropertiesUtils.END_POINT;
        String accessKeyId = ConstantPropertiesUtils.ACCESS_KEY_ID;
        String accessKeySecret = ConstantPropertiesUtils.ACCESS_KEY_SECRET;
        String bucketName = ConstantPropertiesUtils.BUCKET_NAME;
        String url = null;

        try 
            //创建OSSClient实例。
            OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);

            //获取上传文件输入流
            InputStream inputStream = file.getInputStream();
            //获取文件名称
            String fileName = file.getOriginalFilename();

            //保证文件名唯一，去掉uuid中的'-'
            String uuid = UUID.randomUUID().toString().replaceAll("-", "");
            fileName = uuid + fileName;

            //把文件按日期分类，构建日期路径：avatar/2019/02/26/文件名
            String datePath = new DateTime().toString("yyyy/MM/dd");

            //拼接
            fileName=datePath+"/"+fileName;

            //调用oss方法上传到阿里云
            //第一个参数：Bucket名称
            //第二个参数：上传到oss文件路径和文件名称
            //第三个参数：上传文件输入流
            ossClient.putObject(bucketName, fileName, inputStream);

            //把上传后把文件url返回
            //https://xppll.oss-cn-beijing.aliyuncs.com/01.jpg
            url = "https://" + bucketName + "." + endpoint + "/" + fileName;
            //关闭OSSClient
            ossClient.shutdown();
         catch (IOException e) 
            e.printStackTrace();
        

        return url;
    

2.5 使用swagger测试

上传成功，并实现了日期分类：

最后喜欢的小伙伴，记得三连哦！😏🍭😘