JAVA 对象存储OSS工具类(腾讯云)

对象存储OSS工具类

在这里插入图片描述

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.model.ObjectMetadata;
import com.qcloud.cos.model.PutObjectRequest;
import com.qcloud.cos.model.PutObjectResult;
import com.qcloud.cos.model.ciModel.persistence.PicOperations;
import com.qcloud.cos.region.Region;
import com.wangyao.common.config.TencentOssConfig;
import jakarta.validation.constraints.NotNull;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.apache.http.HttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.conn.ssl.NoopHostnameVerifier;
import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
import org.apache.http.conn.ssl.TrustSelfSignedStrategy;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.ssl.SSLContexts;
import org.springframework.web.multipart.MultipartFile;import java.io.InputStream;
import java.util.LinkedList;
import java.util.List;@Slf4j
public class CosUtil {private static final TencentOssConfig CONFIG;private static final String RULE_STR = "imageMogr2/format/webp";private static final String EXT = "^(jpg|jpeg|png|gif)$";public static final int INT = 1024;static {CONFIG = SpringUtil.getBean(TencentOssConfig.class);}@NotNullprivate static COSClient createCosClient() {COSCredentials cred = new BasicCOSCredentials(CONFIG.getSecretId(), CONFIG.getSecretKey());ClientConfig clientConfig = new ClientConfig();clientConfig.setRegion(new Region(CONFIG.getRegion()));return new COSClient(cred, clientConfig);}/*** 上传OSS 自定义 Key** @param inputStream 文件流* @param key         key* @return String*/@SuppressWarnings("unused")public static String upOssByKey(InputStream inputStream, String key, String fileName) {return upOssByKey(inputStream, key, CONFIG.getBucket(), fileName);}/*** 上传OSS 自定义 Key** @param inputStream 文件流* @param key         key* @param bucket      桶名* @return String*/public static String upOssByKey(InputStream inputStream, String key, String bucket, String fileName) {return upOss(inputStream, null, key, bucket, fileName);}/*** 上传OSS** @param inputStream 文件流* @param keyPrefix   key前缀* @return String*/@NotNullpublic static String upOss(InputStream inputStream, String keyPrefix, String fileName) {return upOss(inputStream, keyPrefix, CONFIG.getBucket(), fileName);}/*** 上传OSS** @param file      文件* @param keyPrefix key前缀* @return String*/public static String upOss(MultipartFile file, String keyPrefix, String fileName) {return upOss(file, keyPrefix, null, CONFIG.getBucket(), fileName);}/*** 上传OSS** @param inputStream 文件流* @param keyPrefix   key前缀* @param bucket      桶名* @return String*/public static String upOss(InputStream inputStream, String keyPrefix, String bucket, String fileName) {return upOss(inputStream, keyPrefix, null, bucket, fileName);}@NotNull@SuppressWarnings("unused")public static String upOssKey(InputStream inputStream, String keyPrefix, String key, String fileName) {return upOss(inputStream, keyPrefix, key, CONFIG.getBucket(), fileName);}/*** 上传网络图片到OSS* @param url 网络路径* @return String*/public static String upOss(String url, String keyPrefix, String fileName) {try {SSLConnectionSocketFactory scsf = new SSLConnectionSocketFactory(SSLContexts.custom().loadTrustMaterial(null, new TrustSelfSignedStrategy()).build(), NoopHostnameVerifier.INSTANCE);try (CloseableHttpClient client = HttpClients.custom().setSSLSocketFactory(scsf).build();) {HttpGet httpget = new HttpGet(url);HttpResponse response = client.execute(httpget);return upOss(response.getEntity().getContent(), keyPrefix, CONFIG.getBucket(), fileName);}} catch (Exception e) {log.error("上传网络图片到OSS失败:", e);}return null;}private static String upOss(InputStream inputStream, String keyPrefix, String key, String bucket, @NotNull String fileName) {var cosClient = createCosClient();var compressPath = "https://455.cos.ap-beijing.myqcloud.com/";key = getString(keyPrefix, key, fileName);log.info("key={}", key);String type = fileName.substring(fileName.lastIndexOf(".") + 1);ObjectMetadata objectMetadata = new ObjectMetadata();objectMetadata.setContentType(type);try {PutObjectRequest putObjectRequest = new PutObjectRequest(bucket, key, inputStream, objectMetadata);if (type.toLowerCase().matches(EXT)) {extracted(bucket, fileName, putObjectRequest);}PutObjectResult putObjectResult = cosClient.putObject(putObjectRequest);String eTag = putObjectResult.getETag();log.info("eTag = {}", eTag);cosClient.shutdown();} catch (Exception e) {log.error("Cos Upload Failed. ", e);}String result = compressPath + key;log.info("Cos Upload Path: {}", result);return result;}private static String getString(String keyPrefix, String key, String fileName) {if (StringUtils.isBlank(key)) {key = StringUtils.isNotBlank(keyPrefix) ? keyPrefix + fileName : fileName;}return key;}private static void extracted(String bucket, String fileName, PutObjectRequest putObjectRequest) {//如果图片比较大就进行压缩。否则就直接上传PicOperations picOperations = new PicOperations();// 添加图片处理规则List<PicOperations.Rule> ruleList = new LinkedList<>();PicOperations.Rule rule = new PicOperations.Rule();rule.setBucket(bucket);rule.setFileId(fileName);rule.setRule(RULE_STR);ruleList.add(rule);picOperations.setRules(ruleList);putObjectRequest.setPicOperations(picOperations);}@SuppressWarnings("all")private static String upOss(@NotNull MultipartFile file, String keyPrefix, String key, String bucket, String fileName) {COSClient cosClient = createCosClient();String compressPath = "https://455.cos.ap-beijing.myqcloud.com/";key = getString(keyPrefix, key, fileName);log.info("key={}", key);String type = fileName.substring(fileName.lastIndexOf(".") + 1);ObjectMetadata objectMetadata = new ObjectMetadata();objectMetadata.setContentType(type);try {PutObjectRequest putObjectRequest = new PutObjectRequest(bucket, key, file.getInputStream(), objectMetadata);if (type.toLowerCase().matches(EXT)) {//如果图片比较大就进行压缩。否则就直接上传if (file.getSize() > INT * INT) {extracted(bucket, fileName, putObjectRequest);}}PutObjectResult putObjectResult = cosClient.putObject(putObjectRequest);String eTag = putObjectResult.getETag();log.info("eTag = {}", eTag);cosClient.shutdown();} catch (Exception e) {log.error("Cos Upload Failed. ", e);}String result = compressPath + key;log.info("Cos Upload Path: {}", result);return result;}}

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

如若内容造成侵权/违法违规/事实不符,请联系一条长河网进行投诉反馈,一经查实,立即删除!

相关文章

重塑通信边界,基于ZYNQ7000 FPGA驱动的多频段多协议软件无线电平台

01、产品概述 本平台是基于高性能ZYNQ-7000系列中的XC7Z045处理器构建的多频段多协议软件无线电解决方案&#xff0c;集成了AD9364芯片——一款业界领先的1x1通道RF敏捷收发器&#xff0c;为无线通信应用提供了强大支持。其存储架构包括2路高速4GB DDR3内存、1路32GB EMMC存储以…

龙迅#LT8642UXE适用于四路HDMI转两路HDMI切换应用功能,分辨率高达4K60HZ!

1. 概述 LT8642UXE HD-DVI2.0/1.4 交换机具有符合 HD-DVI2.0/1.4 规范的 4&#xff1a;2 交换机、最大 6Gbps 高速数据速率、自适应均衡接收输入和预加重 TX 输出&#xff0c;以支持长电缆应用。 LT8642UXE HD-DVI2.0/1.4 开关自动检测电缆损耗&#xff0c;并自适应优化均衡设置…

第二轮复习 408 操作系统(概述)

第二轮复习 408 操作系统&#xff08;概述&#xff09; 操作系统的概述操作系统的目标与特征操作系统发展历程 操作系统的运行环境处理器运行模式中断和异常的概念系统调用操作系统结构操作系统引导 操作系统的概述 操作系统是控制和管理整个计算机系统的硬件与软件管理整个计…

JMH320【亲测】【御剑九歌】唯美仙侠手游御剑九歌+WIN学习手工端+视频教程+开服清档+运营后台+授权GM物品充值后台

资源介绍&#xff1a; 这也是仙梦奇缘的一个游戏 注意&#xff1a;外网14位IP或域名 ———————————————————————————————————– ps后台介绍: 1区运营后台&#xff1a;http://ip:9981/admin/admintool/ 2区运营后台&#xff1a;http://ip…

识别 Spring Cloud 配置文件的规则:Nacos, Bootstrap, Application

个人名片 &#x1f393;作者简介&#xff1a;java领域优质创作者 &#x1f310;个人主页&#xff1a;码农阿豪 &#x1f4de;工作室&#xff1a;新空间代码工作室&#xff08;提供各种软件服务&#xff09; &#x1f48c;个人邮箱&#xff1a;[2435024119qq.com] &#x1f4f1…

redis哨兵系统框架部署

redsi主从配置 下面是基于redis主从的环境部署哨兵模式 1、在配置好redis主从后&#xff0c;添加哨兵模式需要在sentinel.conf文件添加一条命令(主从节点都需要添加) mymaster 是主节点的别名。192.168.25.129 是主节点的 IP。6379 是主节点的端口。2 是仲裁值&#xff0c;表…

遗漏知识点

什么是RAII&#xff1f; RAII是Resource Acquisition Is Initialization&#xff08;wiki上面翻译成 “资源获取就是初始化”&#xff09;的简称&#xff0c;是C语言的一种管理资源、避免泄漏的惯用法。利用的就是C构造的对象最终会被销毁的原则。RAII的做法是使用一个对象&am…

Day05-组织架构-角色管理

提示&#xff1a;文章写完后&#xff0c;目录可以自动生成&#xff0c;如何生成可参考右边的帮助文档 文章目录 1.组织架构-编辑部门-弹出层获取数据2.组织架构-编辑部门-编辑表单校验3.组织架构-编辑部门-确认取消4.组织架构-删除部门5.角色管理-搭建页面结构6.角色管理-获取数…

网络数据传输中的封装与解封装详解

注&#xff1a;机翻&#xff0c;未校对。 The goal of networks is to transmit data from one host to another. 网络的目标是将数据从一个主机传输到另一个主机。 Encapsulation 封装 To achieve this goal, each layer adds its own header to the data. A header contain…

Vue2基础 14:自定义指令

自定义指令 1 函数式1.1 案例--v-text放大10倍 2 对象式2.1 案例--v-fbind默认获取焦点&#xff08;函数式&#xff09;2.2 案例--v-fbind默认获取焦点&#xff08;对象式&#xff09; 3 自定义指令容易犯的错4 全局指令写法&#xff08;参考过滤器写法&#xff09;&#xff1a…

跟《经济学人》学英文:2024年07月06日这期 Central banks are winning the battle against inflation

Central banks are winning the battle against inflation. But the war is just getting started Politics and protectionism will make life difficult 原文&#xff1a; The trajectory of inflation has not given central bankers much cause for celebration in rece…

android2024 gradle8 Processor和ksp两种编译时注解实现

android编译时注解&#xff0c;老生常谈&#xff0c;外面的例子都是bindView&#xff0c;脑壳看疼了&#xff0c;自己学习和编写下。 而且现在已经进化到kotlin2.0&#xff0c;google也逐渐放弃kapt&#xff0c;进入维护状态。所以要好好看看本贴。 参考我的工程&#xff1a; h…

gda动态调试-cnblog

忽的发现gda有动态调试功能 动态监听返回值 框柱指定方法&#xff0c;选择调试方法&#xff0c;gda会自动监听函数的返回值&#xff0c;例如 自定义frida脚本 gda会自动生成hook该函数的frida脚本

zigbee笔记:六、看门狗定时器(Watch Dog)

一、看门狗基础 1、看门狗功能&#xff1a; 由于单片机的工作常常会受到来自外界电磁场的干扰&#xff0c;造成各种寄存器和内存的数据混乱&#xff0c;会导致程序指针错误等&#xff0c;程序运行可能会陷入死循环。程序的正常运行被打断&#xff0c;由单片机控制的系统无法继…

kafka系列之消费后不提交offset情况的分析总结

概述 每当我们调用Kafka的poll()方法或者使用KafkaListener(其实底层也是poll()方法)时&#xff0c;它都会返回之前被写入Kafka的记录&#xff0c;即我们组中的消费者还没有读过的记录。 这意味着我们有一种方法可以跟踪该组消费者读取过的记录。 如前所述&#xff0c;Kafka的一…

【面向就业的Linux基础】从入门到熟练,探索Linux的秘密(十)-git(2)

下面是一些git的常用命令和基本操作&#xff0c;可以当做平常的笔记查询&#xff0c;用于学习&#xff01;&#xff01;&#xff01; 文章目录 前言 一、git 二、git常用命令 总结 前言 下面是一些git的常用命令和基本操作&#xff0c;可以当做平常的笔记查询&#xff0c;用于…

解决前后端同一个端口跨域问题

前端起了一个代理 如果url是api开头的自动代理访问8080端口&#xff08;解决前后端端口不一致要么是前端代理&#xff0c;要么是后端加过滤器&#xff09; proxy:{/api:{target:http://localhost:8080,changeOrigin : true,// 替换去掉路径上的api// rewrite:(path)>path.r…

配置基于不同端口的虚拟主机

更改配置文件&#xff0c;添加三个不同端口的虚拟主机 <directory /www> allowoverride none require all granted </directory><virtualhost 192.168.209.136:80> documentroot /www servername 192.168.209.136 </virtualhost><virtualhost 192.…

【python基础】—如何理解安装程序时要配置Widows和DOS操作系统中的path环境变量?

文章目录 前言一、环境变量是什么&#xff1f;二、为什么需要设置环境变量&#xff1f;三、配置anaconda的环境变量 前言 在安装一些程序的时候&#xff0c; 我们总是需要将安装路径配置到正在使用电脑的环境变量里。为什么要进行这一步呢&#xff1f;本文主要解释Widows和DOS…

【后端面试题】【中间件】【NoSQL】MongoDB查询优化2(优化排序、mongos优化)

优化排序 在MongoDB里面&#xff0c;如果能够利用索引来排序的话&#xff0c;直接按照索引顺序加载数据就可以了。如果不能利用索引来排序的话&#xff0c;就必须在加载了数据之后&#xff0c;再次进行排序&#xff0c;也就是进行内存排序。 可想而知&#xff0c;如果内存排序…