首頁>技術>

Go 每日一庫之 viper簡介

上一篇文章介紹 cobra 的時候提到了 viper,今天我們就來介紹一下這個庫。 viper 是一個配置解決方案,擁有豐富的特性:

支援 JSON/TOML/YAML/HCL/envfile/Java properties 等多種格式的配置檔案;可以設定監聽配置檔案的修改,修改時自動載入新的配置;從環境變數、命令列選項和io.Reader中讀取配置;從遠端配置系統中讀取和監聽修改,如 etcd/Consul;程式碼邏輯中顯示設定鍵值。快速使用

安裝:

$ go get github.com/spf13/viper複製程式碼

使用:

package mainimport (  "fmt"  "log"  "github.com/spf13/viper")func main() {  viper.SetConfigName("config")  viper.SetConfigType("toml")  viper.AddConfigPath(".")  viper.SetDefault("redis.port", 6381)  err := viper.ReadInConfig()  if err != nil {    log.Fatal("read config failed: %v", err)  }  fmt.Println(viper.Get("app_name"))  fmt.Println(viper.Get("log_level"))  fmt.Println("mysql ip: ", viper.Get("mysql.ip"))  fmt.Println("mysql port: ", viper.Get("mysql.port"))  fmt.Println("mysql user: ", viper.Get("mysql.user"))  fmt.Println("mysql password: ", viper.Get("mysql.password"))  fmt.Println("mysql database: ", viper.Get("mysql.database"))  fmt.Println("redis ip: ", viper.Get("redis.ip"))  fmt.Println("redis port: ", viper.Get("redis.port"))}複製程式碼

我們使用之前Go 每日一庫之 go-ini一文中使用的配置,不過改為 toml 格式。 toml 的語法很簡單,快速入門請看learn X in Y minutes。

app_name = "awesome web"# possible values: DEBUG, INFO, WARNING, ERROR, FATALlog_level = "DEBUG"[mysql]ip = "127.0.0.1"port = 3306user = "dj"password = 123456database = "awesome"[redis]ip = "127.0.0.1"port = 7381複製程式碼

viper 的使用非常簡單,它需要很少的設定。設定檔名(SetConfigName)、配置型別(SetConfigType)和搜尋路徑(AddConfigPath),然後呼叫ReadInConfig。 viper會自動根據型別來讀取配置。使用時呼叫viper.Get方法獲取鍵值。

編譯、執行程式:

awesome webDEBUGmysql ip:  127.0.0.1mysql port:  3306mysql user:  djmysql password:  123456mysql database:  awesomeredis ip:  127.0.0.1redis port:  7381複製程式碼

有幾點需要注意:

設定檔名時不要帶字尾;搜尋路徑可以設定多個,viper 會根據設定順序依次查詢;viper 獲取值時使用section.key的形式,即傳入巢狀的鍵名;預設值可以呼叫viper.SetDefault設定。讀取鍵

viper 提供了多種形式的讀取方法。在上面的例子中,我們看到了Get方法的用法。Get方法返回一個interface{}的值,使用有所不便。

GetType系列方法可以返回指定型別的值。 其中,Type 可以為Bool/Float64/Int/String/Time/Duration/IntSlice/StringSlice。 但是請注意,如果指定的鍵不存在或型別不正確,GetType方法返回對應型別的零值。

如果要判斷某個鍵是否存在,使用IsSet方法。 另外,GetStringMap和GetStringMapString直接以 map 返回某個鍵下面所有的鍵值對,前者返回map[string]interface{},後者返回map[string]string。 AllSettings以map[string]interface{}返回所有設定。

// 省略包名和 import 部分func main() {  viper.SetConfigName("config")  viper.SetConfigType("toml")  viper.AddConfigPath(".")  err := viper.ReadInConfig()  if err != nil {    log.Fatal("read config failed: %v", err)  }  fmt.Println("protocols: ", viper.GetStringSlice("server.protocols"))  fmt.Println("ports: ", viper.GetIntSlice("server.ports"))  fmt.Println("timeout: ", viper.GetDuration("server.timeout"))  fmt.Println("mysql ip: ", viper.GetString("mysql.ip"))  fmt.Println("mysql port: ", viper.GetInt("mysql.port"))  if viper.IsSet("redis.port") {    fmt.Println("redis.port is set")  } else {    fmt.Println("redis.port is not set")  }  fmt.Println("mysql settings: ", viper.GetStringMap("mysql"))  fmt.Println("redis settings: ", viper.GetStringMap("redis"))  fmt.Println("all settings: ", viper.AllSettings())}複製程式碼

我們在配置檔案 config.toml 中新增protocols和ports配置:

[server]protocols = ["http", "https", "port"]ports = [10000, 10001, 10002]timeout = 3s複製程式碼

