最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

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

 更新時間:2020年06月04日 11:05:27   作者:_雨落山嵐  
這篇文章主要介紹了詳解go基于viper實現(xiàn)配置文件熱更新及其源碼分析,文中通過示例代碼介紹的非常詳細,對大家的學(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 {
        // 如果對該文件進行了創(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)文章

  • 詳解Go語言單元測試中如何解決MySQL存儲依賴問題

    詳解Go語言單元測試中如何解決MySQL存儲依賴問題

    MySQL?存儲就是一個非常常見的外部依賴,這篇文章主要來和大家一起探討在?Go?語言中編寫單元測試時,如何解決?MySQL?存儲依賴,需要的可以參考一下
    2023-07-07
  • golang跳轉(zhuǎn)語句goto,break,continue的使用及區(qū)別說明

    golang跳轉(zhuǎn)語句goto,break,continue的使用及區(qū)別說明

    這篇文章主要介紹了golang跳轉(zhuǎn)語句goto,break,continue的使用及區(qū)別說明,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧
    2020-12-12
  • 一文教你如何快速學(xué)會Go的struct數(shù)據(jù)類型

    一文教你如何快速學(xué)會Go的struct數(shù)據(jù)類型

    結(jié)構(gòu)是表示字段集合的用戶定義類型。它可以用于將數(shù)據(jù)分組為單個單元而不是將每個數(shù)據(jù)作為單獨的值的地方。本文就來和大家聊聊Go中struct數(shù)據(jù)類型的使用,需要的可以參考一下
    2023-03-03
  • golang編程入門之http請求天氣實例

    golang編程入門之http請求天氣實例

    這篇文章主要介紹了golang編程入門之http請求天氣實例,小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2018-08-08
  • 一文告訴你大神是如何學(xué)習(xí)Go語言之make和new

    一文告訴你大神是如何學(xué)習(xí)Go語言之make和new

    當(dāng)我們想要在 Go 語言中初始化一個結(jié)構(gòu)時,其實會使用到兩個完全不同的關(guān)鍵字,也就是 make 和 new,同時出現(xiàn)兩個用于『初始化』的關(guān)鍵字對于初學(xué)者來說可能會感到非常困惑,不過它們兩者有著卻完全不同的作用,本文就和大家詳細講講
    2023-02-02
  • go 實現(xiàn)簡易端口掃描的示例

    go 實現(xiàn)簡易端口掃描的示例

    該功能實現(xiàn)原理很簡單,就是發(fā)送socket連接(IP+端口),如果能連接成功,說明目標(biāo)主機開放了某端口。當(dāng)要大量掃描端口時,就需要寫并發(fā)編程了。
    2021-05-05
  • Go語言-為什么返回值為接口類型,卻返回結(jié)構(gòu)體

    Go語言-為什么返回值為接口類型,卻返回結(jié)構(gòu)體

    這篇文章主要介紹了Go語言返回值為接口類型,卻返回結(jié)構(gòu)體的實例講解,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧
    2021-04-04
  • golang 打印error的堆棧信息操作

    golang 打印error的堆棧信息操作

    這篇文章主要介紹了golang 打印error的堆棧信息操作,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧
    2021-05-05
  • Go map排序的實現(xiàn)示例

    Go map排序的實現(xiàn)示例

    map默認是無序的,不管是按照key還是按照value默認都不排序,本文主要介紹了Go map排序的實現(xiàn)示例,具有一定的參考價值,感興趣的可以了解一下
    2023-12-12
  • Go語言中websocket的使用demo分享

    Go語言中websocket的使用demo分享

    WebSocket是一種在單個TCP連接上進行全雙工通信的協(xié)議。這篇文章主要和大家分享了一個Go語言中websocket的使用demo,需要的可以參考一下
    2022-12-12

最新評論

阳城县| 霍邱县| 日喀则市| 原阳县| 剑河县| 黄陵县| 南部县| 周口市| 阿城市| 襄汾县| 阳泉市| 泸溪县| 临江市| 东阳市| 垦利县| 鄱阳县| 阆中市| 泉州市| 台北市| 成武县| 朝阳区| 湖北省| 诏安县| 泰宁县| 昌黎县| 德格县| 丰城市| 衢州市| 武强县| 郁南县| 文山县| 克东县| 天祝| 县级市| 新丰县| 青岛市| 丁青县| 德保县| 平乡县| 驻马店市| 翼城县|