| 文件名从 ruoyi-oss/src/main/java/com/ruoyi/oss/service/impl/MinioCloudStorageServiceImpl.java 修改 |
| | |
|---|
| | | import com.ruoyi.oss.enumd.CloudServiceEnumd; |
|---|
| | | import com.ruoyi.oss.enumd.PolicyType; |
|---|
| | | import com.ruoyi.oss.exception.OssException; |
|---|
| | | import com.ruoyi.oss.factory.OssFactory; |
|---|
| | | import com.ruoyi.oss.properties.CloudStorageProperties; |
|---|
| | | import com.ruoyi.oss.properties.CloudStorageProperties.MinioProperties; |
|---|
| | | import com.ruoyi.oss.service.abstractd.AbstractCloudStorageService; |
|---|
| | | import com.ruoyi.oss.service.abstractd.AbstractCloudStorageStrategy; |
|---|
| | | import io.minio.*; |
|---|
| | | import org.springframework.beans.factory.InitializingBean; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.context.annotation.Lazy; |
|---|
| | | import org.springframework.http.MediaType; |
|---|
| | | import org.springframework.stereotype.Service; |
|---|
| | | |
|---|
| | | import java.io.ByteArrayInputStream; |
|---|
| | | import java.io.InputStream; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * minio瀛樺偍 |
|---|
| | | * minio瀛樺偍绛栫暐 |
|---|
| | | * |
|---|
| | | * @author Lion Li |
|---|
| | | */ |
|---|
| | | @Lazy |
|---|
| | | @Service |
|---|
| | | public class MinioCloudStorageServiceImpl extends AbstractCloudStorageService implements InitializingBean { |
|---|
| | | public class MinioCloudStorageStrategy extends AbstractCloudStorageStrategy { |
|---|
| | | |
|---|
| | | private final MinioClient minioClient; |
|---|
| | | private final MinioProperties properties; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | public MinioCloudStorageServiceImpl(CloudStorageProperties properties) { |
|---|
| | | this.properties = properties.getMinio(); |
|---|
| | | public MinioCloudStorageStrategy(CloudStorageProperties cloudStorageProperties) { |
|---|
| | | properties = cloudStorageProperties; |
|---|
| | | try { |
|---|
| | | minioClient = MinioClient.builder() |
|---|
| | | .endpoint(this.properties.getEndpoint()) |
|---|
| | | .credentials(this.properties.getAccessKey(), this.properties.getSecretKey()) |
|---|
| | | .endpoint(properties.getEndpoint()) |
|---|
| | | .credentials(properties.getAccessKey(), properties.getSecretKey()) |
|---|
| | | .build(); |
|---|
| | | createBucket(); |
|---|
| | | } catch (Exception e) { |
|---|
| | |
|---|
| | | @Override |
|---|
| | | public UploadResult uploadSuffix(InputStream inputStream, String suffix, String contentType) { |
|---|
| | | return upload(inputStream, getPath("", suffix), contentType); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public void afterPropertiesSet() throws Exception { |
|---|
| | | OssFactory.register(getServiceType(), this); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
