• cos文件上传demo (精简版通用)

    1. 依赖

    1. <!--腾讯云cos依赖-->
    2. <dependency>
    3. 	<groupId>com.qcloud</groupId>
    4. 	<artifactId>cos_api</artifactId>
    5. 	<version>5.6.54</version>
    6. </dependency>

    2. FileController

    1. import com.ruoyi.common.core.domain.AjaxResult;
    2. import com.ruoyi.common.utils.file.FileUtils;
    3. import io.swagger.annotations.Api;
    4. import io.swagger.annotations.ApiOperation;
    5. import lombok.extern.slf4j.Slf4j;
    6. import org.springframework.beans.factory.annotation.Autowired;
    7. import org.springframework.web.bind.annotation.PostMapping;
    8. import org.springframework.web.bind.annotation.RequestMapping;
    9. import org.springframework.web.bind.annotation.RequestPart;
    10. import org.springframework.web.bind.annotation.RestController;
    11. import org.springframework.web.multipart.MultipartFile;
    12.  
    13. import java.security.SecureRandom;
    14. import java.text.SimpleDateFormat;
    15. import java.util.Date;
    16.  
    17. @Slf4j
    18. @Api(value = "文件", tags = {"文件"})
    19. @RestController
    20. @RequestMapping("/file/upload")
    21. public class FileController {
    22.  
    23.  
    24.     @Autowired
    25.     private COSUtils cosUtils;
    26.  
    27.     @ApiOperation("文件上传")
    28.     @PostMapping
    29.     public AjaxResult upload(@RequestPart("file") MultipartFile file){
    30.         try {
    31.             String url = "";
    32.             // 获取后缀名
    33.             String fileSuffix = file.getOriginalFilename().substring(file.getOriginalFilename().lastIndexOf("."));
    34.             // 最后上传生成的文件名
    35.             String finalFileName = System.currentTimeMillis() + "" + new SecureRandom().nextInt(0x0400) + fileSuffix;
    36.             // oss中的文件夹名
    37.             String objectName = new SimpleDateFormat("yyyyMMdd").format(new Date()) + "/" + finalFileName;
    38.             // 上传oss
    39.             cosUtils.uploadFileCOS(file.getInputStream(), objectName);
    40.             //获取文件的URl地址
    41.             url = cosUtils.getUrl(objectName);
    42.             log.info("url: {}",url);
    43.  
    44.             AjaxResult ajax = AjaxResult.success();
    45.             ajax.put("url", url);
    46.             ajax.put("fileName", file.getOriginalFilename());
    47.             ajax.put("newFileName", FileUtils.getName(finalFileName));
    48.             return ajax;
    49.         } catch (Exception e) {
    50.             return AjaxResult.error(e.getMessage());
    51.         }
    52.     }
    53. }

     

    3. AjaxResult
     

    1. import java.util.HashMap;
    2. import com.ruoyi.common.constant.HttpStatus;
    3. import com.ruoyi.common.utils.StringUtils;
    4.  
    5. /**
    6.  * 操作消息提醒
    7.  * 
    8.  */
    9. public class AjaxResult extends HashMap<String, Object>
    10. {
    11.     private static final long serialVersionUID = 1L;
    12.  
    13.     /** 状态码 */
    14.     public static final String CODE_TAG = "code";
    15.  
    16.     /** 返回内容 */
    17.     public static final String MSG_TAG = "msg";
    18.  
    19.     /** 数据对象 */
    20.     public static final String DATA_TAG = "data";
    21.  
    22.     /**
    23.      * 初始化一个新创建的 AjaxResult 对象，使其表示一个空消息。
    24.      */
    25.     public AjaxResult()
    26.     {
    27.     }
    28.  
    29.     /**
    30.      * 初始化一个新创建的 AjaxResult 对象
    31.      * 
    32.      * @param code 状态码
    33.      * @param msg 返回内容
    34.      */
    35.     public AjaxResult(int code, String msg)
    36.     {
    37.         super.put(CODE_TAG, code);
    38.         super.put(MSG_TAG, msg);
    39.     }
    40.  
    41.     /**
    42.      * 初始化一个新创建的 AjaxResult 对象
    43.      * 
    44.      * @param code 状态码
    45.      * @param msg 返回内容
    46.      * @param data 数据对象
    47.      */
    48.     public AjaxResult(int code, String msg, Object data)
    49.     {
    50.         super.put(CODE_TAG, code);
    51.         super.put(MSG_TAG, msg);
    52.         if (StringUtils.isNotNull(data))
    53.         {
    54.             super.put(DATA_TAG, data);
    55.         }
    56.     }
    57.  
    58.     /**
    59.      * 返回成功消息
    60.      * 
    61.      * @return 成功消息
    62.      */
    63.     public static AjaxResult success()
    64.     {
    65.         return AjaxResult.success("操作成功");
    66.     }
    67.  
    68.     /**
    69.      * 返回成功数据
    70.      * 
    71.      * @return 成功消息
    72.      */
    73.     public static AjaxResult success(Object data)
    74.     {
    75.         return AjaxResult.success("操作成功", data);
    76.     }
    77.  
    78.     /**
    79.      * 返回成功消息
    80.      * 
    81.      * @param msg 返回内容
    82.      * @return 成功消息
    83.      */
    84.     public static AjaxResult success(String msg)
    85.     {
    86.         return AjaxResult.success(msg, null);
    87.     }
    88.  
    89.     /**
    90.      * 返回成功消息
    91.      * 
    92.      * @param msg 返回内容
    93.      * @param data 数据对象
    94.      * @return 成功消息
    95.      */
    96.     public static AjaxResult success(String msg, Object data)
    97.     {
    98.         return new AjaxResult(HttpStatus.SUCCESS, msg, data);
    99.     }
    100.  
    101.     /**
    102.      * 返回错误消息
    103.      * 
    104.      * @return
    105.      */
    106.     public static AjaxResult error()
    107.     {
    108.         return AjaxResult.error("操作失败");
    109.     }
    110.  
    111.     /**
    112.      * 返回错误消息
    113.      * 
    114.      * @param msg 返回内容
    115.      * @return 警告消息
    116.      */
    117.     public static AjaxResult error(String msg)
    118.     {
    119.         return AjaxResult.error(msg, null);
    120.     }
    121.  
    122.     /**
    123.      * 返回错误消息
    124.      * 
    125.      * @param msg 返回内容
    126.      * @param data 数据对象
    127.      * @return 警告消息
    128.      */
    129.     public static AjaxResult error(String msg, Object data)
    130.     {
    131.         return new AjaxResult(HttpStatus.ERROR, msg, data);
    132.     }
    133.  
    134.     /**
    135.      * 返回错误消息
    136.      * 
    137.      * @param code 状态码
    138.      * @param msg 返回内容
    139.      * @return 警告消息
    140.      */
    141.     public static AjaxResult error(int code, String msg)
    142.     {
    143.         return new AjaxResult(code, msg, null);
    144.     }
    145.  
    146.     /**
    147.      * 方便链式调用
    148.      *
    149.      * @param key 键
    150.      * @param value 值
    151.      * @return 数据对象
    152.      */
    153.     @Override
    154.     public AjaxResult put(String key, Object value)
    155.     {
    156.         super.put(key, value);
    157.         return this;
    158.     }
    159. }
     

     

     

     

     

     

     

     

     

     

     

     

     

     

     

     

     

     

     

     

     

     

     

     

     

     

     

     

     

     

    4. COSUtils
     

    1. import com.qcloud.cos.COSClient;
    2. import com.qcloud.cos.ClientConfig;
    3. import com.qcloud.cos.auth.BasicCOSCredentials;
    4. import com.qcloud.cos.auth.COSCredentials;
    5. import com.qcloud.cos.http.HttpMethodName;
    6. import com.qcloud.cos.http.HttpProtocol;
    7. import com.qcloud.cos.model.GeneratePresignedUrlRequest;
    8. import com.qcloud.cos.model.ObjectMetadata;
    9. import com.qcloud.cos.model.PutObjectResult;
    10. import com.qcloud.cos.region.Region;
    11. import lombok.extern.slf4j.Slf4j;
    12. import org.springframework.stereotype.Component;
    13.  
    14. import java.io.IOException;
    15. import java.io.InputStream;
    16. import java.net.URL;
    17. import java.util.Date;
    18.  
    19. @Slf4j
    20. @Component
    21. public class COSUtils {
    22.  
    23.  
    24.     // API密钥
    25.     private static final String secretId = "xxxxxx";
    26.     private static final String secretKey = "xxxxxx";
    27.     // 桶名称
    28.     private static final String bucketName = "xxxxxx";
    29.     // 地域
    30.     private static final String region = "xxxxxx";
    31.     // 文件夹
    32.     private static final String FOLDER = "image/";
    33.  
    34.  
    35.  
    36.     public static COSClient getCOSClient() {
    37.         // 1 初始化用户身份信息（secretId, secretKey）。
    38.         COSCredentials cred = new BasicCOSCredentials(secretId, secretKey);
    39.         // 2 此处设置的地域为香港
    40.         Region rg = new Region(region);
    41.         ClientConfig clientConfig = new ClientConfig(rg);
    42.         // 这里建议设置使用 https 协议
    43.         // 从 5.6.54 版本开始，默认使用了 https
    44.         clientConfig.setHttpProtocol(HttpProtocol.https);
    45.         // 3 生成 cos 客户端。
    46.         COSClient cosClient = new COSClient(cred, clientConfig);
    47.         return cosClient;
    48.     }
    49.  
    50.  
    51.  
    52.     public String uploadFileCOS(InputStream instream, String fileName){
    53.  
    54.         String ret = "";
    55.         try {
    56.             // 创建上传Object的Metadata
    57.             ObjectMetadata objectMetadata = new ObjectMetadata();
    58.             objectMetadata.setContentLength(instream.available());
    59.             objectMetadata.setCacheControl("no-cache");
    60.             objectMetadata.setContentType(getContentType(fileName.substring(fileName.lastIndexOf("."))));
    61.             objectMetadata.setHeader("Pragma", "no-cache");
    62.  
    63.             // 上传文件
    64.             PutObjectResult putResult = getCOSClient().putObject(bucketName, FOLDER + fileName, instream, objectMetadata);
    65.             ret = putResult.getETag();
    66.         } catch (IOException e) {
    67.             e.printStackTrace();
    68.         }finally {
    69.             try {
    70.                 if (instream != null) {
    71.                     instream.close();
    72.                 }
    73.             } catch (IOException e) {
    74.                 e.printStackTrace();
    75.             }
    76.         }
    77.         return ret;
    78.     }
    79.  
    80.  
    81.  
    82.     public static final String getContentType(String filenameExtension) {
    83.  
    84.         if (filenameExtension.equalsIgnoreCase(".bmp")) {
    85.             return "application/x-bmp";
    86.         }
    87.         if (filenameExtension.equalsIgnoreCase(".gif")) {
    88.             return "image/gif";
    89.         }
    90.         if (filenameExtension.equalsIgnoreCase(".jpeg") ||
    91.                 filenameExtension.equalsIgnoreCase(".jpg") ||
    92.                 filenameExtension.equalsIgnoreCase(".png")) {
    93.             return "image/jpg";
    94.         }
    95.         if (filenameExtension.equalsIgnoreCase(".html")) {
    96.             return "text/html";
    97.         }
    98.         if (filenameExtension.equalsIgnoreCase(".txt")) {
    99.             return "text/plain";
    100.         }
    101.         if (filenameExtension.equalsIgnoreCase(".vsd")) {
    102.             return "application/vnd.visio";
    103.         }
    104.         if (filenameExtension.equalsIgnoreCase(".pptx") ||
    105.                 filenameExtension.equalsIgnoreCase(".ppt")) {
    106.             return "application/vnd.ms-powerpoint";
    107.         }
    108.         if (filenameExtension.equalsIgnoreCase(".docx") ||
    109.                 filenameExtension.equalsIgnoreCase(".doc")) {
    110.             return "application/msword";
    111.         }
    112.         if (filenameExtension.equalsIgnoreCase(".xla") ||
    113.                 filenameExtension.equalsIgnoreCase(".xlc") ||
    114.                 filenameExtension.equalsIgnoreCase(".xlm") ||
    115.                 filenameExtension.equalsIgnoreCase(".xls") ||
    116.                 filenameExtension.equalsIgnoreCase(".xlt") ||
    117.                 filenameExtension.equalsIgnoreCase(".xlw")) {
    118.             return "application/vnd.ms-excel";
    119.         }
    120.         if (filenameExtension.equalsIgnoreCase(".xlsx")) {
    121.             return "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet";
    122.         }
    123.         if (filenameExtension.equalsIgnoreCase(".xml")) {
    124.             return "text/xml";
    125.         }
    126.         if (filenameExtension.equalsIgnoreCase(".pdf")) {
    127.             return "application/pdf";
    128.         }
    129.         if (filenameExtension.equalsIgnoreCase(".zip")) {
    130.             return "application/zip";
    131.         }
    132.         if (filenameExtension.equalsIgnoreCase(".tar")) {
    133.             return "application/x-tar";
    134.         }
    135.         if (filenameExtension.equalsIgnoreCase(".avi")) {
    136.             return "video/avi";
    137.         }
    138.         if (filenameExtension.equalsIgnoreCase(".mp4")) {
    139.             return "video/mpeg4";
    140.         }
    141.         if (filenameExtension.equalsIgnoreCase(".mp3")) {
    142.             return "audio/mp3";
    143.         }
    144.         if (filenameExtension.equalsIgnoreCase(".mp2")) {
    145.             return "audio/mp2";
    146.         }
    147.         // 默认下载
    148. //        return "application/octet-stream";
    149.         return "image/jpg";
    150.     }
    151.  
    152.  
    153.     public String getUrl(String key) {
    154.         GeneratePresignedUrlRequest req =
    155.                 new GeneratePresignedUrlRequest(bucketName, key, HttpMethodName.GET);
    156.         // 设置签名过期时间(可选), 若未进行设置, 则默认使用 ClientConfig 中的签名过期时间(1小时)
    157.         // 10年
    158.         Date expirationDate = new Date(System.currentTimeMillis() + 3600L * 1000 * 24 * 365 * 10);
    159.         req.setExpiration(expirationDate);
    160.         COSClient cosClient = getCOSClient();
    161.         URL url = cosClient.generatePresignedUrl(req);
    162.         cosClient.shutdown();
    163.         if (url != null) {
    164.             return "https://" + url.getHost() + "/image" + url.getPath();
    165.         }
    166.         return "";
    167.     }
    168. }
     

     

     

     

     

     

     

     

     

     

     

     

     

     

     

     

     

     

     

     

     

     

     

     

     

     

     

     

     

     

     

     

     

    5. 上传成功
     

     

     

     

     

     

     

     

     

     

    
                
    
                    
    
                
    • 

                
  • 

                    相关阅读:
    
                    
开源物联网平台ThingsBoard的安装                            
    
ContOS 7 修改IP地址                            
    
Linux常用命令——chpasswd命令                            
    
IO进程间通信：信号                            
    
基于 FFMPEG 的跨平台视频播放器简明教程（三）：视频解码                            
    
波奇学Linux:日志                            
    
2019年数维杯数学建模A题 我国省际生态环境与经济交互状况的综合评价求解全过程文档及程序                            
    
【深入浅出 Yarn 架构与实现】6-3 NodeManager 分布式缓存                            
    
第四十五篇，STL标准模板库常见算法                            
    
案例--某站视频爬取                            
    
                        
                
    • 
                
  • 
                    原文地址：https://blog.csdn.net/weixin_43652507/article/details/133752858
                
    •