Spring Boot---(18)SpringBoot整合阿里云OSS存储服务1

最新推荐文章于 2025-04-06 10:00:00 发布

IT云清

最新推荐文章于 2025-04-06 10:00:00 发布

阅读量1.7w

点赞数 5

分类专栏： (25)...Spring Boot SpringBoot--从零开始学SpringBoot 文章标签： SpringBoot 阿里云OSS

本文链接：https://blog.csdn.net/weixin_39800144/article/details/79287548

版权

(25)...Spring Boot 同时被 2 个专栏收录

36 篇文章

订阅专栏

SpringBoot--从零开始学SpringBoot

25 篇文章

订阅专栏

摘要：OSS可用于图片、音视频、日志等海量文件的存储。各种终端设备、Web网站程序、移动应用可以直接向OSS写入或读取数据，非常方便。本篇文章介绍如何在java的SpringBoot项目中，整个使用OSS服务，spring 项目也可以参考。

主要步骤如下：

前提是开通了阿里云OSS服务，然后；

1.引入依赖

2.获取关键参数，如endpoint,accessKeyId等，这个进入阿里云OSS控制台即可获取

3.建一个文件上传工具类

4.调用工具类，上传文件

1.pom.xml

		<!--aliyunOSS-->
		<dependency>
			<groupId>com.aliyun.oss</groupId>
			<artifactId>aliyun-sdk-oss</artifactId>
			<version>2.4.0</version>
		</dependency>
		<dependency>
			<groupId>commons-fileupload</groupId>
			<artifactId>commons-fileupload</artifactId>
			<version>1.3.1</version>
		</dependency>

2.配置文件

注意：为了以后的拓展性，代码和配置解耦，我这里会专门建一个配置文件，然后在使用时直接从配置类中获取，而不是写死在java代码中。所以2,3两步不是必须的，作用只是规范的使用相关配置参数，若觉得麻烦，学习时，可直接在java代码中写死。

application.properties 这里是我定义的一些必要常量

#OSS
java4all.file.endpoint=oss-cn-shanghai.aliyuncs.com 不同的服务器，地址不同
java4all.file.keyid=去OSS控制台获取
java4all.file.keysecret=去OSS控制台获取
java4all.file.bucketname1=java4all-file 这个自己创建bucket时的命名，控制台创建也行，代码创建也行
java4all.file.filehost=blog 文件路径，我这里是blog

3.ConstantProperties.java

这是我定义的常量类，读取配置文件application.properties中的配置，定义为常量，方便使用

package com.java4all.config;

import org.springframework.beans.factory.InitializingBean;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

/**
 * Created by lightClouds917
 * Date 2018/1/16
 * Description:配置文件配置项
 */
@Component
public class ConstantProperties implements InitializingBean{

    @Value("${java4all.file.endpoint}")
    private String java4all_file_endpoint;

    @Value("${java4all.file.keyid}")
    private String java4all_file_keyid;

    @Value("${java4all.file.keysecret}")
    private String java4all_file_keysecret;

    @Value("${java4all.file.filehost}")
    private String java4all_file_filehost;

    @Value("${java4all.file.bucketname1}")
    private String java4all_file_bucketname1;


    public static String JAVA4ALL_END_POINT         ;
    public static String JAVA4ALL_ACCESS_KEY_ID     ;
    public static String JAVA4ALL_ACCESS_KEY_SECRET ;
    public static String JAVA4ALL_BUCKET_NAME1      ;
    public static String JAVA4ALL_FILE_HOST         ;

    @Override
    public void afterPropertiesSet() throws Exception {
        JAVA4ALL_END_POINT = java4all_file_endpoint;
        JAVA4ALL_ACCESS_KEY_ID = java4all_file_keyid;
        JAVA4ALL_ACCESS_KEY_SECRET = java4all_file_keysecret;
        JAVA4ALL_FILE_HOST = java4all_file_filehost;
        JAVA4ALL_BUCKET_NAME1 = java4all_file_bucketname1;
    }
}

4.工具类 AliyunOSSUtil.java

package com.java4all.utils;

