//package com.stylefeng.guns.modular.system.util.qianyuntong;
|
//
|
//import com.heredata.hos.HOS;
|
//import com.heredata.hos.HOSClientBuilder;
|
//import com.heredata.hos.model.CreateBucketRequest;
|
//import com.heredata.hos.model.HOSObject;
|
//import com.heredata.hos.model.PutObjectRequest;
|
//import com.heredata.hos.model.PutObjectResult;
|
//import com.heredata.hos.model.bucket.Bucket;
|
//import com.heredata.model.VoidResult;
|
//import lombok.extern.slf4j.Slf4j;
|
//
|
//import java.io.InputStream;
|
//
|
///**
|
// * OSS 工具类
|
// * @author zhibing.pu
|
// * @Date 2025/6/23 17:50
|
// */
|
//@Slf4j
|
//public class NCOSSUtil {
|
//
|
// /**
|
// * 创建桶
|
// * @param bucketName
|
// * @return
|
// */
|
// public static Boolean createBucket(String bucketName) {
|
// /**
|
// * endPoint：HOS的基础路径(公共前缀)
|
// * account：账户的ID
|
// * accessKey：向UAAS服务请求到的access_key
|
// * secretKey：向UAAS服务请求到的secret_key
|
// */
|
// HOS hos = new HOSClientBuilder().build(QianYunTongProperties.endPoint, QianYunTongProperties.account, QianYunTongProperties.accessKey, QianYunTongProperties.secretKey);
|
// try {
|
// // 创建请求对象，并且设置创建桶名为"example"的桶
|
// CreateBucketRequest createBucketRequest = new CreateBucketRequest(bucketName);
|
// VoidResult result = hos.createBucket(createBucketRequest);
|
// if (result.getResponse().isSuccessful()) {
|
// log.info("创建桶成功：" + bucketName);
|
// return true;
|
// }
|
// } catch (Exception e){
|
// log.info("创建桶失败：" + bucketName);
|
// e.printStackTrace();
|
// }
|
// return false;
|
// }
|
//
|
//
|
// /**
|
// * 查询桶详情
|
// * @param bucketName
|
// * @return
|
// */
|
// public static Bucket getBucketInfo(String bucketName) {
|
// /**
|
// * endPoint：HOS的基础路径(公共前缀)
|
// * account：账户的ID
|
// * accessKey：向UAAS服务请求到的access_key
|
// * secretKey：向UAAS服务请求到的secret_key
|
// */
|
// HOS hos = new HOSClientBuilder().build(QianYunTongProperties.endPoint, QianYunTongProperties.account, QianYunTongProperties.accessKey, QianYunTongProperties.secretKey);
|
// try {
|
// // 查询桶名为"example"的详情
|
// Bucket bucket = hos.getBucketInfo(bucketName);
|
// return bucket;
|
// } catch (Exception e){
|
// e.printStackTrace();
|
// }
|
// return null;
|
// }
|
//
|
//
|
// /**
|
// * 删除桶
|
// * @param bucketName
|
// * @return
|
// */
|
// public static Boolean deleteBucket(String bucketName) {
|
// /**
|
// * endPoint：HOS的基础路径(公共前缀)
|
// * account：账户的ID
|
// * accessKey：向UAAS服务请求到的access_key
|
// * secretKey：向UAAS服务请求到的secret_key
|
// */
|
// HOS hos = new HOSClientBuilder().build(QianYunTongProperties.endPoint, QianYunTongProperties.account, QianYunTongProperties.accessKey, QianYunTongProperties.secretKey);
|
// try {
|
// VoidResult result = hos.deleteBucket(bucketName);
|
// if (result.getResponse().isSuccessful()) {
|
// log.info("删除桶成功：" + bucketName);
|
// return true;
|
// }
|
// } catch (Exception e){
|
// log.info("删除桶成功：" + bucketName);
|
// e.printStackTrace();
|
// }
|
// return false;
|
// }
|
//
|
//
|
// /**
|
// * 设置桶策略
|
// * @param bucketName 桶名
|
// * @param policyText 策略规则字符串
|
// * {
|
// * // 策略配置的版本号，由用户定义
|
// * "Version": "2012-10-17",
|
// * // 策略规则配置，可指定多条策略规则
|
// * "Statement": [{
|
// * // 策略规则ID，可用户指定，如不指定则服务自动生成一条
|
// * "Sid": "sid",
|
// * // 策略规则指定的HOS API接口标识，可参照下表填写
|
// * "Action": [
|
// * "action"
|
// * ],
|
// * // 策略规则效果，具体表现为允许或拒绝，有效值为Allow（允许），Deny（拒绝）；
|
// * "Effect": "Allow",
|
// * // 策略规则指定的资源参照下面resource配置
|
// * "Resource": "resource",
|
// * // 策略规则指定的授权人 参照下面Principal配置
|
// * "Principal": {
|
// * "HWS": [
|
// * "account_id:root"
|
// * ]
|
// * }
|
// * }
|
// * ]
|
// * }
|
// * @return
|
// */
|
// public static Boolean setBucketPolicy(String bucketName, String policyText) {
|
// /**
|
// * endPoint：HOS的基础路径(公共前缀)
|
// * account：账户的ID
|
// * accessKey：向UAAS服务请求到的access_key
|
// * secretKey：向UAAS服务请求到的secret_key
|
// */
|
// HOS hos = new HOSClientBuilder().build(QianYunTongProperties.endPoint, QianYunTongProperties.account, QianYunTongProperties.accessKey, QianYunTongProperties.secretKey);
|
// // 桶策略字符串
|
// try {
|
// VoidResult result = hos.setBucketPolicy(bucketName, policyText);
|
// if (result.getResponse().isSuccessful()) {
|
// log.info("设置桶策略成功：" + bucketName);
|
// return true;
|
// }
|
// } catch (Exception e) {
|
// log.info("设置桶策略失败：" + bucketName);
|
// e.printStackTrace();
|
// }
|
// return false;
|
// }
|
//
|
//
|
// /**
|
// * 上传对象
|
// * @param bucketName 桶名称
|
// * @param key 存储文件名
|
// * @param inputStream 上传文件流
|
// * @return 对象唯一标识
|
// */
|
// public static String putObject(String bucketName, String key, InputStream inputStream) {
|
// /**
|
// * endPoint：HOS的基础路径(公共前缀)
|
// * account：账户的ID
|
// * accessKey：向UAAS服务请求到的access_key
|
// * secretKey：向UAAS服务请求到的secret_key
|
// */
|
// HOS hos = new HOSClientBuilder().build(QianYunTongProperties.endPoint, QianYunTongProperties.account, QianYunTongProperties.accessKey, QianYunTongProperties.secretKey);
|
// try {
|
// PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, key , inputStream);
|
// PutObjectResult example = hos.putObject(putObjectRequest);
|
// if (example.getResponse().isSuccessful()) {
|
// log.info("上传对象成功：" + bucketName + "--->" + key);
|
// return example.getETag();
|
// }
|
// } catch (Exception e) {
|
// log.info("上传对象成功：" + bucketName);
|
// e.printStackTrace();
|
// }
|
// return null;
|
// }
|
//
|
//
|
// /**
|
// * 查询对象
|
// * @param bucketName 桶名称
|
// * @param key 存储文件名
|
// * @return
|
// */
|
// public static HOSObject getObject(String bucketName, String key) {
|
// /**
|
// * endPoint：HOS的基础路径(公共前缀)
|
// * account：账户的ID
|
// * accessKey：向UAAS服务请求到的access_key
|
// * secretKey：向UAAS服务请求到的secret_key
|
// */
|
// HOS hos = new HOSClientBuilder().build(QianYunTongProperties.endPoint, QianYunTongProperties.account, QianYunTongProperties.accessKey, QianYunTongProperties.secretKey);
|
// try {
|
// HOSObject example = hos.getObject(bucketName, key);
|
// if (example.getResponse().isSuccessful()) {
|
// log.info("查询对象成功：" + bucketName + "--->" + key);
|
// return example;
|
// }
|
// } catch (Exception e) {
|
// log.info("查询对象失败：" + bucketName);
|
// e.printStackTrace();
|
// }
|
// return null;
|
// }
|
//
|
//
|
// /**
|
// * 删除对象
|
// * @param bucketName 桶名称
|
// * @param key 存储文件名
|
// * @return
|
// */
|
// public static Boolean deleteObject(String bucketName, String key) {
|
// /**
|
// * endPoint：HOS的基础路径(公共前缀)
|
// * account：账户的ID
|
// * accessKey：向UAAS服务请求到的access_key
|
// * secretKey：向UAAS服务请求到的secret_key
|
// */
|
// HOS hos = new HOSClientBuilder().build(QianYunTongProperties.endPoint, QianYunTongProperties.account, QianYunTongProperties.accessKey, QianYunTongProperties.secretKey);
|
// try {
|
// VoidResult example = hos.deleteObject(bucketName, key);
|
// if (example.getResponse().isSuccessful()) {
|
// log.info("删除对象成功：" + bucketName + "--->" + key);
|
// return true;
|
// }
|
// } catch (Exception e) {
|
// log.info("删除对象失败：" + bucketName + "--->" + key);
|
// e.printStackTrace();
|
// }
|
// return false;
|
// }
|
//}
|
