修改参数获取
This commit is contained in:
@@ -8,6 +8,7 @@ import (
|
|||||||
"fmt"
|
"fmt"
|
||||||
"log"
|
"log"
|
||||||
"os"
|
"os"
|
||||||
|
"path/filepath"
|
||||||
"reflect"
|
"reflect"
|
||||||
|
|
||||||
"github.com/fsnotify/fsnotify"
|
"github.com/fsnotify/fsnotify"
|
||||||
@@ -18,7 +19,7 @@ import (
|
|||||||
|
|
||||||
// @param configPath 配置文件路径
|
// @param configPath 配置文件路径
|
||||||
// @param configData 配置数据结构体指针
|
// @param configData 配置数据结构体指针
|
||||||
func InitConfig(configPath string, configData interface{}) {
|
func InitConfig(configData interface{}, defaultPath string) {
|
||||||
|
|
||||||
// 判断是否指针
|
// 判断是否指针
|
||||||
if reflect.ValueOf(configData).Kind() != reflect.Ptr {
|
if reflect.ValueOf(configData).Kind() != reflect.Ptr {
|
||||||
@@ -26,29 +27,32 @@ func InitConfig(configPath string, configData interface{}) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// 优先级: 命令行 > 环境变量 > 默认值
|
// 优先级: 命令行 > 环境变量 > 默认值
|
||||||
if len(configPath) == 0 {
|
|
||||||
// 从命令行读取配置文件路径
|
filePath := ""
|
||||||
flag.StringVar(&configPath, "c", "", "choose config file.")
|
|
||||||
|
flag.StringVar(&filePath, "c", "", "choose config file.")
|
||||||
flag.Parse()
|
flag.Parse()
|
||||||
if configPath == "" {
|
|
||||||
// 从环境变量读取配置文件路径
|
if filePath == "" {
|
||||||
if configEnv := os.Getenv("config"); configEnv == "" {
|
if configEnv := os.Getenv("config"); configEnv == "" {
|
||||||
configPath = "config.yaml"
|
filePath = defaultPath
|
||||||
log.Printf("您正在使用config的默认值,config的路径为%v\n", configPath)
|
log.Printf("您正在使用config的默认值,config的路径为%v\n", filePath)
|
||||||
} else {
|
} else {
|
||||||
configPath = configEnv
|
filePath = configEnv
|
||||||
log.Printf("您正在使用GVA_CONFIG环境变量,config的路径为%v\n", configPath)
|
log.Printf("您正在使用GVA_CONFIG环境变量,config的路径为%v\n", filePath)
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
log.Printf("您正在使用命令行的-c参数传递的值,config的路径为%v\n", configPath)
|
log.Printf("您正在使用命令行的-c参数传递的值,config的路径为%v\n", filePath)
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
absPath, _ := filepath.Abs(filePath)
|
||||||
|
log.Println("配置文件路径:", absPath)
|
||||||
|
|
||||||
v := viper.New()
|
v := viper.New()
|
||||||
v.SetConfigFile(configPath)
|
v.SetConfigFile(filePath)
|
||||||
err := v.ReadInConfig()
|
err := v.ReadInConfig()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
panic(fmt.Errorf("Fatal error config file: %s \n", err))
|
panic(fmt.Sprintf("Fatal error config file: %s \n", err))
|
||||||
}
|
}
|
||||||
|
|
||||||
// 监控配置文件的变化
|
// 监控配置文件的变化
|
||||||
@@ -56,7 +60,7 @@ func InitConfig(configPath string, configData interface{}) {
|
|||||||
|
|
||||||
// 监听配置的变化
|
// 监听配置的变化
|
||||||
v.OnConfigChange(func(e fsnotify.Event) {
|
v.OnConfigChange(func(e fsnotify.Event) {
|
||||||
fmt.Println("config file changed:", e.Name)
|
log.Println("config file changed:", e.Name)
|
||||||
if err := v.Unmarshal(&configData); err != nil {
|
if err := v.Unmarshal(&configData); err != nil {
|
||||||
log.Println(err)
|
log.Println(err)
|
||||||
}
|
}
|
||||||
@@ -65,6 +69,6 @@ func InitConfig(configPath string, configData interface{}) {
|
|||||||
// 将配置文件的内容映射到configData中
|
// 将配置文件的内容映射到configData中
|
||||||
if err := v.Unmarshal(&configData); err != nil {
|
if err := v.Unmarshal(&configData); err != nil {
|
||||||
log.Println(err)
|
log.Println(err)
|
||||||
panic(fmt.Errorf("Fatal error config file: %s \n", err))
|
panic(fmt.Sprintf("Fatal error config file: %s \n", err))
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user