estel/gva
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

minio 完善

Browse Source
This commit is contained in:
Brandon-lz
2024-10-14 11:46:39 +00:00
parent 91e4c89962
commit a483ac9174
6 changed files with 44 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
server/utils/upload/minio_oss.go
View File

@@ -15,14 +15,14 @@ import (
"go.uber.org/zap"
)
var MinioClient *Minio // 优化性能，但是不支持动态配置
var MinioClient *Minio // 优化性能，但是不支持动态配置，如果修改了minio配置，需要重启后端
type Minio struct {
client *minio.Client
bucket string
}
func NewMinio(endpoint, accessKeyID, secretAccessKey, bucketName string, useSSL bool) (*Minio, error) {
func GetMinio(endpoint, accessKeyID, secretAccessKey, bucketName string, useSSL bool) (*Minio, error) {
if MinioClient != nil {
return MinioClient, nil
}

4
server/utils/upload/upload.go
View File

@@ -34,9 +34,9 @@ func NewOss() OSS {
case "cloudflare-r2":
return &CloudflareR2{}
case "minio":
minioClient, err := NewMinio(global.GVA_CONFIG.Minio.Endpoint, global.GVA_CONFIG.Minio.AccessKeyId, global.GVA_CONFIG.Minio.AccessKeySecret, global.GVA_CONFIG.Minio.BucketName, global.GVA_CONFIG.Minio.UseSSL)
minioClient, err := GetMinio(global.GVA_CONFIG.Minio.Endpoint, global.GVA_CONFIG.Minio.AccessKeyId, global.GVA_CONFIG.Minio.AccessKeySecret, global.GVA_CONFIG.Minio.BucketName, global.GVA_CONFIG.Minio.UseSSL)
if err != nil {
global.GVA_LOG.Error("你配置了使用minio，但是初始化失败，请检查minio可用性或安全配置: " + err.Error())
global.GVA_LOG.Warn("你配置了使用minio，但是初始化失败，请检查minio可用性或安全配置: " + err.Error())
panic("minio初始化失败") // 建议这样做，用户自己配置了minio，如果报错了还要把服务开起来，使用起来也很危险
}
return minioClient