pom.xml引入s3的依赖

<!--AWS S3上传依赖-->
<dependency><groupId>com.amazonaws</groupId><artifactId>aws-java-sdk-s3</artifactId><version>1.11.172</version>
</dependency>

请求

import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;import java.util.Date;@Data
@ApiModel("文件请求DTO")
public class FileReqDTO {private static final long serialVersionUID = 6168402123733836858L;@ApiModelProperty(value = "文件类型",example = "jar")private String fileType;@ApiModelProperty(value = "s3位置",example = "https://s3.daoerz.com/DaoerZPlatform/jar/20190707/test.jar")private String s3Location;@ApiModelProperty(value = "描述",example = "测试jar包")private String description;@ApiModelProperty("创建时间")private Date createdTime;}

响应

import lombok.Data;/*** 文件响应信息*/
@Data
public class FileResDTO {private static final long serialVersionUID = -407615853780074057L;/** 文件名 */private String fileName;/** 文件路径 */private String s3Location;}

Manager

import com.amazonaws.ClientConfiguration;
import com.amazonaws.Protocol;
import com.amazonaws.auth.AWSCredentials;
import com.amazonaws.auth.BasicAWSCredentials;
import com.amazonaws.services.s3.AmazonS3;
import com.amazonaws.services.s3.AmazonS3Client;
import com.amazonaws.services.s3.model.Bucket;
import com.amazonaws.services.s3.model.CannedAccessControlList;
import com.amazonaws.services.s3.model.ObjectMetadata;import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.stereotype.Component;
import org.springframework.web.multipart.MultipartFile;import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.List;@Slf4j
@Component
public class FileManager {/** 要确认s3上已经存在该存储桶,且桶名必须大写开头 */private String DAOERZ_FILE_BUCKET = "DaoerZPlatform";/** AWS 访问密钥 */private String ACCESS_KEY = "G5O3C6I2N9N2PBSW2ADQ";/** AWS SECRET_KEY */private String SECRET_KEY = "O2ymTeW3Mn3uHuiozm2fnmsAFIO8Ks6dOoP1TYuw";/** AWS 云平台地址*/private String URL = "https://s3.daoerz.com";/*** 文件上传至s3文件云平台** @param file 文件* @return FileResDTO 文件响应信息*/public FileResDTO uploadImageFile(MultipartFile file){try {// 获取原始文件名称String fileName = file.getOriginalFilename();// 获取文件格式后缀String suffix = "other";if (fileName.contains(".")) {suffix = fileName.substring(fileName.lastIndexOf(".") + 1).toLowerCase();}// 文件目录，由 bucket + 文件后缀 + 文件后缀名同名文件夹 + 当前年月日 + 时分秒毫秒组成LocalDateTime localDateTime = LocalDateTime.now();String fileDirName = DAOERZ_FILE_BUCKET + "/" + suffix + "/" + localDateTime.format(DateTimeFormatter.ofPattern("yyyyMMdd"))+ "/" + localDateTime.format(DateTimeFormatter.ofPattern("HHmmssSSS"));// AWS连接云平台AWSCredentials awsCredentials = new BasicAWSCredentials(ACCESS_KEY, SECRET_KEY);ClientConfiguration clientConfig = new ClientConfiguration();clientConfig.setProtocol(Protocol.HTTP);AmazonS3 conn = new AmazonS3Client(awsCredentials, clientConfig);conn.setEndpoint(URL);// 打印所有 bucketList<Bucket> buckets = conn.listBuckets();log.info("s3文件云平台存储桶列表,{}", buckets);// 存入文件conn.putObject(fileDirName, fileName, file.getInputStream(), new ObjectMetadata());// 修改对象的 ACL 访问权限为公有conn.setObjectAcl(fileDirName, fileName, CannedAccessControlList.PublicReadWrite);//获取上传文件的下载地址String url = conn.getUrl(fileDirName, fileName).toString();//判断返回的文件下载地址是否为空if (StringUtils.isBlank(url)){log.error("文件下载地址为空,{}", url);throw new ServiceException(ErrorMsgEnum.FIlE_UPLOAD_FAILED);}FileResDTO fileResDTO = new FileResDTO();fileResDTO.setS3Location(url);fileResDTO.setFileName(fileName);return fileResDTO;}catch (Exception e){log.error("s3上传文件异常:{}", e);throw new ServiceException(ErrorMsgEnum.FIlE_UPLOAD_FAILED);}}/*** 删除s3上的文件** @param s3Location 文件在s3上的全路径* @return 删除结果*/public Boolean deleteFile(String s3Location) {// AWS连接云平台try {String keyName = s3Location.substring(s3Location.indexOf(DAOERZ_FILE_BUCKET) + DAOERZ_FILE_BUCKET.length() + 1);AWSCredentials awsCredentials = new BasicAWSCredentials(ACCESS_KEY, SECRET_KEY);ClientConfiguration clientConfig = new ClientConfiguration();clientConfig.setProtocol(Protocol.HTTP);AmazonS3 conn = new AmazonS3Client(awsCredentials, clientConfig);conn.setEndpoint(URL);conn.deleteObject(DAOERZ_FILE_BUCKET,keyName);return true;} catch (Exception e) {log.error("s3删除文件失败：{}", e);throw new ServiceException(ErrorMsgEnum.FIlE_DELETE_FAILED);}}}

Service

import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;/*** s3 处理类** @author daoerZ*/
@Slf4j
@Service
public class S3Service {@Autowiredprivate FileManager fileManager;/*** 上传文件*/public FileResDTO uploadFile(FileReqDTO reqDTO, MultipartFile file) {String fileName = file.getOriginalFilename();if (fileName == null) {log.error("传入的文件名不能为空");throw new ServiceException(ErrorMsgEnum.BLANK_FILE_NAME);}if (!this.validateFileName(fileName)) {log.error("文件名应仅包含汉字、字母、数字、下划线和点号");throw new ServiceException(ErrorMsgEnum.FILE_NAME_REGEX_ERROR);}//上传 s3 服务器FileResDTO fileResDTO = this.fileManager.uploadImageFile(file);// 对请求参数进行加工处理，如 将文件信息落库等 ...
//        reqDTO.setS3Location(fileResDTO.getS3Location());return fileResDTO;}/*** 删除文件* - 物理删除s3上的文件* @param reqDTO 包含 s3 文件路径的请求*/public void deleteFile(FileReqDTO reqDTO) {// s3上的文件路径String s3Location = reqDTO.getS3Location();this.fileManager.deleteFile(s3Location);}/*** 验证文件名称：仅包含 汉字、字母、数字、下划线和点号** @param fileName 文件名称* @return 返回true表示符合要求*/public boolean validateFileName(String fileName) {String regex = "^[a-zA-Z0-9_\\u4e00-\\u9fa5_\\.]+$";return fileName.matches(regex);}}

controller

import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;@RestController
@RequestMapping("/file")
@Api(description = "文件管理")
public class FileController {@Autowiredprivate S3Service s3Service;/*** 上传文件**/@ApiOperation(value = "uploadFile", notes = "上传文件", response = Result.class)@RequestMapping(value = "/uploadFile", method = RequestMethod.POST,consumes = MediaType.MULTIPART_FORM_DATA_VALUE)public void uploadFile(@Validated FileReqDTO reqDTO, @RequestParam("file") MultipartFile file) {s3Service.uploadFile(reqDTO,file);}/*** 删除文件*/@ApiOperation(value = "删除文件", response = Result.class)@RequestMapping(value = "/deleteFile", method = RequestMethod.POST, consumes = MediaType.APPLICATION_JSON_VALUE)public void deleteFile(@RequestBody FileReqDTO reqDTO) {s3Service.deleteFile(reqDTO);}}