import com.aliyun.oss.ClientException;
import com.aliyun.oss.OSSClient;
import com.aliyun.oss.OSSException;
import com.aliyun.oss.model.CannedAccessControlList;
import com.aliyun.oss.model.CreateBucketRequest;
import com.aliyun.oss.model.PutObjectRequest;
import com.aliyun.oss.model.PutObjectResult;
import com.java4all.config.ConstantProperties;
import org.slf4j.LoggerFactory;

import java.io.File;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.UUID;

/**
 * Created by lightClouds917
 * Date 2018/2/7
 * Description:aliyunOSSUtil
 */
public class AliyunOSSUtil {

    private static final org.slf4j.Logger logger = LoggerFactory.getLogger(AliyunOSSUtil.class);


    public static String upload(File file){
        logger.info("=========>OSS文件上传开始："+file.getName());
        String endpoint=ConstantProperties.JAVA4ALL_END_POINT;
        String accessKeyId=ConstantProperties.JAVA4ALL_ACCESS_KEY_ID;
        String accessKeySecret=ConstantProperties.JAVA4ALL_ACCESS_KEY_SECRET;
        String bucketName=ConstantProperties.JAVA4ALL_BUCKET_NAME1;
        String fileHost=ConstantProperties.JAVA4ALL_FILE_HOST;

        SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");
        String dateStr = format.format(new Date());

        if(null == file){
            return null;
        }

        OSSClient ossClient = new OSSClient(endpoint,accessKeyId,accessKeySecret);
        try {
            //容器不存在，就创建
            if(! ossClient.doesBucketExist(bucketName)){
                ossClient.createBucket(bucketName);
                CreateBucketRequest createBucketRequest = new CreateBucketRequest(bucketName);
                createBucketRequest.setCannedACL(CannedAccessControlList.PublicRead);
                ossClient.createBucket(createBucketRequest);
            }
            //创建文件路径
            String fileUrl = fileHost+"/"+(dateStr + "/" + UUID.randomUUID().toString().replace("-","")+"-"+file.getName());
            //上传文件
            PutObjectResult result = ossClient.putObject(new PutObjectRequest(bucketName, fileUrl, file));
            //设置权限 这里是公开读
            ossClient.setBucketAcl(bucketName,CannedAccessControlList.PublicRead);
            if(null != result){
                logger.info("==========>OSS文件上传成功,OSS地址："+fileUrl);
                return fileUrl;
            }
        }catch (OSSException oe){
            logger.error(oe.getMessage());
        }catch (ClientException ce){
            logger.error(ce.getMessage());
        }finally {
            //关闭
            ossClient.shutdown();
        }
        return null;
    }
}

5.页面 upload.html

Springboot如何写页面，参考：Spring Boot---(16)Spring Boot使用Thymeleaf开发web页面

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8"/>
    <title>文件上传</title>
</head>
    <body>
        <form method="POST" enctype="multipart/form-data" action="/upload/uploadBlog">
            <p>文件：<input type="file" name="file"/></p>
            <p><input type="submit" value="上传" /></p>
        </form>
    </body>
</html>

6.使用 UploadController.java

package com.java4all.controller;

import com.java4all.utils.AliyunOSSUtil;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.multipart.MultipartFile;

import java.io.File;
import java.io.FileOutputStream;

/**
 * Created by lightClouds917
 * Date 2018/2/7
 * Description:文件上传
 */
@Controller
@RequestMapping("upload")
public class UploadController {
    private final org.slf4j.Logger logger = LoggerFactory.getLogger(getClass());
    /**
     * 文件上传
     * @param file
     */
    @RequestMapping(value = "uploadBlog",method = RequestMethod.POST)
    public String uploadBlog(MultipartFile file){

        logger.info("============>文件上传");
        try {

            if(null != file){
                String filename = file.getOriginalFilename();
                if(!"".equals(filename.trim())){
                    File newFile = new File(filename);
                    FileOutputStream os = new FileOutputStream(newFile);
                    os.write(file.getBytes());
                    os.close();
                    file.transferTo(newFile);
                    //上传到OSS
                    String uploadUrl = AliyunOSSUtil.upload(newFile);

                }

            }
        }catch (Exception ex){
            ex.printStackTrace();
        }
        return "index";
    }

    @RequestMapping(value = "toUploadBlog",method = RequestMethod.GET)
    public String toUploadBlog(){
        return "upload";
    }

}