From 647e88b21a79acaffdeb1059fc0a3b65bb5385b9 Mon Sep 17 00:00:00 2001 From: qhd <1766646056@qq.com> Date: Mon, 26 Jan 2026 11:40:57 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=20MinIO=20=E6=96=87=E4=BB=B6?= =?UTF-8?q?=E5=89=8D=E7=BC=80=E9=85=8D=E7=BD=AE=E5=B9=B6=E4=BC=98=E5=8C=96?= =?UTF-8?q?=E6=96=87=E4=BB=B6=E5=9C=B0=E5=9D=80=E6=8B=BC=E6=8E=A5=E9=80=BB?= =?UTF-8?q?=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- minio/minio.go | 28 +++++++++++++++------------- 1 file changed, 15 insertions(+), 13 deletions(-) diff --git a/minio/minio.go b/minio/minio.go index 03df1d4..2b6a98c 100644 --- a/minio/minio.go +++ b/minio/minio.go @@ -19,11 +19,12 @@ import ( // IoConfig 映射 YAML 中的 minio 配置节点 type IoConfig struct { - Endpoint string `yaml:"endpoint"` // MinIO API 地址 - AccessKey string `yaml:"accessKey"` // AK - SecretKey string `yaml:"secretKey"` // SK - Secure bool `yaml:"secure"` // 是否启用 SSL - Region string `yaml:"region"` // 区域 + FilePrefix string `yaml:"filePrefix"` // 文件前缀 + Endpoint string `yaml:"endpoint"` // MinIO API 地址 + AccessKey string `yaml:"accessKey"` // AK + SecretKey string `yaml:"secretKey"` // SK + Secure bool `yaml:"secure"` // 是否启用 SSL + Region string `yaml:"region"` // 区域 } // 全局 MinIO 客户端(初始化一次,避免重复创建) @@ -36,11 +37,12 @@ func init() { if !g.Cfg().MustGet(ctx, "minio").IsEmpty() { // 加载 MinIO 配置(可从配置文件/环境变量读取,这里硬编码示例) minioCfg = IoConfig{ - Endpoint: g.Cfg().MustGet(ctx, "minio.endpoint").String(), - AccessKey: g.Cfg().MustGet(ctx, "minio.accessKey").String(), - SecretKey: g.Cfg().MustGet(ctx, "minio.secretKey").String(), - Secure: g.Cfg().MustGet(ctx, "minio.secure").Bool(), - Region: g.Cfg().MustGet(ctx, "minio.region").String(), + FilePrefix: g.Cfg().MustGet(ctx, "filePrefix.endpoint").String(), + Endpoint: g.Cfg().MustGet(ctx, "minio.endpoint").String(), + AccessKey: g.Cfg().MustGet(ctx, "minio.accessKey").String(), + SecretKey: g.Cfg().MustGet(ctx, "minio.secretKey").String(), + Secure: g.Cfg().MustGet(ctx, "minio.secure").Bool(), + Region: g.Cfg().MustGet(ctx, "minio.region").String(), } // 创建 MinIO 客户端 var err error @@ -123,14 +125,14 @@ func uploadFile(ctx context.Context, bucketName string, fileHeader *ghttp.Upload return objectName, err } -// GetIFileAddressPrefix 拼接图片前缀地址 -func GetIFileAddressPrefix(ctx context.Context) (imageUrl string) { +// GetFileAddressPrefix 拼接图片前缀地址 +func GetFileAddressPrefix(ctx context.Context) (imageUrl string) { // 拼接图片前缀地址 var url = "http://" if minioCfg.Secure { url = "https://" } - imgAddressPrefix := url + minioCfg.Endpoint + "/" + getBucketName(ctx) + imgAddressPrefix := url + minioCfg.FilePrefix + "/" + getBucketName(ctx) return imgAddressPrefix }