編譯、執行程式,輸出:

protocols:  [http https port]ports:  [10000 10001 10002]timeout:  3smysql ip:  127.0.0.1mysql port:  3306redis.port is setmysql settings:  map[database:awesome ip:127.0.0.1 password:123456 port:3306 user:dj]redis settings:  map[ip:127.0.0.1 port:7381]all settings:  map[app_name:awesome web log_level:DEBUG mysql:map[database:awesome ip:127.0.0.1 password:123456 port:3306 user:dj] redis:map[ip:127.0.0.1 port:7381] server:map[ports:[10000 10001 10002] protocols:[http https port]]]複製程式碼

如果將配置中的redis.port註釋掉,將輸出redis.port is not set。

上面的示例中還演示了如何使用time.Duration型別,只要是time.ParseDuration接受的格式都可以,例如3s、2min、1min30s等。

設定鍵值

viper 支援在多個地方設定,使用下面的順序依次讀取:

呼叫Set顯示設定的;命令列選項;環境變數;配置檔案;預設值。viper.Set

如果某個鍵通過viper.Set設定了值,那麼這個值的優先順序最高。

viper.Set("redis.port", 5381)複製程式碼

如果將上面這行程式碼放到程式中,執行程式,輸出的redis.port將是 5381。

命令列選項

如果一個鍵沒有通過viper.Set顯示設定值,那麼獲取時將嘗試從命令列選項中讀取。 如果有,優先使用。viper 使用 pflag 庫來解析選項。 我們首先在init方法中定義選項,並且呼叫viper.BindPFlags繫結選項到配置中:

