图片上传的实现思路

布响丸辣大约 3 分钟

前期工作

登录阿里云控制台，进入OSS服务管理界面。

创建Bucket 并获取关键信息(方框要记住数据,圆框记得设置)

创建AccessKey,记录创建成功的AccessKeyId 和 AccessSecret(这个肥肠重要)

代码实现

导入相关依赖:

<!--导入阿里云图片上传依赖-->
<dependency>
    <groupId>com.aliyun.oss</groupId>
    <artifactId>aliyun-sdk-oss</artifactId>
    <version>3.1.0</version>
</dependency>

<!-- 日期工具栏依赖 -->
<dependency>
    <groupId>joda-time</groupId>
    <artifactId>joda-time</artifactId>
    <version>2.10.1</version>
</dependency>


2. 配置文件

   ```yaml
   # 阿里云存储
   aliyun:
     oss:
       file:
         endpoint: oss-cn-beijing.aliyuncs.com
         keyid: LTAI5tR27dsxwUiECbMijVMD
         keysecret: A9Z9ZHmsN2eMJhBe0EavVwyOe2CbWZ
         bucketname: bookmanager-lm

通过工具类从配置文件中获取配置

import org.springframework.beans.factory.InitializingBean;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Configuration;

@Configuration
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_POIND;
    public static String ACCESS_KEY_ID;
    public static String ACCESS_KEY_SECRET;
    public static String BUCKET_NAME;

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

创建文件上传接口

import org.springframework.web.multipart.MultipartFile;

public interface OssService {
    //上传头像到oss
    String uploadFileAvatar(MultipartFile file);
}

实现上传功能

import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClientBuilder;
import com.example.bookmanager.service.OssService;
import com.example.bookmanager.utils.ConstantPropertiesUtils;
import lombok.extern.slf4j.Slf4j;
import org.joda.time.DateTime;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;

import java.io.InputStream;
import java.util.UUID;

@Service
@Slf4j
public class OssServiceImpl implements OssService {
    //上传头像到oss
    @Override
    public String uploadFileAvatar(MultipartFile file) {
        // 工具类获取值
        String endpoint = ConstantPropertiesUtils.END_POIND;
        String accessKeyId = ConstantPropertiesUtils.ACCESS_KEY_ID;
        String accessKeySecret = ConstantPropertiesUtils.ACCESS_KEY_SECRET;
        String bucketName = ConstantPropertiesUtils.BUCKET_NAME;

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

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

            //1 在文件名称里面添加随机唯一的值
            String uuid = UUID.randomUUID().toString().replaceAll("-","");
            // yuy76t5rew0000.jpg
            fileName = uuid+fileName;

            //2 把文件按照日期进行分类
            //获取当前日期
            String datePath = new DateTime().toString("yyyy/MM/dd");
            //拼接
            fileName = datePath+"/"+fileName;
            //调用oss方法实现上传
            //第一个参数  Bucket名称
            //第二个参数  上传到oss文件路径和文件名称   aa/bb/1.jpg
            //第三个参数  上传文件输入流
            ossClient.putObject(bucketName,fileName , inputStream);
            // 关闭OSSClient。
            ossClient.shutdown();

            //把上传之后文件路径返回
            //需要把上传到阿里云oss路径手动拼接出来
            String url = "https://"+bucketName+"."+endpoint+"/"+fileName;
            log.info(url);
            return url;
        }catch(Exception e) {
            e.printStackTrace();
            return null;
        }
    }

}

调用

    /**
     * 上传头像
     * @param file
     * @return
     */
    @PostMapping("/sendUserImg/{id}")
    @Operation(summary = "上传头像")
    public R<String> uploadOssFile(@RequestParam("file") MultipartFile file, @PathVariable int id) {
        //获取上传文件  MultipartFile
        //返回上传到oss的路径
        User u = userService.getUserById(id);
        if (u != null) {
            String url = ossService.uploadFileAvatar(file);
            userService.updateImg(u, url);
            return R.success(url);
        } else {
            return R.error("上传失败");
        }
    }

测试

打开Postman,选择正确请求类型,输入正确接口路径,点击body -> from-data -> KEY输入框选择file,且输入”file”字段,VALUE输入框选择上传的图片,点击发送

点开链接:

参考

全网最详细SpringBoot、SpringCloud整合阿里云OSS对象存储服务_spring cloud oss-CSDN博客