怎么在Golang利用viper包對yaml的配置信息進行讀取?針對這個問題,這篇文章詳細介紹了相對應的分析和解答,希望可以幫助更多想解決這個問題的小伙伴找到更簡單易行的方法。
成都創新互聯公司專注于民和網站建設服務及定制,我們擁有豐富的企業做網站經驗。 熱誠為您提供民和營銷型網站建設,民和網站制作、民和網頁設計、民和網站官網定制、重慶小程序開發服務,打造民和網絡公司原創品牌,更為您提供民和網站排名全網營銷落地服務。1、安裝
go get github.com/spf13/viper
database: host: 127.0.0.1 user: root dbname: test pwd: 123456
package main import ( "fmt" "os" "github.com/spf13/viper" ) func main() { //獲取項目的執行路徑 path, err := os.Getwd() if err != nil { panic(err) } config := viper.New() config.AddConfigPath(path) //設置讀取的文件路徑 config.SetConfigName("config") //設置讀取的文件名 config.SetConfigType("yaml") //設置文件的類型 //嘗試進行配置讀取 if err := config.ReadInConfig(); err != nil { panic(err) } //打印文件讀取出來的內容: fmt.Println(config.Get("database.host")) fmt.Println(config.Get("database.user")) fmt.Println(config.Get("database.dbname")) fmt.Println(config.Get("database.pwd")) }
輸出:
127.0.0.1 root test 123456
ok!
補充:go基于viper實現配置文件熱更新及其源碼分析
go第三方庫 github.com/spf13/viper 實現了對配置文件的讀取并注入到結構中,好用方便。
其中以
viperInstance := viper.New() // viper實例 viperInstance.WatchConfig() viperInstance.OnConfigChange(func(e fsnotify.Event) { log.Print("Config file updated.") viperLoadConf(viperInstance) // 加載配置的方法 })
可實現配置的熱更新,不用重啟項目新配置即可生效(實現熱加載的方法也不止這一種,比如以文件的上次修改時間來判斷等)。
為什么這么寫?這樣寫為什么就能立即生效?基于這兩個問題一起來看看viper是怎樣實現熱更新的。
上面代碼的核心一共兩處:WatchConfig()方法、OnConfigChange()方法。WatchConfig()方法用來開啟事件監聽,確定用戶操作文件后該文件是否可正常讀取,并將內容注入到viper實例的config字段,先來看看WatchConfig()方法:
func (v *Viper) WatchConfig() { go func() { // 建立新的監視處理程序,開啟一個協程開始等待事件 // 從I/O完成端口讀取,將事件注入到Event對象中:Watcher.Events watcher, err := fsnotify.NewWatcher() if err != nil { log.Fatal(err) } defer watcher.Close() // we have to watch the entire directory to pick up renames/atomic saves in a cross-platform way filename, err := v.getConfigFile() if err != nil { log.Println("error:", err) return } configFile := filepath.Clean(filename) //配置文件E:\etc\bizsvc\config.yml configDir, _ := filepath.Split(configFile) // E:\etc\bizsvc\ done := make(chan bool) go func() { for { select { // 讀取的event對象有兩個屬性,Name為E:\etc\bizsvc\config.yml,Op為write(對文件的操作) case event := <-watcher.Events: // 清除內部的..和他前面的元素,清除當前路徑.,用來判斷操作的文件是否是configFile if filepath.Clean(event.Name) == configFile { // 如果對該文件進行了創建操作或寫操作 if event.Op&fsnotify.Write == fsnotify.Write || event.Op&fsnotify.Create == fsnotify.Create { err := v.ReadInConfig() if err != nil { log.Println("error:", err) } v.onConfigChange(event) } } case err := <-watcher.Errors: // 有錯誤將打印 log.Println("error:", err) } } }() watcher.Add(configDir) <-done }() }
其中,fsnotify是用來監控目錄及文件的第三方庫; watcher, err := fsnotify.NewWatcher() 用來建立新的監視處理程序,它會開啟一個協程開始等待讀取事件,完成 從I / O完成端口讀取任務,將事件注入到Event對象中,即Watcher.Events;
執行v.ReadInConfig()后配置文件的內容將重新讀取到viper實例中,如下圖:
執行完v.ReadInConfig()后,config字段的內容已經是用戶修改的新內容了;
其中這行v.onConfigChange(event)的onConfigChange是核心結構體Viper的一個屬性,類型是func:
type Viper struct { // Delimiter that separates a list of keys // used to access a nested value in one go keyDelim string // A set of paths to look for the config file in configPaths []string // The filesystem to read config from. fs afero.Fs // A set of remote providers to search for the configuration remoteProviders []*defaultRemoteProvider // Name of file to look for inside the path configName string configFile string configType string envPrefix string automaticEnvApplied bool envKeyReplacer *strings.Replacer config map[string]interface{} override map[string]interface{} defaults map[string]interface{} kvstore map[string]interface{} pflags map[string]FlagValue env map[string]string aliases map[string]string typeByDefValue bool // Store read properties on the object so that we can write back in order with comments. // This will only be used if the configuration read is a properties file. properties *properties.Properties onConfigChange func(fsnotify.Event) }
它用來傳入本次event來執行你寫的函數。為什么修改會立即生效?相信第二個疑問已經得到解決了。
接下來看看OnConfigChange(func(e fsnotify.Event) {...... })的運行情況:
func (v *Viper) OnConfigChange(run func(in fsnotify.Event)) { v.onConfigChange = run }
方法參數為一個函數,類型為func(in fsnotify.Event)) {},這就意味著開發者需要把你自己的執行邏輯放到這個func里面,在監聽到event時就會執行你寫的函數,所以就可以這樣寫:
viperInstance.OnConfigChange(func(e fsnotify.Event) { log.Print("Config file updated.") viperLoadConf(viperInstance) // viperLoadConf函數就是將新配置注入到自定義結構體對象的邏輯 })
而OnConfigChange方法的參數會賦值給形參run并傳到viper實例的onConfigChange屬性,以WatchConfig()方法中的v.onConfigChange(event)來執行這個函數。
關于怎么在Golang利用viper包對yaml的配置信息進行讀取問題的解答就分享到這里了,希望以上內容可以對大家有一定的幫助,如果你還有很多疑惑沒有解開,可以關注創新互聯行業資訊頻道了解更多相關知識。
標題名稱:怎么在Golang利用viper包對yaml的配置信息進行讀取-創新互聯
網頁網址:http://m.newbst.com/article44/dchiee.html
成都網站建設公司_創新互聯,為您提供外貿建站、App開發、網站改版、網站制作、網站設計公司、用戶體驗
聲明:本網站發布的內容(圖片、視頻和文字)以用戶投稿、用戶轉載內容為主,如果涉及侵權請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網站立場,如需處理請聯系客服。電話:028-86922220;郵箱:631063699@qq.com。內容未經允許不得轉載,或轉載時需注明來源: 創新互聯