Java springboot项目引入腾讯云COS实现上传

pom.xml
配置类CosConfig.java
上传工具类CosClientUtil.java

pom.xml

 <!--腾讯云上传图片pom依赖--><dependency><groupId>com.qcloud</groupId><artifactId>cos_api</artifactId><version>5.6.24</version></dependency>

配置类CosConfig.java

package com.dongao.support.config;import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;/*** 腾讯云上传参数* @author： dongao* @create: 2019/10/16*/
@Component
@ConfigurationProperties(prefix = "cos")
public class CosConfig {private String secretId = "腾讯云控制台项目配置secretId";private String secretKey = "腾讯云控制台项目配置secretKey";private String region = "存储桶地域";private String bucketName = "存储桶名称";private String projectName = "业务项目名称";private String common = "common";private String imageSize = "2";private String prefixDomain = "CDN加速域名";private Long expiration = 60L;public String getSecretId() {return secretId;}public void setSecretId(String secretId) {this.secretId = secretId;}public String getSecretKey() {return secretKey;}public void setSecretKey(String secretKey) {this.secretKey = secretKey;}public String getRegion() {return region;}public void setRegion(String region) {this.region = region;}public String getBucketName() {return bucketName;}public void setBucketName(String bucketName) {this.bucketName = bucketName;}public String getProjectName() {return projectName;}public void setProjectName(String projectName) {this.projectName = projectName;}public String getCommon() {return common;}public void setCommon(String common) {this.common = common;}public String getImageSize() {return imageSize;}public void setImageSize(String imageSize) {this.imageSize = imageSize;}public String getPrefixDomain() {return prefixDomain;}public void setPrefixDomain(String prefixDomain) {this.prefixDomain = prefixDomain;}public Long getExpiration() {return expiration;}public void setExpiration(Long expiration) {this.expiration = expiration;}
}

此处给的为默认值，如需改变对应参数，需在application.properties中进行配置

## 腾讯云相关配置
cos.bucketName=testbucket-APPID
cos.projectName=local_qsbase
cos.businessName=knowledge_point
cos.prefixDomain=http://ei-d-files.dongao.com/
cos.imageSize=20
cos.expiration=1

上传工具类CosClientUtil.java

