调整客户端获取方式

This commit is contained in:
2023-03-14 23:15:10 +08:00
parent a8bacd0517
commit 339b9d9d3d

View File

@@ -1,5 +1,6 @@
package com.njcn.huawei.obs.util; package com.njcn.huawei.obs.util;
import cn.hutool.core.util.StrUtil;
import com.njcn.huawei.obs.config.HuaweiObsProperties; import com.njcn.huawei.obs.config.HuaweiObsProperties;
import com.obs.services.ObsClient; import com.obs.services.ObsClient;
import com.obs.services.exception.ObsException; import com.obs.services.exception.ObsException;
@@ -105,28 +106,30 @@ public class OBSUtil {
/*** /***
* 获取文件上传后的url * 获取文件上传后的url
* 对象访问路径为https://桶名.域名/对象名。例如https://bucketname.obs.cn-north-4.myhuaweicloud.com/objectname
* @author hongawen * @author hongawen
* @date 2023/3/2 11:46 * @date 2023/3/2 11:46
*/ */
public String getFileUrl(String fileName) { public String getFileUrl(String fileName) {
ObsClient obsClient = null; return "https://" + huaweiObsProperties.getObs().getBucket() + StrUtil.DOT + huaweiObsProperties.getObs().getEndpoint() + StrUtil.SLASH + fileName;
try { // ObsClient obsClient = null;
obsClient = huaweiObsProperties.getInstance(); // try {
// URL有效期3600秒 // obsClient = huaweiObsProperties.getInstance();
Map<String, String> headers = new HashMap<>(); // // URL有效期3600秒
headers.put("Content-Type", "application/octet-stream"); // Map<String, String> headers = new HashMap<>();
TemporarySignatureRequest request = new TemporarySignatureRequest(HttpMethodEnum.PUT, huaweiObsProperties.getObs().getExpire()); // headers.put("Content-Type", "application/octet-stream");
request.setBucketName(huaweiObsProperties.getObs().getBucket()); // TemporarySignatureRequest request = new TemporarySignatureRequest(HttpMethodEnum.PUT, huaweiObsProperties.getObs().getExpire());
request.setObjectKey(fileName); // request.setBucketName(huaweiObsProperties.getObs().getBucket());
request.setHeaders(headers); // request.setObjectKey(fileName);
TemporarySignatureResponse response = obsClient.createTemporarySignature(request); // request.setHeaders(headers);
return response.getSignedUrl(); // TemporarySignatureResponse response = obsClient.createTemporarySignature(request);
} catch (Exception e) { // return response.getSignedUrl();
log.error("获取上传地址异常:{}", e.getMessage(), e); // } catch (Exception e) {
} finally { // log.error("获取上传地址异常:{}", e.getMessage(), e);
huaweiObsProperties.destroy(obsClient); // } finally {
} // huaweiObsProperties.destroy(obsClient);
return null; // }
// return null;
} }
/*** /***