一.OSS服务器开通并创建账户

参考阿里云OSS的使用(全程请登陆)_zhz小白的博客-CSDN博客https://blog.csdn.net/zhouhengzhe/article/details/112077301

二.Springboot整合OSS

1.创建springboot项目

1.1勾选web依赖

注意：如果jdk版本为1.8，则springboot版本应该为3.0以下

1.2 引入相关依赖


		<dependency>
			<groupId>com.aliyun.oss</groupId>
			<artifactId>aliyun-sdk-oss</artifactId>
			<version>3.10.2</version>
		</dependency>

		<dependency>
			<groupId>org.projectlombok</groupId>
			<artifactId>lombok</artifactId>
			<version>1.18.20</version>
			<scope>compile</scope>
		</dependency>

2.整合OSS

2.1启动文件配置

server:
  port: 8080
spring:
  application:
    name: oss-server
aliyun: 
  oss:
    end-point: oss-cn-chengdu.aliyuncs.com
    access-key-id: LTAI5tCNDUQeX9PtAv9nZmMf
    access-key-secret: KGVGWz2H9yyrogOilJ4K1dgr8EX7Xh
    bucket-name: oss-test-cheng

2.2 OSS配置类OSSConfig

@Configuration
@Data
@ConfigurationProperties(prefix = "aliyun.oss")
public class OSSConfig {
    private String endPoint;
    private String accessKeyId;
    private String accessKeySecret;
    private String bucketName;
}

2.3 服务层代码

public interface FileService {
    String upload(MultipartFile file) throws IOException;

    void download() throws IOException;
}

@Service
@Slf4j
public class FileServiceImpl implements FileService {
    @Autowired
    private OSSConfig ossConfig;
    @Override
    public String upload(MultipartFile file) throws IOException {
        String endPoint = ossConfig.getEndPoint();
        String accessKeyId = ossConfig.getAccessKeyId();
        String accessKeySecret = ossConfig.getAccessKeySecret();
        String bucketName = ossConfig.getBucketName();

        //创建oss对象
        OSS oss = new OSSClientBuilder().build(endPoint, accessKeyId, accessKeySecret);

        String originalFilename = file.getOriginalFilename();

        //设置日期格式
        LocalDateTime now = LocalDateTime.now();
        DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern("yyyy/MM/dd");
        String date = dateTimeFormatter.format(now);

        //拼装oss文件的存储路径
        String fileName= UUID.randomUUID().toString().replaceAll("-", "").substring(0, 32);
        String extension=originalFilename.substring(originalFilename.lastIndexOf("."));
        //在oss上bucket下的文件路径
        String uploadFileName = "user/" + date + "/" + fileName + extension;

        PutObjectResult putObjectResult = oss.putObject(bucketName, uploadFileName,  file.getInputStream());
        if (putObjectResult!=null){
            log.info("文件上传成功");
            return "https://"+bucketName+"."+endPoint+"/"+uploadFileName;
        }else {
            log.info("文件上传失败");
        }
        oss.shutdown();
        return null;
    }

    @Override
    public void download() throws IOException {
        String endPoint = ossConfig.getEndPoint();
        String accessKeyId = ossConfig.getAccessKeyId();
        String accessKeySecret = ossConfig.getAccessKeySecret();
        String bucketName = ossConfig.getBucketName();

        OSS oss = new OSSClientBuilder().build(endPoint, accessKeyId, accessKeySecret);

        //获取OSS端的文件
        OSSObject result = oss.getObject(bucketName, "235920pM89Q.jpg");

        //创建输入流
        BufferedInputStream inputStream = new BufferedInputStream(result.getObjectContent(), 512);
        String[] split = result.getKey().split("/");
        String fileName = split[split.length - 1];

        //创建输出流
        FileOutputStream outputStream= new FileOutputStream("C:\\Users\\13404\\Pictures\\Camera Roll\\write.jpg");

        //处理oss文件流传输
        int number;/**/
        byte[] buffer = new byte[512];
        while ((number = inputStream.read(buffer)) != -1) {
            outputStream.write(buffer, 0, number);
        }
        outputStream.flush();
        outputStream.close();
        inputStream.close();
        log.info("下载完毕");
    }
}

2.4 控制层代码

@RestController
@Slf4j
@RequestMapping("/file")
public class FileController {

    @Autowired
    private FileService fileService;
    @PostMapping("/upload")
    public Map<String,Object> upload(@RequestParam("file") MultipartFile file) throws IOException {
        String upload = fileService.upload(file);
        Map<String, Object> result = new HashMap<>();
        if(upload== null || "".equals(upload)){
            result.put("code",10000);
            result.put("msg","图片上传失败");
            result.put("data",null);
        }else{
            result.put("code",200);
            result.put("msg","图片上传成功");
            result.put("data",upload);
        }
        return result;
    }
    @GetMapping("/download")
    public void download() throws IOException {
        fileService.download();
    }

}