oss文件上傳

官網API：https://help.aliyun.com/document_detail/32015.html?spm=5176.8466032.bucket-object.1.33ac1450TuX65y

1.獲取application.yml中的配置參數

# OSS相關配置信息
aliyun:
  oss:
    endpoint:  # oss對外服務的訪問域名
    accessKeyId:  # 訪問身份驗證中用到用戶標識
    accessKeySecret: # 用戶用於加密簽名字符串和oss用來驗證簽名字符串的密鑰
    bucketName:  # oss的存儲空間
    urlPrefix: 
    policy:
      expire: 300 # 簽名有效期(S)
    maxSize: 10 # 上傳文件大小(M)
    #callback: # 文件上傳成功后的回調地址

 

@Configuration @Data public class AliyunConfig { @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; @Value("${aliyun.oss.urlPrefixe}") private String urlPrefix; @Bean public OSS oSSClient() { return new OSSClient(endpoint, accessKeyId, accessKeySecret); } }

2.上傳文件返回結果集

@Data public class FileUploadResult { // 文件唯一標識
    private String uid; // 文件名
    private String name; // 狀態有：uploading done error removed
    private String status; // 服務端響應內容，如：'{"status": "success"}'
    private String response; }

 

3.錯誤信息

public enum FileStateEnum { GET_FILE_FAIL(-1, "獲取文件流失敗"), GET_FILE_SUCCESS(1, "成功獲取文件流ccc"), NULL_FILE(-1, "上傳文件為空"), MAX_SIZE_FILE(-1, "上傳圖片大小不能超過10M"), UPLOAD_FILE_FAIL(-1, "上傳文件失敗"), UPLOAD_FILE_SUCCESS(1, "上傳文件成功"), DELETE_FILE_FAIL(-1, "刪除文件失敗"); private int state; private String stateInfo; FileStateEnum(int state, String stateInfo) { this.state = state; this.stateInfo = stateInfo; } public int getState() { return state; } public void setState(int state) { this.state = state; } public String getStateInfo() { return stateInfo; } public void setStateInfo(String stateInfo) { this.stateInfo = stateInfo; } }

4.controller

/** * @author 團子 * @desc * @date 2019-07-31 11:31 */ @Controller @RequestMapping({"${adminPath}/cover"}) public class CoverFileUploadController { @Autowired private CoverFileUploadService coverFileUploadService; /** * @return FileUploadResult * @author 團子 * @desc 文件上傳到oss * @Param uploadFile */ @RequestMapping("file/upload") @ResponseBody public FileUploadResult upload(@RequestParam("file") MultipartFile uploadFile) throws Exception { return this.coverFileUploadService.upload(uploadFile); } /** * @return FileUploadResult * @desc 根據文件名刪除oss上的文件 * @author 團子 * @Param objectName */ @RequestMapping("file/delete") @ResponseBody public FileUploadResult delete(@RequestParam("fileName") String objectName) throws Exception { return this.coverFileUploadService.delete(objectName); } /** * @return List<OSSObjectSummary> * @author 團子 * @desc 查詢oss上的所有文件 * @Param */ @RequestMapping("file/list") @ResponseBody public List<OSSObjectSummary> list() throws Exception { return this.coverFileUploadService.list(); } /** * @return * @author 團子 * @desc 根據文件名下載oss上的文件 * @Param objectName */ @RequestMapping("file/download") @ResponseBody public void download(@RequestParam("fileName") String objectName, HttpServletResponse response) throws IOException { //通知瀏覽器以附件形式下載
        response.setHeader("Content-Disposition", "attachment;filename=" + new String(objectName.getBytes(), "ISO-8859-1")); this.coverFileUploadService.exportOssFile(response.getOutputStream(), objectName); } }

 

5.service

@Service public class CoverFileUploadService { // 允許上傳的格式
    private static final String[] IMAGE_TYPE = new String[]{".bmp", ".jpg", ".jpeg", ".gif", ".png"}; @Autowired private OSS ossClient; @Autowired private AliyunConfig aliyunConfig; /** * @author 團子 * @desc 文件上傳 * @date 2019-07-31 11:31 */
    public FileUploadResult upload(MultipartFile uploadFile) { // 校驗圖片格式
        boolean isLegal = false; for (String type : IMAGE_TYPE) { if (StringUtils.endsWithIgnoreCase(uploadFile.getOriginalFilename(), type)) { isLegal = true; break; } } //封裝Result對象，並且將文件的byte數組放置到result對象中
        FileUploadResult fileUploadResult = new FileUploadResult(); if (!isLegal) { fileUploadResult.setStatus("error"); return fileUploadResult; } //文件新路徑
        String fileName = uploadFile.getOriginalFilename(); String filePath = getFilePath(fileName); // 上傳到阿里雲
        try { ossClient.putObject(aliyunConfig.getBucketName(), filePath, new ByteArrayInputStream(uploadFile.getBytes())); } catch (Exception e) { e.printStackTrace(); //上傳失敗
            fileUploadResult.setStatus("error"); return fileUploadResult; } fileUploadResult.setStatus("done"); fileUploadResult.setResponse("success"); fileUploadResult.setName(this.aliyunConfig.getUrlPrefix() + filePath); fileUploadResult.setUid(String.valueOf(System.currentTimeMillis())); return fileUploadResult; } /** * @author 團子 * @desc 生成路徑以及文件名 例如：//images/2019/08/10/15564277465972939.jpg * @date 2019-07-31 11:31 */
    private String getFilePath(String sourceFileName) { LocalDate localDate = LocalDate.now(); return "images/" + localDate.getYear() + "/" + localDate.getMonth() + "/"
                + localDate.getDayOfMonth() + "/" + System.currentTimeMillis() + RandomUtils.nextInt(100, 9999) + "." + StringUtils.substringAfterLast(sourceFileName, "."); } /** * @author 團子 * @desc 查看文件列表 * @date 2019-07-31 11:31 */
    public List<OSSObjectSummary> list() { // 設置最大個數。
        final int maxKeys = 200; // 列舉文件。
        ObjectListing objectListing = ossClient.listObjects(new ListObjectsRequest(aliyunConfig.getBucketName()).withMaxKeys(maxKeys)); List<OSSObjectSummary> sums = objectListing.getObjectSummaries(); return sums; } /** * @author 團子 * @desc 刪除文件 * @date 2019-07-31 11:31 */
    public FileUploadResult delete(String objectName) { // 根據BucketName,objectName刪除文件
 ossClient.deleteObject(aliyunConfig.getBucketName(), objectName); FileUploadResult fileUploadResult = new FileUploadResult(); fileUploadResult.setName(objectName); fileUploadResult.setStatus("removed"); fileUploadResult.setResponse("success"); return fileUploadResult; } /** * @author 團子 * @desc 下載文件 * @date 2019-07-31 11:31 */
    public void exportOssFile(OutputStream os, String objectName) throws IOException { // ossObject包含文件所在的存儲空間名稱、文件名稱、文件元信息以及一個輸入流。
        OSSObject ossObject = ossClient.getObject(aliyunConfig.getBucketName(), objectName); // 讀取文件內容。
        BufferedInputStream in = new BufferedInputStream(ossObject.getObjectContent()); BufferedOutputStream out = new BufferedOutputStream(os); byte[] buffer = new byte[1024]; int lenght = 0; while ((lenght = in.read(buffer)) != -1) { out.write(buffer, 0, lenght); } if (out != null) { out.flush(); out.close(); } if (in != null) { in.close(); } } }