❤️SpringBoot使用阿里云oss实现文件上传

 1 package com.stu.service.oss.utils;
 2 
 3 import lombok.Data;
 4 import org.springframework.boot.context.properties.ConfigurationProperties;
 5 import org.springframework.stereotype.Component;
 6 
 7 /******************************
 8  * 用途说明:从配置文件读取变量
 9  * 作者姓名: Administrator
10  * 创建时间: 2022-05-03 1:12
11  ******************************/
12 @Data
13 @Component
14 @ConfigurationProperties(prefix = "aliyun.oss")
15 public class OssProperties {
16 
17     private String endpoint;
18     private String keyId;
19     private String keySecret;
20     private String bucketname;
21 }

 1 package com.stu.oss.utils;
 2 
 3 import org.springframework.beans.factory.InitializingBean;
 4 import org.springframework.beans.factory.annotation.Value;
 5 import org.springframework.stereotype.Component;
 6 
 7 //项目启动，spring接口，spring加载之后，执行接口一个方法
 8 @Component
 9 public class ConstantPropertiesUtil implements InitializingBean {
10 
11     //读取配置文件的内容
12 
13     @Value("${aliyun.oss.file.endpoint}")
14     private String endpoint;
15     @Value("${aliyun.oss.file.keyid}")
16     private String keyid;
17     @Value("${aliyun.oss.file.keysecret}")
18     private String keysecret;
19     @Value("${aliyun.oss.file.bucketname}")
20     private String bucketname;
21 
22     //定义一些静态常量
23     public  static String END_POINT;
24     public  static String KEY_ID;
25     public  static String KEY_SECRET;
26     public  static String BUCKET_NAME;
27 
28     //上边赋值完成后，会执行afterPropertiesSet方法，这是spring机制
29     @Override
30     public void afterPropertiesSet() throws Exception {
31         END_POINT = endpoint;
32         KEY_ID = keyid;
33         KEY_SECRET = keysecret;
34         BUCKET_NAME = bucketname;
35 
36 
37     }
38 }

 1 package com.stu.service.oss.controller;
 2 
 3 import com.stu.service.base.result.R;
 4 import com.stu.service.oss.service.FileService;
 5 import lombok.extern.slf4j.Slf4j;
 6 import org.springframework.beans.factory.annotation.Autowired;
 7 import org.springframework.web.bind.annotation.PostMapping;
 8 import org.springframework.web.bind.annotation.RequestMapping;
 9 import org.springframework.web.bind.annotation.RestController;
