SpringBoot集成腾讯COS流程

1.pom.xml中添加cos配置

<!--腾讯cos -->
<dependency><groupId>com.qcloud</groupId><artifactId>cos_api</artifactId><version>5.6.28</version>
</dependency>

2.application.yaml中添加cos配置

# 腾讯云存储cos相关公共配置
tencent:cos:secretId: ABIDFG5gz36gMp2xbyHvYw3usecretKey: 93ima8OcaHhDUUDjEdmfYEdbucketName: haha-18888888folder: videoregion: ap-shanghai

3.创建属性映射类CosProperties

/*** Cos配置*/
@Data
@Component
@RefreshScope
@ConfigurationProperties(prefix = "tencent.cos")
public class CosProperties {private String secretId;private String secretKey;private String bucketName;private String folder;private String region;}

4.封装Cos工具类

/*** cos 工具类*/
@Slf4j
public class CosUtils {private static CosUtils cosUtils = new CosUtils();private COSClient cosClient;public static CosUtils getInstance() {return cosUtils;}private CosProperties cosProperties;public CosUtils setCosProperties(CosProperties cosProperties) {this.cosProperties = cosProperties;this.cosClient = createCOSClient(cosProperties);return this;}public String getUploadTemporaryToken(String key) {if (StrUtil.hasBlank(cosProperties.getSecretId(), cosProperties.getSecretKey())) {return null;}COSCredentials cred = new BasicCOSCredentials(cosProperties.getSecretId(), cosProperties.getSecretKey());COSSigner signer = new COSSigner();// 设置过期时间为1个小时LocalDateTime now = LocalDateTime.now();Date expiredTime = new Date(now.toInstant(ZoneOffset.of("+8")).toEpochMilli() + 3600L * 1000L);// 要签名的 key, 生成的签名只能用于对应此 key 的上传log.info("待签名key[{}], now[{}]", key, now);String signStr = signer.buildAuthorizationStr(HttpMethodName.PUT, key, cred, expiredTime);log.info("签名成功, key[{}], now[{}], signStr[{}]", key, now, signStr);return signStr;}/*** 上传文件* 1.创建本地文件 2.上传** @param fileName    文件名(带后缀)* @param fileContent 文件内容* @return*/public String upload(String fileName, String fileContent, String customizeFolder) {try {String cosSecretId = cosProperties.getSecretId();String cosSecretKey = cosProperties.getSecretKey();String folder = StringUtils.isEmpty(customizeFolder) ? cosProperties.getFolder() : customizeFolder;String bucketName = cosProperties.getBucketName();if (StringUtils.isEmpty(cosSecretId) ||StringUtils.isEmpty(cosSecretKey) ||StringUtils.isEmpty(bucketName) ||StringUtils.isEmpty(folder)) {log.error("cos upload params Incomplete");return "";}String root = Objects.requireNonNull(CosUtils.class.getResource("/")).getPath();String s = root + "/temp/upload/";File localFile = getLocalFile(fileContent, s, fileName);if (localFile == null) {return "";}DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");String fromatDate = LocalDateTime.now().format(formatter);String fileUrl = folder + "/" + fromatDate + "/" + fileName;PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, fileUrl, localFile);// 设置存储类型, 默认是标准(Standard), 低频(standard_ia)putObjectRequest.setStorageClass(StorageClass.Standard);try {this.cosClient.putObject(putObjectRequest);} catch (CosClientException e) {log.error("An exception occurs during execution cos upload,error message:{}", e.getMessage());}//删除本地缓存文件if (localFile.exists()) {localFile.delete();}return fileUrl.startsWith("/") ? fileUrl : "/" + fileUrl;}catch (Exception e){log.error("文件上传失败,{}",e);}return StrUtil.EMPTY;}/*** 删除文件** @param bucketName* @param key* @return*/public Boolean deleteCosFile(String bucketName, String key) {String cosSecretId = cosProperties.getSecretId();String cosSecretKey = cosProperties.getSecretKey();Boolean executeFlag = true;if (StringUtils.isEmpty(cosSecretId) ||StringUtils.isEmpty(cosSecretKey) ||StringUtils.isEmpty(bucketName) ||StringUtils.isEmpty(key)) {log.error("cos delete file  params Incomplete");return false;}COSCredentials cred = new BasicCOSCredentials(cosSecretId, cosSecretKey);// 2 设置bucket的区域, COS地域的简称请参照 https://www.qcloud.com/document/product/436/6224ClientConfig clientConfig = new ClientConfig(new Region("ap-nanjing"));// 3 生成cos客户端COSClient cosclient = new COSClient(cred, clientConfig);try {cosclient.deleteObject(bucketName, key);} catch (CosClientException e) {log.error("An exception occurs during execution cos delete,error message:{}", e.getMessage());executeFlag = false;}// 关闭客户端cosclient.shutdown();return executeFlag;}private void getDir(String path) {File localFile = new File(path);if (!localFile.exists()) {localFile.mkdirs();}}private File getLocalFile(String instructionSet, String dir, String fileName) {File localFile = null;try {getDir(dir);localFile = new File(dir, fileName);if (!localFile.exists()) {localFile.createNewFile();}FileOutputStream fos = new FileOutputStream(localFile, true);OutputStreamWriter osw = new OutputStreamWriter(fos);BufferedWriter bw = new BufferedWriter(osw);bw.write(instructionSet);bw.newLine();bw.flush();bw.close();osw.close();fos.close();return localFile;} catch (IOException e2) {log.error("An exception occurs during execution create local file,error message:{} ", e2.getMessage());return null;}}/*** 获取二进制文件*/public static byte[] downLoadBinary(String urlStr) throws IOException {HttpURLConnection conn = null;InputStream inputStream = null;ByteArrayOutputStream bos = null;try {URL url = new URL(urlStr);conn = (HttpURLConnection) url.openConnection();//设置超时间为10秒conn.setConnectTimeout(10 * 1000);conn.setRequestProperty("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/84.0.4147.135 Safari/537.36");//得到输入流inputStream = conn.getInputStream();bos = new ByteArrayOutputStream();//获取数据数组return readInputStream(inputStream, bos);} finally {if (bos != null) {bos.close();}if (inputStream != null) {inputStream.close();}if (conn != null) {conn.disconnect();}}}/*** 获取字符串列表*/public static List<String> downLoadList(String urlStr) throws IOException {HttpURLConnection conn = null;InputStream inputStream = null;try {URL url = new URL(urlStr);conn = (HttpURLConnection) url.openConnection();//设置超时间为10秒conn.setConnectTimeout(10 * 1000);conn.setRequestProperty("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/84.0.4147.135 Safari/537.36");//得到输入流inputStream = conn.getInputStream();//获取数据数组 windows操作系统默认编码：GB18030return IoUtil.readLines(new InputStreamReader(inputStream, Charset.forName("GB18030")), new ArrayList<>());} catch (IOException e){log.error("An exception occurs during execution download file,error message:{} ", e.getMessage());return Collections.EMPTY_LIST;}finally {if (inputStream != null) {inputStream.close();}if (conn != null) {conn.disconnect();}}}/*** 输入流转二进制*/public static byte[] readInputStream(InputStream inputStream, ByteArrayOutputStream bos) throws IOException {byte[] buffer = new byte[1024];int len = 0;while ((len = inputStream.read(buffer)) != -1) {bos.write(buffer, 0, len);}return bos.toByteArray();}/*** 创建cosClient** @param cosProperties* @return*/public static COSClient createCOSClient(CosProperties cosProperties) {// 1 初始化用户身份信息（secretId, secretKey）。// SECRETID和SECRETKEY请登录访问管理控制台 https://console.cloud.tencent.com/cam/capi// 进行查看和管理String secretId = cosProperties.getSecretId();String secretKey = cosProperties.getSecretKey();COSCredentials cred = new BasicCOSCredentials(secretId, secretKey);// 2 设置 bucket 的地域, COS 地域的简称请参照// https://cloud.tencent.com/document/product/436/6224// clientConfig 中包含了设置 region, https(默认 http), 超时, 代理等 set 方法, 使用可参见源码或者常见问题// Java SDK 部分。Region region = new Region(cosProperties.getRegion());ClientConfig clientConfig = new ClientConfig(region);// 这里建议设置使用 https 协议// 从 5.6.54 版本开始，默认使用了 httpsclientConfig.setHttpProtocol(HttpProtocol.https);// 3 生成 cos 客户端。return new COSClient(cred, clientConfig);}/*** 获取视频属性: (宽度、高度、时长)* 获取方式:从oss获取** @param ossUrl* @return*/public VideoProperties getVideoPropertiesFromCos(String ossUrl) {try {// 此处的key为对象键，对象键是对象在存储桶内的唯一标识String key = ossUrl;GeneratePresignedUrlRequest req = new GeneratePresignedUrlRequest("greatpan-1300159541", key, HttpMethodName.GET);// 设置签名过期时间(可选), 若未进行设置, 则默认使用 ClientConfig 中的签名过期时间(1小时)// 可以设置任意一个未来的时间，推荐是设置 10 分钟到 3 天的过期时间// 这里设置签名在半个小时后过期Date expirationDate = new Date(System.currentTimeMillis() + 30L * 60L * 1000L);req.setExpiration(expirationDate);req.addRequestParameter("ci-process", "videoinfo");URL url = this.cosClient.generatePresignedUrl(req);String mediaInfoXml = HttpClientUtil.doGet(url.toString());if (mediaInfoXml != null) {Document document = XmlUtil.readXML(mediaInfoXml);Node error = document.getElementsByTagName("Error").item(0);if (!ObjectUtils.isEmpty(error)) {Node message = document.getElementsByTagName("Message").item(0);log.error("获取视频基础信息出错.ossurl:{}, e:{}", ossUrl, Optional.ofNullable(message).map(Node::getTextContent).orElse(""));return null;}String width = document.getElementsByTagName("Width").item(0).getTextContent();String height = document.getElementsByTagName("Height").item(0).getTextContent();String rotation = document.getElementsByTagName("Rotation").item(0).getTextContent();if (StringUtils.isEmpty(width) || StringUtils.isEmpty(height) || StringUtils.isEmpty(rotation)) {return null;}VideoProperties videoProperties = new VideoProperties();int w = Integer.parseInt(width);int h = Integer.parseInt(height);int r = (int) Double.parseDouble(rotation);// 如果r是90或者270, 说明视频有旋转操作, 并宽高比有变化，需要把w 和 h 调换if (r % 90 == 0 && (r / 90 % 2) == 1) {videoProperties.setHeight(w);videoProperties.setWidth(h);return videoProperties;}videoProperties.setHeight(h);videoProperties.setWidth(w);return videoProperties;}return null;} catch (Exception e) {log.error("获取视频基础信息出错.ossurl:{}, e:", ossUrl, e);return null;}}public static void main(String[] args) throws Exception {
//        VideoProperties videoPropertiesFromCos = getVideoPropertiesFromCos("/video/2024-05-30/723d5de3-f874-4744-819f-0a31e6e8e507.mp4");
//        System.out.println(videoPropertiesFromCos);byte[] bytes = CosUtils.downLoadBinary("http://fs.haha.com/video/2024-05-30/1484098659191754752.txt");System.out.println(new String(bytes));}
}

5.前端获取cos上传token

@Resource
private CosUtils cosUtils;@GetMapping("/token")
@ApiOperation("获取文件存储token")
public ApiResponse<?> getFileUploadToken(@RequestParam String fileFullPath) {if(StringUtils.isEmpty(fileFullPath)){return ApiResponse.error("参数错误");}return ApiResponse.ok(cosUtils.getUploadTemporaryToken(fileFullPath));
}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/845296.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

java微服在使用nacos注册中心时，ribbon负载均衡时给部分feign client使用静态serverList

java微服在使用nacos注册中心时，ribbon负载均衡时给部分feign client使用静态serverList

我看很多贴子都是针对eureka环境下做静态ServerList配置&#xff0c;目前国内大部分都用Nacos&#xff0c;所以便研究了一下。 micore-service-x:ribbon:listOfServers: ip1:port,ip2:port2NIWSServerListClassName: com.netflix.loadbalancer.ConfigurationBasedServerList m…
阅读更多...
Linux上传文件

Linux上传文件

在finalshell中连接的Linux系统中&#xff0c;输入命令rz然后选择windows中的文件即可。
阅读更多...
数据结构算法 数组的实现与练习(C语言实现,Java实现)

数据结构算法 数组的实现与练习(C语言实现,Java实现)

文章目录 数据结构数组(顺序表)特点使用Java实现更高级的数组C语言实现总结优点缺点 例题[26. 删除有序数组中的重复项](https://leetcode.cn/problems/remove-duplicates-from-sorted-array/)[1. 两数之和](https://leetcode.cn/problems/two-sum/)[27. 移除元素](https://lee…
阅读更多...
openfeign服务相互调用碰到问题总结

openfeign服务相互调用碰到问题总结

起因&#xff1a;服务A调用服务B&#xff0c;B中返回了数据&#xff0c;A服务没接收到。 经查发现是服务A中标注FeignClient的接口&#xff0c;数据类型和服务B的返回的类型不一样。 一、服务B RestController RequestMapping("/lanren312") public class Lanren3…
阅读更多...
破解生产难题，这些中小汽配企业这样做

破解生产难题，这些中小汽配企业这样做

伴随着汽车新四化即智能化、网联化、电动化、共享化的趋势,国内汽车零部件行业在市场规模和发展速度上呈现高速增长。然而&#xff0c;在劳动力成本上升,原材料价格上涨,企业生产成本逐年增加的情境下&#xff0c;市场竞争越来越激烈&#xff0c;如何降本增效&#xff0c;还能构…
阅读更多...
三十二篇：转化决策为行动：探索决策支持系统的深层价值

三十二篇：转化决策为行动：探索决策支持系统的深层价值

转化决策为行动&#xff1a;探索决策支持系统的深层价值 1. DSS的精髓&#xff1a;定义与核心功能 1.1 定义与作用 在现代商业的快速演变中&#xff0c;决策支持系统&#xff08;Decision Support Systems, DSS&#xff09;已成为企业获得竞争优势的重要工具。DSS是一种利用先…
阅读更多...
【R语言基础】如何更新R版本

【R语言基础】如何更新R版本

文章目录 概要流程细节具体步骤 概要 提示&#xff1a;由于软件包的更新&#xff0c;所以需要更新R至新版本 流程细节 查看当前R版本 R.version下载更新包&#xff1a;installr install.packages("installr")library(installr)跟着向导一步步执行安装 具体步骤 …
阅读更多...
HTML5的标签（文本链接、图片路径详解）

HTML5的标签（文本链接、图片路径详解）

目录 前言 一、文本链接 超链接表述 二、图片路径详解 绝对路径 相对路径 网络路径 前言 一、文本链接 超链接表述 HTML 使用标签<a>来设置超文本链接 超链接可以是一个字&#xff0c;一个词&#xff0c;或者一组词&#xff0c;也可以是一幅图像&#xff0c;…
阅读更多...
本地电脑通过远程服务器进行ssh远程转发

本地电脑通过远程服务器进行ssh远程转发

☆ 问题描述 想要实现这样一个事情&#xff1a; 我想要提供一个ai服务&#xff0c;但是租计算服务器太贵了&#xff0c;我自己有配的台式机。那么用我的台式机作为服务器&#xff0c;租一个服务器做端口转发可行吗&#xff1f; ★ 解决方案 1. 修改服务器上的sshd_config文件…
阅读更多...
大模型日报2024-05-31

大模型日报2024-05-31

大模型日报 2024-05-31 大模型资讯 Anthropic揭示Claude大语言模型的内部机制 摘要: 研究人员将大语言模型的活动模式与特定概念关联起来&#xff0c;并展示了他们可以通过调整这些模式来控制AI模型的行为。 Mistral AI开源新款代码语言模型Codestral 摘要: 人工智能初创公司Mi…
阅读更多...
如何格式化只读U盘？

如何格式化只读U盘？

U盘只读无法格式化&#xff0c;该怎么处理&#xff1f;别担心&#xff01;本文将向你提供一些实用方法&#xff0c;助你解决U盘写保护的难题。这些方法能有效帮助你解除U盘的只读状态&#xff0c;从而可以顺利进行格式化和其他操作。 不能格式化只读U盘 “我购买了一个U盘&…
阅读更多...
vmware esxi虚拟化数据迁移

vmware esxi虚拟化数据迁移

1、启用esxi的ssh 登录esxi的web界面&#xff0c;选择主机-》操作——》服务——》启动ssh 2.xshell登录esxi 3、找到虚拟机所在目录 blog.csdnimg.cn/direct/d57372536a4145f2bcc1189d02cc7da8.png)#### 3在传输数据前需关闭防火墙服务 查看防火墙状态&#xff1a;esxcli …
阅读更多...
系统架构设计师【第8章】: 系统质量属性与架构评估 (核心总结)

系统架构设计师【第8章】: 系统质量属性与架构评估 (核心总结)

文章目录 8.1　软件系统质量属性8.1.1　质量属性概念8.1.2　面向架构评估的质量属性8.1.3　质量属性场景描述 8.2　系统架构评估8.2.1　系统架构评估中的重要概念8.2.2　系统架构评估方法 8.3　ATAM方法架构评估实践8.3.1　阶段1—演示&#xff08;Presentation&#xff09;8.3…
阅读更多...
卷积网络迁移学习：实现思想与TensorFlow实践

卷积网络迁移学习：实现思想与TensorFlow实践

摘要&#xff1a;迁移学习是一种利用已有知识来改善新任务学习性能的方法。 在深度学习中&#xff0c;迁移学习通过迁移卷积网络&#xff08;CNN&#xff09;的预训练权重&#xff0c;实现了在新领域或任务上的高效学习。 下面我将详细介绍迁移学习的概念、实现思想&#xff0c…
阅读更多...
堆排序详细理解

堆排序详细理解

目录 一、前备知识 二、建堆 2.2.1 向上调整算法建堆 2.2.2 向下调整算法建堆 三、排序 3.1 常见问题 3.2 思路 3.3 源码 一、前备知识 详细图解请点击&#xff1a;二叉树的顺序实现-堆-CSDN博客 本文只附上向上/向下调整算法的源码 //交换 void Swap(int* p, int* …
阅读更多...
发电机组故障的原因、解决方案及解决措施

发电机组故障的原因、解决方案及解决措施

发电机组故障的原因、解决方案及解决措施可以总结如下&#xff1a; 一、故障原因 供电中断 原因&#xff1a;电网故障、线路短路或电力负荷过重等。 燃油问题 原因&#xff1a;燃油供应系统问题&#xff0c;如燃油管路堵塞、燃油质量不佳等。 轴承过热 原因&#xff1a;轴承过…
阅读更多...
TensorFlow Playground神经网络演示工具使用方法详解

TensorFlow Playground神经网络演示工具使用方法详解

在现代机器学习领域，神经网络无疑是一个重要的研究方向。然而，对于许多初学者来说，神经网络的概念和实际操作可能显得相当复杂。幸运的是，TensorFlow Playground 提供了一个交互式的在线工具，使得我们可以直观地理解和实验神经网络的基本原理。在这篇博客中，我们将详细介…
阅读更多...
长虹智能电视55D3P(机芯：ZLH74GiR2G)海思平台固件解析打包

长虹智能电视55D3P(机芯：ZLH74GiR2G)海思平台固件解析打包

一、使用Hitool打包固件 接上一篇&#xff0c;尝试使用HITOOL打包固件 长虹55D3P海思平台固件破解-CSDN博客 参考ZNDS HItool备份固件&#xff1a;【玩机必看】海思机顶盒备份线刷包 制作分区表xml文件_ZNDS刷机/救砖_ZNDS HITOOL下载&#xff1a;https://cloud.189.cn/web/…
阅读更多...
Visual Studio 2022创建dll并调用

Visual Studio 2022创建dll并调用

需求&#xff1a; 创建A项目&#xff0c;有函数和类&#xff0c;将A项目生成DLL动态链接库 创建B项目&#xff0c;使用A项目生成的dll和lib相关文件 正常项目开发.h用于函数声明&#xff0c;.cpp用于函数实现&#xff0c;但是项目开发往往不喜欢将.cpp函数实现的代码发给别人&…
阅读更多...
Elasticsearch 认证模拟题 - 5

Elasticsearch 认证模拟题 - 5

一、题目 .在集群上有一个索引 food_ingredient&#xff0c;搜索需要满足以下要求&#xff1a; 三个字段 manufacturer&#xff0c;name&#xff0c;brand 都能匹配到文本 cake mix高亮 字段 name&#xff0c;并加标签排序&#xff0c;对字段 brand 正序&#xff0c;_score 降…
阅读更多...
最新文章

Copyright @ 2022~2023