rakor
/
wms
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

初始化

This commit is contained in:
曹鹏飞 2025-07-04 18:13:43 +08:00
parent fa55eb19b2
commit a8f6916b49
2 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
nflg-wms-starter/src/main/java/com/nflg/wms/starter/config/MinIOConfig.java
View File

@ -3,6 +3,7 @@ package com.nflg.wms.starter.config;
import io.minio.BucketExistsArgs; import io.minio.BucketExistsArgs;
import io.minio.MakeBucketArgs; import io.minio.MakeBucketArgs;
import io.minio.MinioClient; import io.minio.MinioClient;
import io.minio.SetBucketPolicyArgs;
import jakarta.annotation.PreDestroy; import jakarta.annotation.PreDestroy;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value; import org.springframework.beans.factory.annotation.Value;
@ -39,6 +40,9 @@ public class MinIOConfig {
if (!client.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build())) { if (!client.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build())) {
client.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build()); client.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build());
} }
String policyJsonString = """
{"Version":"2012-10-17","Statement":[{"Effect":"Allow","Principal":"*","Action":"s3:GetObject","Resource":"arn:aws:s3:::%s/*"}]}""".formatted(bucketName);
client.setBucketPolicy(SetBucketPolicyArgs.builder().bucket(bucketName).config(policyJsonString).build());
return client; return client;
} }

8
nflg-wms-starter/src/main/java/com/nflg/wms/starter/service/impl/MinIOServiceImpl.java
View File

@ -39,6 +39,12 @@ public class MinIOServiceImpl implements FileUploadService {
.object(filePath) .object(filePath)
.stream(stream, stream.available(), -1) .stream(stream, stream.available(), -1)
.build()); .build());
return StrUtil.format("{}/{}", domain, filePath); // return minioClient.getPresignedObjectUrl(GetPresignedObjectUrlArgs.builder()
// .method(Method.GET)
// .bucket(bucketName)
// .object(filePath)
// .expiry(7, TimeUnit.DAYS)
// .build());
return StrUtil.format("{}/{}/{}", domain,bucketName, filePath);
} }
} }