func init() {  pflag.Int("redis.port", 8381, "Redis port to connect")  // 繫結命令列  viper.BindPFlags(pflag.CommandLine)}複製程式碼

然後,在main方法開頭處呼叫pflag.Parse解析選項。

編譯、執行程式:

$ ./main.exe --redis.port 9381awesome webDEBUGmysql ip:  127.0.0.1mysql port:  3306mysql user:  djmysql password:  123456mysql database:  awesomeredis ip:  127.0.0.1redis port:  9381複製程式碼

如何不傳入選項:

$ ./main.exeawesome webDEBUGmysql ip:  127.0.0.1mysql port:  3306mysql user:  djmysql password:  123456mysql database:  awesomeredis ip:  127.0.0.1redis port:  7381複製程式碼

注意,這裡並不會使用選項redis.port的預設值。

但是,如果通過下面的方法都無法獲得鍵值,那麼返回選項預設值(如果有)。試試註釋掉配置檔案中redis.port看看效果。

環境變數

如果前面都沒有獲取到鍵值,將嘗試從環境變數中讀取。我們既可以一個個繫結,也可以自動全部繫結。

在init方法中呼叫AutomaticEnv方法繫結全部環境變數:

func init() {  // 繫結環境變數  viper.AutomaticEnv()}複製程式碼

為了驗證是否繫結成功,我們在main方法中將環境變數 GOPATH 打印出來:

func main() {  // 省略部分程式碼  fmt.Println("GOPATH: ", viper.Get("GOPATH"))}複製程式碼

通過 系統 -> 高階設定 -> 新建 建立一個名為redis.port的環境變數,值為 10381。 執行程式,輸出的redis.port值為 10381,並且輸出中有 GOPATH 資訊。

也可以單獨繫結環境變數:

func init() {  // 繫結環境變數  viper.BindEnv("redis.port")  viper.BindEnv("go.path", "GOPATH")}func main() {  // 省略部分程式碼  fmt.Println("go path: ", viper.Get("go.path"))}複製程式碼

呼叫BindEnv方法,如果只傳入一個引數,則這個引數既表示鍵名,又表示環境變數名。 如果傳入兩個引數,則第一個引數表示鍵名,第二個引數表示環境變數名。

還可以通過viper.SetEnvPrefix方法設定環境變數字首,這樣一來,通過AutomaticEnv和一個引數的BindEnv繫結的環境變數, 在使用Get的時候,viper 會自動加上這個字首再從環境變數中查詢。

如果對應的環境變數不存在,viper 會自動將鍵名全部轉為大寫再查詢一次。所以,使用鍵名gopath也能讀取環境變數GOPATH的值。

配置檔案

如果經過前面的途徑都沒能找到該鍵,viper 接下來會嘗試從配置檔案中查詢。 為了避免環境變數的影響,需要刪除redis.port這個環境變數。

看快速使用中的示例。

預設值

在上面的快速使用一節,我們已經看到了如何設定預設值,這裡就不贅述了。

讀取配置從io.Reader中讀取

viper 支援從io.Reader中讀取配置。這種形式很靈活,來源可以是檔案,也可以是程式中生成的字串,甚至可以從網路連線中讀取的位元組流。

package mainimport (  "bytes"  "fmt"  "log"  "github.com/spf13/viper")func main() {  viper.SetConfigType("toml")  tomlConfig := []byte(`app_name = "awesome web"# possible values: DEBUG, INFO, WARNING, ERROR, FATALlog_level = "DEBUG"[mysql]ip = "127.0.0.1"port = 3306user = "dj"password = 123456database = "awesome"[redis]ip = "127.0.0.1"port = 7381`)  err := viper.ReadConfig(bytes.NewBuffer(tomlConfig))  if err != nil {    log.Fatal("read config failed: %v", err)  }  fmt.Println("redis port: ", viper.GetInt("redis.port"))}複製程式碼
Unmarshal

viper 支援將配置Unmarshal到一個結構體中,為結構體中的對應欄位賦值。

package mainimport (  "fmt"  "log"  "github.com/spf13/viper")type Config struct {  AppName  string  LogLevel string  MySQL    MySQLConfig  Redis    RedisConfig}type MySQLConfig struct {  IP       string  Port     int  User     string  Password string  Database string}type RedisConfig struct {  IP   string  Port int}func main() {  viper.SetConfigName("config")  viper.SetConfigType("toml")  viper.AddConfigPath(".")  err := viper.ReadInConfig()  if err != nil {    log.Fatal("read config failed: %v", err)  }  var c Config  viper.Unmarshal(&c)  fmt.Println(c.MySQL)}複製程式碼

編譯,執行程式,輸出:

{127.0.0.1 3306 dj 123456 awesome}複製程式碼
儲存配置

有時候,我們想要將程式中生成的配置,或者所做的修改儲存下來。viper 提供了介面!

WriteConfig:將當前的 viper 配置寫到預定義路徑,如果沒有預定義路徑,返回錯誤。將會覆蓋當前配置;SafeWriteConfig:與上面功能一樣,但是如果配置檔案存在,則不覆蓋;WriteConfigAs:儲存配置到指定路徑,如果檔案存在,則覆蓋;SafeWriteConfig:與上面功能一樣,但是入股配置檔案存在,則不覆蓋。

下面我們通過程式生成一個config.toml配置:

package mainimport (  "log"  "github.com/spf13/viper")func main() {  viper.SetConfigName("config")  viper.SetConfigType("toml")  viper.AddConfigPath(".")  viper.Set("app_name", "awesome web")  viper.Set("log_level", "DEBUG")  viper.Set("mysql.ip", "127.0.0.1")  viper.Set("mysql.port", 3306)  viper.Set("mysql.user", "root")  viper.Set("mysql.password", "123456")  viper.Set("mysql.database", "awesome")  viper.Set("redis.ip", "127.0.0.1")  viper.Set("redis.port", 6381)  err := viper.SafeWriteConfig()  if err != nil {    log.Fatal("write config failed: ", err)  }}複製程式碼

編譯、執行程式,生成的檔案如下:

app_name = "awesome web"log_level = "DEBUG"[mysql]  database = "awesome"  ip = "127.0.0.1"  password = "123456"  port = 3306  user = "root"[redis]  ip = "127.0.0.1"  port = 6381複製程式碼
監聽檔案修改

viper 可以監聽檔案修改,熱載入配置。因此不需要重啟伺服器,就能讓配置生效。

package mainimport (  "fmt"  "log"  "time"  "github.com/spf13/viper")func main() {  viper.SetConfigName("config")  viper.SetConfigType("toml")  viper.AddConfigPath(".")  err := viper.ReadInConfig()  if err != nil {    log.Fatal("read config failed: %v", err)  }  viper.WatchConfig()  fmt.Println("redis port before sleep: ", viper.Get("redis.port"))  time.Sleep(time.Second * 10)  fmt.Println("redis port after sleep: ", viper.Get("redis.port"))}複製程式碼

只需要呼叫viper.WatchConfig,viper 會自動監聽配置修改。如果有修改,重新載入的配置。

上面程式中,我們先列印redis.port的值,然後Sleep 10s。在這期間修改配置中redis.port的值,Sleep結束後再次列印。 發現打印出修改後的值:

redis port before sleep:  7381redis port after sleep:  73810複製程式碼

另外,還可以為配置修改增加一個回撥:

viper.OnConfigChange(func(e fsnotify.Event) {  fmt.Printf("Config file:%s Op:%s\\n", e.Name, e.Op)})複製程式碼

這樣檔案修改時會執行這個回撥。

  • BSA-TRITC(10mg/ml) TRITC-BSA 牛血清白蛋白改性標記羅丹明
  • Helm 2 、Helm 3 比較