说到配置文件热加载,这个功能在很多框架中都提供了,如beego,实现的效果就是当你修改文件后,会把你修改后的配置重新加载到配置文件中,而不用重启程序,这个功能在日常中还是非常实用的,毕竟很多时候,线上的配置文件不是想改就能改的。
这次就自己实现一个配置文件的热加载功能的包,并通过一个简单的例子对完成的包进行使用验证
配置文件热加载包的是实现
其实整体的思路还是比较简单的,当获取配置文件内容后,会开启一个goroutine,去 循环读配置文件,当然这里不可能不限制的一直循环,而是设置了一个定时器,定时去读文件,根据文件的修改时间是否变化,从而确定是否重新reload配置文件
实现的config 包的文件结构为:
├── config.go
└── config_notify.go
config.go:代码的主要处理逻辑
config_notify.go:主要定义了一个接口,用于当文件修改时间变化的时候执行回调
config_notify.go的代码相对来说比较简单,我们先看看这个代码:
package config
// 定义一个通知的接口
type Notifyer interface {
Callback(*Config)
}
这样当我们实现了Callback这个方法的时候,我们就实现了Notifyer这个接口,具体的调用在后面会说
在config.go中我们顶一个了一个结构体:
type Config struct {
filename string
lastModifyTime int64
data map[string]string
rwLock sync.RWMutex
notifyList []Notifyer
}
结构体中主要包含几个字段:
filename:配置文件名字
lastModifyTime:配置文件的最后修改时间
data:用于将从配置文件中读取的内容存储为map
rwlock:读写锁
notifyList:用于将调用该包的程序追加到切片中,用于通知调用上面在config_notify.go定义的callback回调函数
关于读取配置文件中的内容并存储到map中,这里定义了一个方法实现:
func (c *Config) parse()(m map[string]string,err error){
// 读文件并或将文件中的数据以k/v的形式存储到map中
m = make(map[string]string,1024)
file,err := os.Open(c.filename)
if err != nil{
return
}
var lineNo int
reader := bufio.NewReader(file)
for{
// 一行行的读文件
line,errRet := reader.ReadString('n')
if errRet == io.EOF{
// 表示读到文件的末尾
break
}
if errRet != nil{
// 表示读文件出问题
err = errRet
return
}
lineNo++
line = strings.TrimSpace(line) // 取出空格
if len(line) == 0 || line[0] == 'n' || line[0] == '+' || line[0] == ';'{
// 当前行为空行或者是注释行等
continue
}
arr := strings.Split(line,"=") // 通过=进行切割取出k/v结构
if len(arr) == 0{
fmt.Printf("invalid config,line:%dn",lineNo)
continue
}
key := strings.TrimSpace(arr[0])
if len(key) == 0{
fmt.Printf("invalid config,line:%dn",lineNo)
continue
}
if len(arr) == 1{
m[key] = ""
continue
}
value := strings.TrimSpace(arr[1])
m[key] = value
}
return
}









