SpringBoot整合阿里云OSS对象存储服务实现文件上传

< dependency >

     < groupId >com.aliyun.oss</ groupId >

     < artifactId >aliyun-sdk-oss</ artifactId >

     < version >3.10.2</ version >

</ dependency >

# 定义的端口号

server:

   port: 8080

aliyun:

   oss:

     #yourEndpoint填写Bucket所在地域对应的Endpoint，可在创建好的Bucket概况页查看。

     endpoint: oss-cn-chengdu.aliyuncs测试数据       # 以成都为例，Endpoint填写为https://oss-cn-chengdu.aliyuncs测试数据

     #阿里云账号AccessKey拥有所有API的访问权限，风险很高。强烈建议您创建并使用RAM用户进行API访问或日常运维，请登录RAM控制台创建RAM用户

     accessKeyId: **********             # 阿里云账号AccessKey里所对应的AccessKey ID

     accessKeySecret: **********             # 阿里云账号AccessKey里所对应的AccessKey Secret

     bucketName: **********              # OSS 对象存储空间名

import org.springframework.stereotype.Service;

import org.springframework.web.multipart.MultipartFile;

import java.util.Map;

@Service

public interface AliyunOssService {

     Map<String, Object> upload(MultipartFile file, String fileName);

}

import com.system.demo.service.AliyunOssService;

import com.system.demo.util.FileUploadUtil;

import org.springframework.stereotype.Service;

import org.springframework.web.multipart.MultipartFile;

import javax.annotation.Resource;

import java.util.HashMap;

import java.util.Map;

@Service ( "aliyunOssService" )

public class AliyunOssServiceImpl implements AliyunOssService {

     @Resource

     private FileUploadUtil fileUploadUtil;

     @Override

     public Map<String, Object> upload(MultipartFile file, String fileName){

         //定义一个目录（这里的目录可根据自己实际情况自己拼接定义）

         String path = "a" ;   //我这里就随便定义一个a文件夹

         //拼接，这里将路径和文件名拼接在了一起

         fileName = path + "/" +fileName;

         Map<String, Object> map = new HashMap<>();

         map.put( "code" , 200 );

         map.put( "msg" , "查询成功" );

         map.put( "data" , this .fileUploadUtil.upload(file, fileName));

         return map;

     }

}

import com.aliyun.oss.OSS;

import com.aliyun.oss.OSSClientBuilder;

import com.aliyun.oss.model.ObjectMetadata;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.stereotype.Component;

import org.springframework.web.multipart.MultipartFile;

import java.io.IOException;

import java.io.InputStream;

@Component

public class FileUploadUtil {

     @Value ( "${aliyun.oss.endpoint}" )

     private String endpoint;

     @Value ( "${aliyun.oss.accessKeyId}" )

     private String accessKeyId;

     @Value ( "${aliyun.oss.accessKeySecret}" )

     private String accessKeySecret;

     @Value ( "${aliyun.oss.bucketName}" )

     private String bucketName;

     public String upload(MultipartFile file, String fileName){

             // 写入文件

             try {

                 //获取上传的输入流

                 InputStream inputStream = file.getInputStream();

                 //设置访问地址是默认是预览图片

                 ObjectMetadata meta = new ObjectMetadata();

                 meta.setContentType( "image/jpg" );

                 // 创建OSSClient实例

                 OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);

                 /*

                 调用oss上传到阿里云对象存储oss----Bucket存储空间

                 第一个参数 bucket名称

                 第二个参数 文件名称

                 第三个参数 输入流

                 第四个参数 文件类型

                  */

                 ossClient.putObject(bucketName, fileName, inputStream, meta);

                 // 删除文件。如需删除文件夹，请将ObjectName设置为对应的文件夹名称。如果文件夹非空，则需要将文件夹下的所有object删除后才能删除该文件夹。

                 //ossClient.deleteObject(bucketName, "a/");

                 // 关闭OSSClient。

                 ossClient.shutdown();

                 //上传成功后获取文件路径

                 String url = "https://" + bucketName + "." + endpoint + "/" + fileName;

                 return url;

             } catch (IOException e) {

                 e.printStackTrace();

             }

         return null ;

     }

}

import com.system.demo.service.impl.AliyunOssServiceImpl;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestMethod;

import org.springframework.web.bind.annotation.RestController;

import org.springframework.web.multipart.MultipartFile;

import javax.annotation.Resource;

import java.util.Map;

@RestController

@RequestMapping ( "oss" )

public class FileUpload {

     @Resource

     private AliyunOssServiceImpl aliyunOssServiceImpl;

     @RequestMapping (value = "fileoss" , method = RequestMethod.POST)

     public Map<String, Object> uploadOssFile(MultipartFile file, String fileName){

         return this .aliyunOssServiceImpl.upload(file, fileName);

     }

}