| ÎļþÃû´Ó ruoyi-oss/src/main/java/com/ruoyi/oss/service/impl/AliyunCloudStorageServiceImpl.java ÐÞ¸Ä |
| | |
|---|
| | | package com.ruoyi.oss.service.impl; |
|---|
| | | |
|---|
| | | import com.ruoyi.common.utils.StringUtils; |
|---|
| | | import com.aliyun.oss.ClientConfiguration; |
|---|
| | | import com.aliyun.oss.OSSClient; |
|---|
| | | import com.aliyun.oss.common.auth.DefaultCredentialProvider; |
|---|
| | |
|---|
| | | import com.aliyun.oss.model.CreateBucketRequest; |
|---|
| | | import com.aliyun.oss.model.ObjectMetadata; |
|---|
| | | import com.aliyun.oss.model.PutObjectRequest; |
|---|
| | | import com.ruoyi.common.utils.StringUtils; |
|---|
| | | import com.ruoyi.oss.entity.UploadResult; |
|---|
| | | import com.ruoyi.oss.enumd.CloudServiceEnumd; |
|---|
| | | import com.ruoyi.oss.exception.OssException; |
|---|
| | | import com.ruoyi.oss.factory.OssFactory; |
|---|
| | | import com.ruoyi.oss.properties.CloudStorageProperties; |
|---|
| | | import com.ruoyi.oss.properties.CloudStorageProperties.AliyunProperties; |
|---|
| | | import com.ruoyi.oss.service.abstractd.AbstractCloudStorageService; |
|---|
| | | import org.springframework.beans.factory.InitializingBean; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.context.annotation.Lazy; |
|---|
| | | import org.springframework.stereotype.Service; |
|---|
| | | import com.ruoyi.oss.service.abstractd.AbstractCloudStorageStrategy; |
|---|
| | | |
|---|
| | | import java.io.ByteArrayInputStream; |
|---|
| | | import java.io.InputStream; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * é¿éäºåå¨ |
|---|
| | | * é¿éäºåå¨çç¥ |
|---|
| | | * |
|---|
| | | * @author Lion Li |
|---|
| | | */ |
|---|
| | | @Lazy |
|---|
| | | @Service |
|---|
| | | public class AliyunCloudStorageServiceImpl extends AbstractCloudStorageService implements InitializingBean { |
|---|
| | | public class AliyunCloudStorageStrategy extends AbstractCloudStorageStrategy { |
|---|
| | | |
|---|
| | | private final OSSClient client; |
|---|
| | | private final AliyunProperties properties; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | public AliyunCloudStorageServiceImpl(CloudStorageProperties properties) { |
|---|
| | | this.properties = properties.getAliyun(); |
|---|
| | | public AliyunCloudStorageStrategy(CloudStorageProperties cloudStorageProperties) { |
|---|
| | | properties = cloudStorageProperties; |
|---|
| | | try { |
|---|
| | | ClientConfiguration configuration = new ClientConfiguration(); |
|---|
| | | DefaultCredentialProvider credentialProvider = new DefaultCredentialProvider( |
|---|
| | | this.properties.getAccessKeyId(), |
|---|
| | | this.properties.getAccessKeySecret()); |
|---|
| | | client = new OSSClient(this.properties.getEndpoint(), credentialProvider, configuration); |
|---|
| | | properties.getAccessKey(), properties.getSecretKey()); |
|---|
| | | client = new OSSClient(properties.getEndpoint(), credentialProvider, configuration); |
|---|
| | | createBucket(); |
|---|
| | | } catch (Exception e) { |
|---|
| | | throw new IllegalArgumentException("é¿éäºåå¨é
ç½®é误! 请æ£æ¥ç³»ç»é
ç½®!"); |
|---|
| | |
|---|
| | | @Override |
|---|
| | | public UploadResult uploadSuffix(InputStream inputStream, String suffix, String contentType) { |
|---|
| | | return upload(inputStream, getPath(properties.getPrefix(), suffix), contentType); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public void afterPropertiesSet() throws Exception { |
|---|
| | | OssFactory.register(getServiceType(), this); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
