From 0627802cb019c38d310281c80fe5e35ca1b5369b Mon Sep 17 00:00:00 2001 From: Junling Bu Date: Fri, 10 Aug 2018 14:26:20 +0800 Subject: [PATCH] =?UTF-8?q?fix[litemall-core]:=20=E4=B8=83=E7=89=9B?= =?UTF-8?q?=E5=AD=98=E5=82=A8=E9=87=8C=E9=9D=A2=E7=9A=84=E4=B8=8A=E4=BC=A0?= =?UTF-8?q?=E5=87=AD=E8=AF=81=E5=AE=9E=E6=97=B6=E7=94=9F=E6=88=90?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../litemall/core/storage/QiniuStorage.java | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/litemall-core/src/main/java/org/linlinjava/litemall/core/storage/QiniuStorage.java b/litemall-core/src/main/java/org/linlinjava/litemall/core/storage/QiniuStorage.java index 1665018b..d5301728 100644 --- a/litemall-core/src/main/java/org/linlinjava/litemall/core/storage/QiniuStorage.java +++ b/litemall-core/src/main/java/org/linlinjava/litemall/core/storage/QiniuStorage.java @@ -21,7 +21,7 @@ public class QiniuStorage implements Storage { private String accessKey; private String secretKey; private String bucketName; - private String upToken; + private Auth auth; private UploadManager uploadManager; private BucketManager bucketManager; @@ -63,12 +63,14 @@ public class QiniuStorage implements Storage { @Override public void store(InputStream inputStream, long contentLength, String contentType, String keyName) { if(uploadManager == null){ + if(auth == null) { + auth = Auth.create(accessKey, secretKey); + } uploadManager = new UploadManager(new Configuration()); - Auth auth = Auth.create(accessKey, secretKey); - upToken = auth.uploadToken(bucketName); } try { + String upToken = auth.uploadToken(bucketName); Response response = uploadManager.put(inputStream, keyName, upToken, null, contentType); } catch (QiniuException ex) { ex.printStackTrace(); @@ -104,7 +106,9 @@ public class QiniuStorage implements Storage { @Override public void delete(String keyName) { if(bucketManager == null){ - Auth auth = Auth.create(accessKey, secretKey); + if(auth == null) { + auth = Auth.create(accessKey, secretKey); + } bucketManager = new BucketManager(auth, new Configuration() ); }