package com.dongao.support.utils;import com.dongao.support.config.CosConfig;
import com.qcloud.cos.COSClient;
import com.qcloud.cos.ClientConfig;
import com.qcloud.cos.auth.BasicCOSCredentials;
import com.qcloud.cos.auth.COSCredentials;
import com.qcloud.cos.exception.CosClientException;
import com.qcloud.cos.http.HttpMethodName;
import com.qcloud.cos.model.*;
import com.qcloud.cos.region.Region;
import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.common.utils.file.FileUploadUtils;
import com.ruoyi.common.utils.spring.SpringUtils;
import org.springframework.web.multipart.MultipartFile;import java.io.IOException;
import java.io.InputStream;
import java.net.URL;
import java.text.SimpleDateFormat;
import java.util.*;/*** 上传工具类* @author： dongao* @create: 2019/10/16*/
public class CosClientUtil {private static CosConfig cosConfig = SpringUtils.getBean(CosConfig.class);/**初始化密钥信息*/private COSCredentials cred = new BasicCOSCredentials(cosConfig.getSecretId(), cosConfig.getSecretKey());/**初始化客户端配置,设置bucket所在的区域*/private ClientConfig clientConfig = new ClientConfig(new Region(cosConfig.getRegion()));/**初始化cOSClient*/private COSClient cosClient = new COSClient(cred, clientConfig);/*** 上传图片* @param file* @param businessName* @return* @throws Exception*/public String uploadImgToCos(MultipartFile file, String businessName) throws Exception {int imageSize = Integer.parseInt(cosConfig.getImageSize());int maxSize = imageSize << 20;if (file.getSize() > maxSize) {throw new Exception("上传文件大小不能超过"+imageSize+"M！");}if (StringUtils.isEmpty(businessName)) {businessName = cosConfig.getCommon();}//生成文件夹层级Calendar cale = Calendar.getInstance();int year = cale.get(Calendar.YEAR);SimpleDateFormat sdf = new SimpleDateFormat("MM");Date dd  = cale.getTime();String month = sdf.format(dd);String folderName = cosConfig.getProjectName()+"/image/"+businessName+"/"+year+"/"+month+"/";//图片名称String originalFilename = file.getOriginalFilename();Random random = new Random();//生成新的图片名称(随机数0-9999+系统当前时间+上传图片名)String name;if (originalFilename.lastIndexOf(".") != -1) {name = random.nextInt(10000) + System.currentTimeMillis() + originalFilename.substring(originalFilename.lastIndexOf("."));}else {String extension = FileUploadUtils.getExtension(file);name = random.nextInt(10000) + System.currentTimeMillis() + "." + extension;}//生成对象键String key = folderName+name;try {InputStream inputStream = file.getInputStream();this.uploadFileToCos(inputStream, key);//return "http://" + cosConfig.getBucketName() + ".cos."+cosConfig.getRegion()+".myqcloud.com/" + key;return key;} catch (Exception e) {throw new Exception("文件上传失败");}}/*** 以文件流方式上传图片* @param is* @param businessName* @param originalFilename* @param fileSize* @return* @throws Exception*/public String uploadImgToCos(InputStream is, String originalFilename, long fileSize, String businessName) throws Exception {int imageSize = Integer.parseInt(cosConfig.getImageSize());int maxSize = imageSize << 20;if (fileSize > maxSize) {throw new Exception("上传文件大小不能超过"+imageSize+"M！");}if (StringUtils.isEmpty(businessName)) {businessName = cosConfig.getCommon();}//生成文件夹层级Calendar cale = Calendar.getInstance();int year = cale.get(Calendar.YEAR);SimpleDateFormat sdf = new SimpleDateFormat("MM");Date dd  = cale.getTime();String month = sdf.format(dd);String folderName = cosConfig.getProjectName()+"/image/"+businessName+"/"+year+"/"+month+"/";//图片名称Random random = new Random();//生成新的图片名称(随机数0-9999+系统当前时间+上传图片名)String name = random.nextInt(10000) + System.currentTimeMillis() + originalFilename.substring(originalFilename.lastIndexOf("."));//生成对象键String key = folderName+name;try {this.uploadFileToCos(is, key);//return "http://" + cosConfig.getBucketName() + ".cos."+cosConfig.getRegion()+".myqcloud.com/" + key;return key;} catch (Exception e) {throw new Exception("文件上传失败");}}/*** 上传到COS服务器 如果同名文件会覆盖服务器上的* @param instream* @param key* @return 出错返回"" ,唯一MD5数字签名*/public String uploadFileToCos(InputStream instream, String key) {String etag = "";try {// 创建上传Object的MetadataObjectMetadata objectMetadata = new ObjectMetadata();// 设置输入流长度为500objectMetadata.setContentLength(instream.available());// 设置 Content typeobjectMetadata.setContentType(getcontentType(key.substring(key.lastIndexOf("."))));// 上传文件PutObjectResult putResult = cosClient.putObject(cosConfig.getBucketName(),  key, instream, objectMetadata);etag = putResult.getETag();} catch (IOException e) {e.printStackTrace();} finally {try {if (instream != null) {//关闭输入流instream.close();}// 关闭客户端(关闭后台线程)cosClient.shutdown();} catch (IOException e) {e.printStackTrace();}}return etag;}/*** Description: 判断Cos服务文件上传时文件的contentType* @param filenameExtension 文件后缀* @return String*/public String getcontentType(String filenameExtension) {String bmp = "bmp";if (bmp.equalsIgnoreCase(filenameExtension)) {return "image/bmp";}String gif = "gif";if (gif.equalsIgnoreCase(filenameExtension)) {return "image/gif";}String jpeg = "jpeg";String jpg = "jpg";String png = "png";if (jpeg.equalsIgnoreCase(filenameExtension) || jpg.equalsIgnoreCase(filenameExtension)|| png.equalsIgnoreCase(filenameExtension)) {return "image/jpeg";}String html = "html";if (html.equalsIgnoreCase(filenameExtension)) {return "text/html";}String txt = "txt";if (txt.equalsIgnoreCase(filenameExtension)) {return "text/plain";}String vsd = "vsd";if (vsd.equalsIgnoreCase(filenameExtension)) {return "application/vnd.visio";}String pptx = "pptx";String ppt = "ppt";if (pptx.equalsIgnoreCase(filenameExtension) || ppt.equalsIgnoreCase(filenameExtension)) {return "application/vnd.ms-powerpoint";}String docx = ".docx";String doc = ".doc";if (docx.equalsIgnoreCase(filenameExtension) || doc.equalsIgnoreCase(filenameExtension)) {return "application/msword";}String xml = "xml";if (xml.equalsIgnoreCase(filenameExtension)) {return "text/xml";}String mp4 = ".mp4";if (mp4.equalsIgnoreCase(filenameExtension)) {return "application/octet-stream";}String pdf = ".pdf";if (pdf.equalsIgnoreCase(filenameExtension)) {// 使用流的形式进行上传，防止下载文件的时候访问url会预览而不是下载。  return "application/pdf";return "application/octet-stream";}String xls = ".xls";String xlsx = ".xlsx";if (xls.equalsIgnoreCase(filenameExtension) || xlsx.equalsIgnoreCase(filenameExtension)) {return "application/vnd.ms-excel";}String mp3 = ".mp3";if (mp3.equalsIgnoreCase(filenameExtension)) {return "audio/mp3";}String wav = ".wav";if (wav.equalsIgnoreCase(filenameExtension)) {return "audio/wav";}return "image/jpeg";}/*** 获取预签名URL* @param urlKey* @return*/public String getPresignedUrl(String urlKey) {URL url = null;try {GeneratePresignedUrlRequest req =new GeneratePresignedUrlRequest(cosConfig.getBucketName(), urlKey, HttpMethodName.GET);// 设置签名过期时间(可选), 若未进行设置, 则默认使用 ClientConfig 中的签名过期时间(1小时)// 可以设置任意一个未来的时间，推荐是设置 10 分钟到 3 天的过期时间// 这里设置签名在半个小时后过期Date expirationDate = new Date(System.currentTimeMillis() + cosConfig.getExpiration() * 60L * 1000L);req.setExpiration(expirationDate);url = cosClient.generatePresignedUrl(req);} catch (CosClientException e) {e.printStackTrace();} finally {cosClient.shutdown();}return url.toString();}/*** 获取预签名URL* @param urlKey  资源路径* @param requestParameter  本次请求的参数* @param customRequestHeader 本次请求的头部。Host 头部会自动补全，不需要填写* @return*/public String getPresignedUrl(String urlKey, Map<String,String> requestParameter,Map<String,String> customRequestHeader) {URL url = null;try {GeneratePresignedUrlRequest req =new GeneratePresignedUrlRequest(cosConfig.getBucketName(), urlKey, HttpMethodName.GET);// 设置签名过期时间(可选), 若未进行设置, 则默认使用 ClientConfig 中的签名过期时间(1小时)// 可以设置任意一个未来的时间，推荐是设置 10 分钟到 3 天的过期时间// 这里设置签名在半个小时后过期Date expirationDate = new Date(System.currentTimeMillis() + cosConfig.getExpiration() * 60L * 1000L);req.setExpiration(expirationDate);// 填写本次请求的参数if (!requestParameter.isEmpty()) {Iterator<Map.Entry<String, String>> iterator = requestParameter.entrySet().iterator();while (iterator.hasNext()) {Map.Entry<String, String> next = iterator.next();String key = next.getKey();String value = next.getValue();req.addRequestParameter(key, value);}}// 填写本次请求的头部。Host 头部会自动补全，不需要填写if (!customRequestHeader.isEmpty()) {Iterator<Map.Entry<String, String>> iterator = customRequestHeader.entrySet().iterator();while (iterator.hasNext()) {Map.Entry<String, String> next = iterator.next();String key = next.getKey();String value = next.getValue();req.putCustomRequestHeader(key, value);}}url = cosClient.generatePresignedUrl(req);} catch (CosClientException e) {e.printStackTrace();} finally {cosClient.shutdown();}return url.toString();}/*** 在指定账号下创建一个存储桶。同一用户账号下，可以创建多个存储桶，数量上限是200个（不区分地域），存储桶中的对象数量没有限制。* 创建存储桶是低频操作，一般建议在控制台创建 Bucket，在 SDK 进行 Object 的操作。* @return*/public Bucket createBucket(String bucketName) {Bucket bucketResult = null;try {//存储桶名称，格式：BucketName-APPIDString bucket = bucketName+"-1252590610";CreateBucketRequest createBucketRequest = new CreateBucketRequest(bucket);// 设置 bucket 的权限为 Private(私有读写), 其他可选有公有读私有写, 公有读写createBucketRequest.setCannedAcl(CannedAccessControlList.Private);bucketResult = cosClient.createBucket(createBucketRequest);} catch (CosClientException e) {e.printStackTrace();} finally {cosClient.shutdown();}return bucketResult;}/*** 查询指定账号下所有的存储桶列表* @return*/public List<Bucket> listBuckets() {List<Bucket> buckets = null;try {// 如果只调用 listBuckets 方法，则创建 cosClient 时指定 region 为 new Region("") 即可buckets = cosClient.listBuckets();} catch (CosClientException e) {e.printStackTrace();} finally {cosClient.shutdown();}return buckets;}/*** 检索存储桶是否存在且是否有权限访问* @param bucketName* @return*/public boolean doesBucketExist(String bucketName) {boolean bucketExistFlag = false;try {// bucket的命名规则为 BucketName-APPID ，此处填写的存储桶名称必须为此格式String bucket = bucketName+"-1252590610";bucketExistFlag = cosClient.doesBucketExist(bucket);} catch (CosClientException e) {e.printStackTrace();} finally {cosClient.shutdown();}return bucketExistFlag;}/*** 删除指定账号下的空存储桶* @param bucketName*/public void deleteBucket(String bucketName){try {// bucket的命名规则为 BucketName-APPID ，此处填写的存储桶名称必须为此格式String bucket = bucketName+"-1252590610";cosClient.deleteBucket(bucket);} catch (CosClientException e) {e.printStackTrace();} finally {cosClient.shutdown();}}/*** 获取存储桶的权限信息* @param bucketName* @return*/public CannedAccessControlList getBucketAcl(String bucketName) {CannedAccessControlList cannedAccessControlList = null;try {// bucket的命名规则为 BucketName-APPID ，此处填写的存储桶名称必须为此格式String bucket = bucketName+"-1252590610";AccessControlList accessControlList = cosClient.getBucketAcl(bucket);// 将存储桶权限转换为预设 ACL, 可选值为：Private, PublicRead, PublicReadWritecannedAccessControlList = accessControlList.getCannedAccessControl();} catch (CosClientException e) {e.printStackTrace();} finally {cosClient.shutdown();}return cannedAccessControlList;}
}

注：日常工作记录，方便后续查阅，也为大家提供方便

Java springboot项目引入腾讯云COS实现上传相关推荐

tp5封装腾讯云cos文件上传sdk
第一步: 使用命令安装sdk到框架vendor目录里 composer require tencentcloud/tencentcloud-sdk-php 第二步:在application/commo ...
SpringBoot整合腾讯云COS（上传）
腾讯云COS文档:对象存储快速入门-SDK 文档-文档中心-腾讯云 (tencent.com) 开通腾讯云COS 创建存储桶请求域名可做拼接文件访问URL使用然后下一步即可上传文件时需要以上红 ...
关于腾讯云COS文件上传
在网上看了很多cos的上传,到处都是坑还很麻烦,而且cos给出的api也很坑,不会看源码真的是会走很多弯路,废话不多说直接上代码.. import com.qcloud.cos.COSClient; ...
springboot整合腾讯云cos进行上传、下载、删除文件
参考腾讯官方文档 pom <dependency><groupId>com.qcloud</groupId><artifactId>cos_api< ...
crmeb 多商户系统七牛云阿里云oss腾讯云cos文件上传配置教程
本地存储不用填写表单信息所属地域:腾讯COS和阿里云必须填写,七牛云可不填七牛云储存创建及使用 1.获取七牛云AccessKey/SecretKey 2.打开七牛云存储 3.创建存储空间 4.绑定 ...
腾讯云轻量应用服务器器使用技巧-腾讯云OrcaTerm的上传下载
前言: 上传下载是WebShell中不可或缺的功能之一,也是我在日常管理过程中经常使用操作.这里就跟着博主的视角来揭秘,腾讯云OrcaTerm的上传与下载. 对比博主对比了一些shell的应用,这里 ...
springboot项目实现腾讯云的短信验证
前言:可以先去看下腾讯云开通短息服务需要哪些信息.我这里使用自己很久之前申请过的公众号,其他的比如网站,小程序啥的也没有,哈哈哈~. 腾讯云地址: https://console.cloud.tenc ...
部署SpringBoot项目到腾讯云或其他服务器
参考 https://blog.csdn.net/qq_32483795/article/details/93979382 使用腾讯云的Tencent Cloud Toolkit进行项目部署的时候发现 ...
【硅谷课堂】腾讯云点播WEB上传方式代码（第二种方式）
下载依赖 npm i vod-js-sdk-v6 前端 /vod/course/Video/Form.vue <template><e ...

Java springboot项目引入腾讯云COS实现上传

Java springboot项目引入腾讯云COS实现上传

pom.xml

配置类CosConfig.java

上传工具类CosClientUtil.java

Java springboot项目引入腾讯云COS实现上传相关推荐

最新文章

热门文章