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