package com.app.framework.config;
import com.amazonaws.ClientConfiguration;
import com.amazonaws.Protocol;
import com.amazonaws.auth.AWSCredentials;
import com.amazonaws.auth.AWSStaticCredentialsProvider;
import com.amazonaws.auth.BasicAWSCredentials;
import com.amazonaws.client.builder.AwsClientBuilder;
import com.amazonaws.services.s3.AmazonS3;
import com.amazonaws.services.s3.AmazonS3ClientBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class AmazonS3Config {
    @Bean
    public AmazonS3 amazonS3Client() {
        //用戶名
        String accessKey = "";
        //密碼
        String secretKey = "";
        AWSCredentials credentials = new BasicAWSCredentials(accessKey, secretKey);
        AWSStaticCredentialsProvider awsStaticCredentialsProvider = new AWSStaticCredentialsProvider(credentials);
        ClientConfiguration config = new ClientConfiguration();
        String region = "wx-pbc";
        AwsClientBuilder.EndpointConfiguration endpointConfiguration = new AwsClientBuilder.EndpointConfiguration("cos.wx-pbc.cos.tg.unicom.local", region);
        return AmazonS3ClientBuilder.standard()
        .withCredentials(awsStaticCredentialsProvider)
        .withClientConfiguration(config.withProtocol(Protocol.HTTP).withSignerOverride("S3SignerType"))
        .withEndpointConfiguration(endpointConfiguration).build();
    }
}

package com.app.project.welfare.controller;
import cn.hutool.core.lang.UUID;
import com.aliyun.oss.*;
import com.aliyun.oss.model.PutObjectResult;
import com.amazonaws.auth.AWSStaticCredentialsProvider;
import com.amazonaws.auth.BasicAWSCredentials;
import com.amazonaws.services.s3.AmazonS3;
import com.amazonaws.services.s3.AmazonS3ClientBuilder;
import com.amazonaws.services.s3.model.ObjectMetadata;
import com.amazonaws.services.s3.model.PutObjectRequest;
import com.app.framework.web.domain.AjaxResult;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;
import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;
@RequestMapping("/oss")
@RestController
@Slf4j
public class OssController {
    /**
     * 把文件上傳到自己的服務(wù)器，然后在上傳到 Amazon s3存儲器
     */
    @PostMapping("/upload-img-s3")
    public AjaxResult uploadImgAmazonS3(@RequestParam("file") MultipartFile file) throws IOException {
        log.info("文件上傳：{}", file);
        //生成一個隨機的UUID（通用唯一標識符）
        UUID uuid = UUID.fastUUID();
        //獲取上傳文件的原始文件名，并將其存儲在變量fileName中
        String fileName = file.getOriginalFilename();
        //使用斷言確保fileName不為空，如果為空則拋出異常
        assert fileName != null;
        //將文件名按照點號（"."）分割成一個字符串數(shù)組
        String[] fileNameSplit = fileName.split("\\.");
        //將UUID和原始文件名中的擴展名重新拼接起來，形成新的文件名
        fileName = uuid + "." + fileNameSplit[1];
        //創(chuàng)建一個新的ObjectMetadata對象
        ObjectMetadata objectMetadata = new ObjectMetadata();
        //獲取上傳文件的輸入流，并使用available()方法來獲取該流中可用的字節(jié)數(shù)
        objectMetadata.setContentLength(file.getInputStream().available());
        //獲取上傳文件的內(nèi)容類型（MIME類型）
        String contentType = file.getContentType();
        //將獲取到的文件內(nèi)容類型設(shè)置為新文件的元數(shù)據(jù)內(nèi)容類型
        objectMetadata.setContentType(contentType);
        // 設(shè)置公共讀
        objectMetadata.setHeader("x-amz-acl", "public-read");
        //拼接
        String finalFileName = "name/" + fileName;
        //將文件上傳到名為"name"的S3存儲桶中
        amazonS3.putObject("name", finalFileName, file.getInputStream(), objectMetadata);
        String imgUrl = "https://xxx" + finalFileName;
        return AjaxResult.success(imgUrl);
    }
}