From 90da0ce9d7135b8d465f0d571ddd65a74269b0c1 Mon Sep 17 00:00:00 2001 From: xin <1099200748@qq.com> Date: Wed, 25 Jun 2025 00:33:30 +0800 Subject: [PATCH] 补充ObsClient使用后关闭 --- oying-tools/src/main/java/com/oying/utils/ObsUtils.java | 12 ++++++++---- 1 files changed, 8 insertions(+), 4 deletions(-) diff --git a/oying-tools/src/main/java/com/oying/utils/ObsUtils.java b/oying-tools/src/main/java/com/oying/utils/ObsUtils.java index 9b98a33..349c1d3 100644 --- a/oying-tools/src/main/java/com/oying/utils/ObsUtils.java +++ b/oying-tools/src/main/java/com/oying/utils/ObsUtils.java @@ -36,9 +36,9 @@ * @return PutObjectResult */ public static PutObjectResult putObject(ObsProperties properties, File file, String objectKey, AccessControlList acl) { + // 创建ObsClient实例 + ObsClient obsClient = getObsClient(properties); try { - // 创建ObsClient实例 - ObsClient obsClient = getObsClient(properties); PutObjectRequest request = new PutObjectRequest(); request.setBucketName(properties.getBucket()); request.setObjectKey(objectKey); @@ -51,6 +51,7 @@ throw new BadRequestException("上传对象失败" + e.getMessage()); } finally { FileUtil.del(file); + CloseUtil.close(obsClient); } } @@ -63,15 +64,16 @@ * @return PutObjectResult */ public static PutObjectResult putObject(ObsProperties properties, File file, String objectKey) { + // 创建ObsClient实例 + ObsClient obsClient = getObsClient(properties); try { - // 创建ObsClient实例 - ObsClient obsClient = getObsClient(properties); // 为待上传的本地文件路径,需要指定到具体的文件名 return obsClient.putObject(properties.getBucket(), objectKey, file); } catch (Exception e) { throw new BadRequestException("上传对象失败" + e.getMessage()); } finally { FileUtil.del(file); + CloseUtil.close(obsClient); } } @@ -107,6 +109,7 @@ } finally { CloseUtil.close(in); CloseUtil.close(out); + CloseUtil.close(obsClient); } } return path; @@ -123,6 +126,7 @@ ObsClient obsClient = getObsClient(properties); // 删除指定的对象 obsClient.deleteObject(properties.getBucket(), objectKey); + CloseUtil.close(obsClient); } public static String getPublicObjectUrl(ObsProperties properties, String objectKey) { -- Gitblit v1.9.3