feat:xiugai

config.json

@@ -3,16 +3,16 @@
   "oss_accounts": [
     {
       "id": "main",
-      "endpoint": "oss-cn-beijing.aliyuncs.com",
-      "access_key_id": "LTAI4G5x9aoZx8dDamQ7vfZi",
-      "access_key_secret": "Bk98FsbPYXcJe72n1bG3Ssf73acuNh"
+      "endpoint": "oss-cn-beijing-internal.aliyuncs.com",
+      "access_key_id": "LTAI5tPJ6FFWd65Es72dPvzR1",
+      "access_key_secret": "448IIiZYgatBwT5ifofC8losWv3cXi"
     }
   ],
   "buckets": [
     {
       "bucket_id": "detail",
       "account_id": "main",
-      "bucket_name": "jytest2022"
+      "bucket_name": "jy-detail-test"
     }
   ],
   "node": {

main.go

@@ -26,6 +26,7 @@ func main() {
 	// 注册一个回调函数，当配置发生变更时会被调用
 	gfsnotify.Add("./config.json", func(event *gfsnotify.Event) {
 		if event.IsWrite() || event.IsChmod() {
+			log.Println("配置文件有变化，更新内存。。。")
 			ossService.LoadOSSAccounts()
 		}
 	})

oss/oss.go

@@ -146,9 +146,11 @@ func DeleteAttachment(bucketID, objectName string) error {
 func LoadOSSAccounts() {
 	var oas []*config.OSSAccount
 	g.Config().MustGet(gctx.New(), "oss_accounts").Structs(&oas)
+	accountMap.Clear()
 	for _, acc := range oas {
-		accountMap.LoadOrStore(acc.ID, *acc)
+		accountMap.Store(acc.ID, *acc)
 	}
+	bucketPool.Clear()
 }
 
 // 获取标讯正文，优先从oss中取，再从es中取