10 import org.springframework.web.multipart.MultipartFile;
11 
12 /******************************
13  * 用途说明:
14  * 作者姓名: Administrator
15  * 创建时间: 2022-05-03 2:22
16  ******************************/
17 @RestController
18 @RequestMapping("admin/oss/file")
19 @Slf4j
20 public class FIleController {
21 
22     @Autowired
23     private FileService fileService;
24 
25     @PostMapping("upload")
26     public R upload(MultipartFile file) {
27            String url = fileService.upload(file);
28             return R.ok().data("url", url);
29     }
30 
31 }

 1 package com.stu.service.oss.service;
 2 
 3 import org.springframework.web.multipart.MultipartFile;
 4 
 5 public interface FileService {
 6 
 7     /***********************************
 8      * 用途说明:文件上传
 9      * 返回值说明: java.lang.String
10      ***********************************/
11     String upload(MultipartFile file);
12 }

  1 package com.stu.service.oss.service.impl;
  2 
  3 import com.aliyun.oss.ClientException;
  4 import com.aliyun.oss.OSS;
  5 import com.aliyun.oss.OSSClientBuilder;
  6 import com.aliyun.oss.OSSException;
  7 import com.stu.service.oss.service.FileService;
  8 import com.stu.service.oss.utils.OssProperties;
  9 import org.joda.time.DateTime;
 10 import org.springframework.beans.factory.annotation.Autowired;
 11 import org.springframework.stereotype.Service;
 12 import org.springframework.web.multipart.MultipartFile;
 13 
 14 import java.io.IOException;
 15 import java.io.InputStream;
 16 import java.util.UUID;
 17 
 18 /******************************
 19  * 用途说明:文件上传
 20  * 作者姓名: Administrator
 21  * 创建时间: 2022-05-03 1:26
 22  ******************************/
 23 @Service
 24 public class FileServiceImpl implements FileService {
 25 
 26     @Autowired
 27     private OssProperties ossProperties;
 28 
 29     @Override
 30     public String upload(MultipartFile file) {
 31         // Endpoint以华东1（杭州）为例，其它Region请按实际情况填写。
 32         String endPoint = ossProperties.getEndpoint();
 33         // 阿里云账号AccessKey拥有所有API的访问权限，风险很高。强烈建议您创建并使用RAM用户进行API访问或日常运维，请登录RAM控制台创建RAM用户。
 34         String accessKeyId = ossProperties.getKeyId();
 35         String accessKeySecret = ossProperties.getKeySecret();
 36         // 填写Bucket名称，例如examplebucket。
 37         String bucketName = ossProperties.getBucketname();
 38         /*// 填写Object完整路径，完整路径中不能包含Bucket名称，例如exampledir/exampleobject.txt。
 39         //获取当前日期 joda-time
 40         String datePath = new DateTime().toString("yyyy/MM/dd");
 41         //1.文件名称添加一个唯一值
 42         String uuid = UUID.randomUUID().toString().replace("-", "");
 43         orginalFileName = uuid + orginalFileName;
 44         String fileExtention = orginalFileName.substring(orginalFileName.lastIndexOf("."));
 45         String objectName = module + "/" + datePath + orginalFileName + fileExtention;*/
 46 
 47         // 创建OSSClient实例。
 48         OSS ossClient = new OSSClientBuilder().build(endPoint, accessKeyId, accessKeySecret);
 49         String url = null;
 50         // 填写本地文件的完整路径。如果未指定本地路径，则默认从示例程序所属项目对应本地路径中上传文件流。
 51         InputStream inputStream = null;
 52         try {
 53             //获取上传文件输入流
 54             inputStream = file.getInputStream();
 55             //调用oss方法实现上传
 56             //第一个参数 Bucket名称
 57             //第二个参数，上传到oss文件路径和文件名称   A/B/图片.jpg
 58             //第三个参数，上传文件输入流
 59             //获取文件名称
 60             // test.png
 61             String fileName = file.getOriginalFilename();
 62             //1.文件名称添加一个唯一值
 63             //80b8fbf76d5140f9b33917f883533cc3
 64             String uuid = UUID.randomUUID().toString().replace("-", "");
 65             fileName = uuid + fileName;
 66             //2.把文件安装日期进行分类
 67             //2021/05/20/图片.jpg
 68             //获取当前日期 joda-time
 69             String datePath = new DateTime().toString("yyyy/MM/dd");
 70 
 71             //fileName 2022/05/03/80b8fbf76d5140f9b33917f883533cc3test.png
 72             fileName = datePath + "/" + fileName;
 73             ossClient.putObject(bucketName, fileName, inputStream);
 74             // 关闭OSSClient。
 75             ossClient.shutdown();
 76             //上传之后把文件路径返回
 77             //https://edu8806.oss-cn-beijing.aliyuncs.com/2022/05/03/80b8fbf76d5140f9b33917f883533cc3test.png
 78             url = "https://" + bucketName + "." + endPoint + "/" + fileName;
 79 
 80         } catch (OSSException oe) {
 81             System.out.println("Caught an OSSException, which means your request made it to OSS, "
 82                     + "but was rejected with an error response for some reason.");
 83             System.out.println("Error Message:" + oe.getErrorMessage());
 84             System.out.println("Error Code:" + oe.getErrorCode());
 85             System.out.println("Request ID:" + oe.getRequestId());
 86             System.out.println("Host ID:" + oe.getHostId());
 87         } catch (ClientException ce) {
 88             System.out.println("Caught an ClientException, which means the client encountered "
 89                     + "a serious internal problem while trying to communicate with OSS, "
 90                     + "such as not being able to access the network.");
 91             System.out.println("Error Message:" + ce.getMessage());
 92         } catch (IOException e) {
 93             e.printStackTrace();
 94         } finally {
 95             if (ossClient != null) {
 96                 ossClient.shutdown();
 97             }
 98         }
 99         return url;
100     }
101 
102 }

package com.stu.gulimall.product;

import com.stu.gulimall.product.entity.BrandEntity;
import com.stu.gulimall.product.service.BrandService;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringBootVersion;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.core.SpringVersion;
import com.aliyun.oss.ClientException;
import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClientBuilder;
import com.aliyun.oss.OSSException;
import com.aliyun.oss.model.PutObjectRequest;
import java.io.ByteArrayInputStream;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.InputStream;

@SpringBootTest
class GulimallProductApplicationTests {

    @Autowired
    BrandService brandService;

