|
@@ -28,7 +28,8 @@ import java.util.stream.Collectors;
|
|
|
@Component
|
|
|
public class MinIoChunkUtils implements InitializingBean {
|
|
|
|
|
|
- private static String url;
|
|
|
+ public static String url;
|
|
|
+ private static String endPort;
|
|
|
|
|
|
private static String accessKey;
|
|
|
|
|
@@ -57,7 +58,7 @@ public class MinIoChunkUtils implements InitializingBean {
|
|
|
|
|
|
@Override
|
|
|
public void afterPropertiesSet() throws Exception {
|
|
|
- minioClient = MinioClient.builder().endpoint(url).credentials(accessKey,secretKey).build();
|
|
|
+ minioClient = MinioClient.builder().endpoint(endPort).credentials(accessKey,secretKey).build();
|
|
|
//方便管理分片文件,则单独创建一个分片文件的存储桶
|
|
|
if (!isBucketExist(chunkBucKet)){
|
|
|
createBucket(chunkBucKet);
|
|
@@ -72,7 +73,8 @@ public class MinIoChunkUtils implements InitializingBean {
|
|
|
MinIOConfig minIOConfig;
|
|
|
@PostConstruct
|
|
|
public void init(){
|
|
|
- url = minIOConfig.getEndpoint();
|
|
|
+ endPort = minIOConfig.getEndpoint();
|
|
|
+ url = minIOConfig.getFileHost();
|
|
|
accessKey =minIOConfig.getAccessKey();
|
|
|
secretKey = minIOConfig.getSecretKey();
|
|
|
chunkBucKet = minIOConfig.getBucketChunk();
|
|
@@ -130,14 +132,15 @@ public class MinIoChunkUtils implements InitializingBean {
|
|
|
@SneakyThrows
|
|
|
public static String createUploadUrl(String bucketName,String objectName,Integer expiry){
|
|
|
expiry = expiryHandle(expiry);
|
|
|
- return minioClient.getPresignedObjectUrl(
|
|
|
+ String presignedObjectUrl = minioClient.getPresignedObjectUrl(
|
|
|
GetPresignedObjectUrlArgs.builder()
|
|
|
.method(Method.PUT)
|
|
|
.bucket(bucketName)
|
|
|
.object(objectName)
|
|
|
.expiry(expiry)
|
|
|
- .build()
|
|
|
- );
|
|
|
+ .build());
|
|
|
+
|
|
|
+ return presignedObjectUrl.replace(endPort,url);
|
|
|
}
|
|
|
|
|
|
/**
|