SpringBoot整合騰訊云COS對象存儲實現(xiàn)文件上傳的示例代碼

更新時間：2021年12月21日 10:05:44 作者：KK·Liu先生

本文主要介紹了SpringBoot整合騰訊云COS對象存儲實現(xiàn)文件上傳的示例代碼，文中通過示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下

企業(yè)級項目開發(fā)中都會有文件、圖片、視頻等文件上傳并能夠訪問的場景，對于初學者Demo可能會直接存儲在應用服務器上；對于傳統(tǒng)項目可能會單獨搭建FastDFS、MinIO等文件服務來實現(xiàn)存儲，這種方案可能對于企業(yè)成本較小，但缺點也是很多，例如：1、增加技術(shù)人員的運維和維護成本，2、規(guī)模越來越大時需要硬件的支持，且存在文件丟失風險，3、服務器沒有CDN，用戶訪問網(wǎng)站圖片加載慢用戶體驗不好。

所以，一般上規(guī)模的項目、或者追求用戶體驗的項目可能會考慮使用第三方的云服務來存儲，市場主流廠商有：七牛云、阿里云OSS、騰訊云COS等，具體采用哪種存儲方案需結(jié)合項目、規(guī)模、成本等因素，綜合考量確定。

因為用的騰訊云服務器，為了方便統(tǒng)一管理，所以直接用了騰訊云的COS對象存儲服務，下面是基于SpringBoot和騰訊云COS提供的Java SDK快速對接實現(xiàn)文件上傳功能。

1、開通騰訊云對象存儲服務

https://console.cloud.tencent.com/cos5

2、創(chuàng)建存儲桶

3、密鑰管理，新建密鑰

4、yml配置密鑰、COS信息

cos:
  baseUrl: fxxxxxa-1xxxxx1.cos.ap-shanghai.myqcloud.com
  accessKey: AKxxxxxxxxxxxxxxxxxxxxxxxxxCF
  secretKey: oKxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxni
  regionName: ap-shanghai
  bucketName: fxxxxxa-1xxxxx1
  folderPrefix: /files

5、COSConfig配置類

@Data
@Component
@ConfigurationProperties(prefix = "cos")
public class COSConfig {
    private String baseUrl;
    private String accessKey;
    private String secretKey;
    private String regionName;
    private String bucketName;
    private String folderPrefix;
}

6、COS文件上傳工具類

/**
 * 騰訊云COS文件上傳工具類
 */
@Slf4j
public class COSClientUtil {
 
    /**
     * 獲取配置信息
     */
    private static COSConfig cosConfig = SpringBeanUtils.getBean(COSConfig.class);
 
    /**
     * 初始化用戶身份信息
     */
    private static COSCredentials cred = new BasicCOSCredentials(cosConfig.getAccessKey(), cosConfig.getSecretKey());
 
    /**
     * 設置bucket的區(qū)域
     */
    private static ClientConfig clientConfig = new ClientConfig(new Region(cosConfig.getRegionName()));
 
    /**
     * 生成COS客戶端
     */
    private static COSClient cosClient = new COSClient(cred, clientConfig);
 
    /**
     * 上傳文件
     *
     * @param file
     * @return
     * @throws Exception
     */
    public static String upload(MultipartFile file) throws Exception {
        String date = DateUtils.formateDate(new Date(), "yyyy-MM-dd");
        String originalFilename = file.getOriginalFilename();
        long nextId = IdGenerator.getFlowIdWorkerInstance().nextId();
        String name = nextId + originalFilename.substring(originalFilename.lastIndexOf("."));
        String folderName = cosConfig.getFolderPrefix() + "/" + date + "/";
        String key = folderName + name;
        File localFile = null;
        try {
            localFile = transferToFile(file);
            String filePath = uploadFileToCOS(localFile, key);
            log.info("upload COS successful: {}", filePath);
            return filePath;
        } catch (Exception e) {
            throw new Exception("文件上傳失敗");
        } finally {
            localFile.delete();
        }
    }
 
    /**
     * 上傳文件到COS
     *
     * @param localFile
     * @param key
     * @return
     */
    private static String uploadFileToCOS(File localFile, String key) throws InterruptedException {
        PutObjectRequest putObjectRequest = new PutObjectRequest(cosConfig.getBucketName(), key, localFile);
        ExecutorService threadPool = Executors.newFixedThreadPool(8);
        // 傳入一個threadPool, 若不傳入線程池, 默認TransferManager中會生成一個單線程的線程池
        TransferManager transferManager = new TransferManager(cosClient, threadPool);
        // 返回一個異步結(jié)果Upload, 可同步的調(diào)用waitForUploadResult等待upload結(jié)束, 成功返回UploadResult, 失敗拋出異常
        Upload upload = transferManager.upload(putObjectRequest);
        UploadResult uploadResult = upload.waitForUploadResult();
        transferManager.shutdownNow();
        cosClient.shutdown();
        String filePath = cosConfig.getBaseUrl() + uploadResult.getKey();
        return filePath;
    }
 
    /**
     * 用緩沖區(qū)來實現(xiàn)這個轉(zhuǎn)換, 即創(chuàng)建臨時文件
     * 使用 MultipartFile.transferTo()
     *
     * @param multipartFile
     * @return
     */
    private static File transferToFile(MultipartFile multipartFile) throws IOException {
        String originalFilename = multipartFile.getOriginalFilename();
        String prefix = originalFilename.split("\\.")[0];
        String suffix = originalFilename.substring(originalFilename.lastIndexOf("."));
        File file = File.createTempFile(prefix, suffix);
        multipartFile.transferTo(file);
        return file;
    }
 
}

7、Controller測試上傳接口：

    /**
     * 騰訊云COS上傳
     *
     * @param file
     * @return
     * @throws Exception
     */
    @PostMapping(value = "/cosUpload")
    public ResponseEntity cosUpload(MultipartFile file) throws Exception {
        String filePath = COSClientUtil.upload(file);
        UploadDTO dto = UploadDTO.builder().filePath(filePath).build();
        return ResultVOUtil.success(dto);
    }