    @Test
    void contextLoads() {
        BrandEntity b = new BrandEntity();
    b.setName("test");
        brandService.save(b);
        System.out.println("=================================");
    }
    @Test
    public void getSpringVersion() throws FileNotFoundException {
// Endpoint以华东1（杭州）为例，其它Region请按实际情况填写。
        String endpoint = "oss-cn-beijing.aliyuncs.com";
        // 阿里云账号AccessKey拥有所有API的访问权限，风险很高。强烈建议您创建并使用RAM用户进行API访问或日常运维，请登录RAM控制台创建RAM用户。
        String accessKeyId = "xxxxxxxxxxxx";
        String accessKeySecret = "xxxxxxxxxxxxxxxxxxxx";
        // 填写Bucket名称，例如examplebucket。
        String bucketName = "edu8806";

        // 填写Object完整路径，完整路径中不能包含Bucket名称，例如exampledir/exampleobject.txt。
        String objectName = "test.png";
        // 填写本地文件的完整路径，例如D:\\localpath\\examplefile.txt。
        // 如果未指定本地路径，则默认从示例程序所属项目对应本地路径中上传文件流。
        String filePath= "E:\\test.png";

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

        try {
            InputStream inputStream = new FileInputStream(filePath);
            // 创建PutObject请求。
            ossClient.putObject(bucketName, objectName, inputStream);
        } catch (OSSException oe) {
            System.out.println("Caught an OSSException, which means your request made it to OSS, "
                    + "but was rejected with an error response for some reason.");
            System.out.println("Error Message:" + oe.getErrorMessage());
            System.out.println("Error Code:" + oe.getErrorCode());
            System.out.println("Request ID:" + oe.getRequestId());
            System.out.println("Host ID:" + oe.getHostId());
        } catch (ClientException ce) {
            System.out.println("Caught an ClientException, which means the client encountered "
                    + "a serious internal problem while trying to communicate with OSS, "
                    + "such as not being able to access the network.");
            System.out.println("Error Message:" + ce.getMessage());
        } finally {
            if (ossClient != null) {
                ossClient.shutdown();
                System.out.println("============success===============");
            }
        }
    }
}

package com.stu.gulimall.product;

import com.aliyun.oss.ClientException;
import com.aliyun.oss.OSSClient;
import com.aliyun.oss.OSSException;
import com.stu.gulimall.product.entity.BrandEntity;
import com.stu.gulimall.product.service.BrandService;
import org.junit.jupiter.api.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.InputStream;

@RunWith(SpringRunner.class)
@SpringBootTest
class GulimallProductApplicationTests {

    @Autowired
    BrandService brandService;
    @Autowired
    private OSSClient ossClient;
    @Test
    void contextLoads() {
        BrandEntity b = new BrandEntity();
        b.setName("test");
        brandService.save(b);
        System.out.println("=================================");
    }
    @Test
    public void getSpringVersion() throws FileNotFoundException {
// Endpoint以华东1（杭州）为例，其它Region请按实际情况填写。
       /* String endpoint = "oss-cn-beijing.aliyuncs.com";
        // 阿里云账号AccessKey拥有所有API的访问权限，风险很高。强烈建议您创建并使用RAM用户进行API访问或日常运维，请登录RAM控制台创建RAM用户。
        String accessKeyId = "xxxxxxxxxxxx";
        String accessKeySecret = "xxxxxxxxxxxxxxxxxxxx";
        // 填写Bucket名称，例如examplebucket。
        String bucketName = "edu8806";

        // 填写Object完整路径，完整路径中不能包含Bucket名称，例如exampledir/exampleobject.txt。
        String objectName = "test.png";
        // 填写本地文件的完整路径，例如D:\\localpath\\examplefile.txt。
        // 如果未指定本地路径，则默认从示例程序所属项目对应本地路径中上传文件流。
        String filePath= "E:\\test.png";

        // 创建OSSClient实例。
        OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);*/
        // 填写Bucket名称，例如examplebucket。
        String bucketName = "edu8806";

        // 填写Object完整路径，完整路径中不能包含Bucket名称，例如exampledir/exampleobject.txt。
        String objectName = "test.png";
        // 填写本地文件的完整路径，例如D:\\localpath\\examplefile.txt。
        // 如果未指定本地路径，则默认从示例程序所属项目对应本地路径中上传文件流。
        String filePath= "E:\\test.png";
        try {
            InputStream inputStream = new FileInputStream(filePath);
            // 创建PutObject请求。
            ossClient.putObject(bucketName, objectName, inputStream);
        } catch (OSSException oe) {
            System.out.println("Caught an OSSException, which means your request made it to OSS, "
                    + "but was rejected with an error response for some reason.");
            System.out.println("Error Message:" + oe.getErrorMessage());
            System.out.println("Error Code:" + oe.getErrorCode());
            System.out.println("Request ID:" + oe.getRequestId());
            System.out.println("Host ID:" + oe.getHostId());
        } catch (ClientException ce) {
            System.out.println("Caught an ClientException, which means the client encountered "
                    + "a serious internal problem while trying to communicate with OSS, "
                    + "such as not being able to access the network.");
            System.out.println("Error Message:" + ce.getMessage());
        } finally {
            if (ossClient != null) {
                ossClient.shutdown();
                System.out.println("============success===============");
            }
        }
    }
}