欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

詳解go基于viper實現(xiàn)配置文件熱更新及其源碼分析

 更新時間:2020年06月04日 11:05:27   作者:_雨落山嵐  
這篇文章主要介紹了詳解go基于viper實現(xiàn)配置文件熱更新及其源碼分析,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

go第三方庫 github.com/spf13/viper  實現(xiàn)了對配置文件的讀取并注入到結(jié)構(gòu)中,好用方便。

其中以

viperInstance := viper.New()	// viper實例
viperInstance.WatchConfig()
viperInstance.OnConfigChange(func(e fsnotify.Event) {
	log.Print("Config file updated.")
	viperLoadConf(viperInstance)  // 加載配置的方法
})

可實現(xiàn)配置的熱更新,不用重啟項目新配置即可生效(實現(xiàn)熱加載的方法也不止這一種,比如以文件的上次修改時間來判斷等)。

為什么這么寫?這樣寫為什么就能立即生效?基于這兩個問題一起來看看viper是怎樣實現(xiàn)熱更新的。

上面代碼的核心一共兩處:WatchConfig()方法、OnConfigChange()方法。WatchConfig()方法用來開啟事件監(jiān)聽,確定用戶操作文件后該文件是否可正常讀取,并將內(nèi)容注入到viper實例的config字段,先來看看WatchConfig()方法:

func (v *Viper) WatchConfig() {
	go func() {
      // 建立新的監(jiān)視處理程序,開啟一個協(xié)程開始等待事件
      // 從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:
		// 清除內(nèi)部的..和他前面的元素,清除當(dāng)前路徑.,用來判斷操作的文件是否是configFile
					if filepath.Clean(event.Name) == configFile {
        // 如果對該文件進(jìn)行了創(chuàng)建操作或?qū)懖僮?
						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是用來監(jiān)控目錄及文件的第三方庫;  watcher, err := fsnotify.NewWatcher() 用來建立新的監(jiān)視處理程序,它會開啟一個協(xié)程開始等待讀取事件,完成 從I / O完成端口讀取任務(wù),將事件注入到Event對象中,即Watcher.Events;

執(zhí)行v.ReadInConfig()后配置文件的內(nèi)容將重新讀取到viper實例中,如下圖:

執(zhí)行完v.ReadInConfig()后,config字段的內(nèi)容已經(jīng)是用戶修改的最新內(nèi)容了;

其中這行v.onConfigChange(event)的onConfigChange是核心結(jié)構(gòu)體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來執(zhí)行你寫的函數(shù)。為什么修改會立即生效?相信第二個疑問已經(jīng)得到解決了。

接下來看看OnConfigChange(func(e fsnotify.Event) {...... })的運行情況:

func (v *Viper) OnConfigChange(run func(in fsnotify.Event)) {
	v.onConfigChange = run
}

方法參數(shù)為一個函數(shù),類型為func(in fsnotify.Event)) {},這就意味著開發(fā)者需要把你自己的執(zhí)行邏輯放到這個func里面,在監(jiān)聽到event時就會執(zhí)行你寫的函數(shù),所以就可以這樣寫:

	viperInstance.OnConfigChange(func(e fsnotify.Event) {
		log.Print("Config file updated.")
		viperLoadConf(viperInstance)  // viperLoadConf函數(shù)就是將最新配置注入到自定義結(jié)構(gòu)體對象的邏輯
	})

而OnConfigChange方法的參數(shù)會賦值給形參run并傳到viper實例的onConfigChange屬性,以WatchConfig()方法中的v.onConfigChange(event)來執(zhí)行這個函數(shù)。

到此,第一個疑問也就解決了。

到此這篇關(guān)于詳解go基于viper實現(xiàn)配置文件熱更新及其源碼分析的文章就介紹到這了,更多相關(guān)go viper文件熱更新內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • 詳解Golang中select的使用與源碼分析

    詳解Golang中select的使用與源碼分析

    select?是?Go?提供的?IO?多路復(fù)用機(jī)制,可以用多個?case?同時監(jiān)聽多個?channl?的讀寫狀態(tài)。本文將從源碼角度帶大家了解一下select的使用,需要的可以參考一下
    2022-12-12
  • GoFrame框架gredis優(yōu)雅的取值和類型轉(zhuǎn)換

    GoFrame框架gredis優(yōu)雅的取值和類型轉(zhuǎn)換

    這篇文章主要為大家介紹了GoFrame框架gredis優(yōu)雅的取值和類型轉(zhuǎn)換,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪
    2022-06-06
  • Go 語言 JSON 標(biāo)準(zhǔn)庫的使用

    Go 語言 JSON 標(biāo)準(zhǔn)庫的使用

    今天通過本文給大家介紹Go 語言 JSON 標(biāo)準(zhǔn)庫的使用小結(jié),包括序列化和反序列化的相關(guān)知識,感興趣的朋友跟隨小編一起看看吧
    2021-10-10
  • 詳解golang執(zhí)行Linux shell命令完整場景下的使用方法

    詳解golang執(zhí)行Linux shell命令完整場景下的使用方法

    本文主要介紹了golang執(zhí)行Linux shell命令完整場景下的使用方法,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2022-06-06
  • 一文教你Golang如何正確關(guān)閉通道

    一文教你Golang如何正確關(guān)閉通道

    Go在通道這一塊,沒有內(nèi)置函數(shù)判斷通道是否已經(jīng)關(guān)閉,也沒有可以直接獲取當(dāng)前通道數(shù)量的方法,因此如果對通道進(jìn)行了錯誤的使用,將會直接引發(fā)系統(tǒng)?panic,這是一件很危險的事情,下面我們就來學(xué)習(xí)一下如何正確關(guān)閉通道吧
    2023-10-10
  • Go語言服務(wù)器開發(fā)之客戶端向服務(wù)器發(fā)送數(shù)據(jù)并接收返回數(shù)據(jù)的方法

    Go語言服務(wù)器開發(fā)之客戶端向服務(wù)器發(fā)送數(shù)據(jù)并接收返回數(shù)據(jù)的方法

    這篇文章主要介紹了Go語言服務(wù)器開發(fā)之客戶端向服務(wù)器發(fā)送數(shù)據(jù)并接收返回數(shù)據(jù)的方法,實例分析了客戶端的開發(fā)技巧,具有一定參考借鑒價值,需要的朋友可以參考下
    2015-02-02
  • golang gorm 結(jié)構(gòu)體的表字段缺省值設(shè)置方式

    golang gorm 結(jié)構(gòu)體的表字段缺省值設(shè)置方式

    這篇文章主要介紹了golang gorm 結(jié)構(gòu)體的表字段缺省值設(shè)置方式,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧
    2020-12-12
  • Go+Kafka實現(xiàn)延遲消息的實現(xiàn)示例

    Go+Kafka實現(xiàn)延遲消息的實現(xiàn)示例

    本文主要介紹了Go+Kafka實現(xiàn)延遲消息的實現(xiàn)示例,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2022-07-07
  • 讓Go反射變快的方法實例探究

    讓Go反射變快的方法實例探究

    反射允許你在運行時獲得有關(guān) Go 類型的信息,如果你曾經(jīng)愚蠢地嘗試編寫 json.Unmarshal 之類的新版本,本文將探討的就是如何使用反射來填充結(jié)構(gòu)體值
    2024-01-01
  • Go defer與time.sleep的使用與區(qū)別

    Go defer與time.sleep的使用與區(qū)別

    本文主要介紹了Go defer與time.sleep的使用與區(qū)別,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2024-04-04

最新評論