|
|
@ -8,7 +8,9 @@ |
|
|
|
|
|
|
|
package com.epmet.cloud; |
|
|
|
|
|
|
|
import com.aliyun.oss.OSS; |
|
|
|
import com.aliyun.oss.OSSClient; |
|
|
|
import com.aliyun.oss.OSSClientBuilder; |
|
|
|
import com.aliyun.oss.model.DownloadFileRequest; |
|
|
|
import com.aliyun.oss.model.DownloadFileResult; |
|
|
|
import com.epmet.commons.tools.exception.RenException; |
|
|
@ -26,12 +28,8 @@ import java.io.InputStream; |
|
|
|
*/ |
|
|
|
public class AliyunCloudStorageService extends AbstractCloudStorageService { |
|
|
|
|
|
|
|
private OSSClient internalClient = null; |
|
|
|
private OSSClient externalClient = null; |
|
|
|
|
|
|
|
{ |
|
|
|
|
|
|
|
} |
|
|
|
private OSS internalClient = null; |
|
|
|
private OSS externalClient = null; |
|
|
|
|
|
|
|
public AliyunCloudStorageService(CloudStorageConfig config){ |
|
|
|
this.config = config; |
|
|
@ -43,11 +41,11 @@ public class AliyunCloudStorageService extends AbstractCloudStorageService { |
|
|
|
* @author wxz |
|
|
|
* @date 2021.01.04 13:49 |
|
|
|
*/ |
|
|
|
public OSSClient getOssClient(String privacyType) { |
|
|
|
public OSS getOssClient(String privacyType) { |
|
|
|
if (PrivacyType.INTERNAL.equalsIgnoreCase(privacyType)) { |
|
|
|
if (internalClient == null){ |
|
|
|
CloudStorageConfig.AliyunCloudStorageConfigProps props = config.getAliyun().getInternal(); |
|
|
|
internalClient = new OSSClient(props.getAliyunEndPoint(), props.getAliyunAccessKeyId(), |
|
|
|
internalClient = new OSSClientBuilder().build(props.getAliyunEndPoint(), props.getAliyunAccessKeyId(), |
|
|
|
props.getAliyunAccessKeySecret()); |
|
|
|
} |
|
|
|
return internalClient; |
|
|
@ -100,7 +98,7 @@ public class AliyunCloudStorageService extends AbstractCloudStorageService { |
|
|
|
@Override |
|
|
|
public String upload(InputStream inputStream, String path, String privacyType) { |
|
|
|
CloudStorageConfig.AliyunCloudStorageConfigProps props = getPropsByprivacyType(privacyType); |
|
|
|
OSSClient client = getOssClient(privacyType); |
|
|
|
OSS client = getOssClient(privacyType); |
|
|
|
try { |
|
|
|
client.putObject(props.getAliyunBucketName(), path, inputStream); |
|
|
|
//client.shutdown();
|
|
|
@ -114,7 +112,7 @@ public class AliyunCloudStorageService extends AbstractCloudStorageService { |
|
|
|
@Override |
|
|
|
public boolean delete(String objectName,String privacyType) { |
|
|
|
CloudStorageConfig.AliyunCloudStorageConfigProps props = getPropsByprivacyType(privacyType); |
|
|
|
OSSClient client = getOssClient(privacyType); |
|
|
|
OSS client = getOssClient(privacyType); |
|
|
|
try { |
|
|
|
client.deleteObject(props.getAliyunBucketName(), objectName); |
|
|
|
//client.shutdown();
|
|
|
@ -140,7 +138,7 @@ public class AliyunCloudStorageService extends AbstractCloudStorageService { |
|
|
|
@Override |
|
|
|
public void down(String privacyType) throws IOException { |
|
|
|
CloudStorageConfig.AliyunCloudStorageConfigProps props = getPropsByprivacyType(privacyType); |
|
|
|
OSSClient client = getOssClient(privacyType); |
|
|
|
OSS client = getOssClient(privacyType); |
|
|
|
try { |
|
|
|
|
|
|
|
/* |
|
|
|