https://pmlpml.gitee.io/service-computing/post/ex-pkg-ini/
watch函数需要实现两个功能,分别是读ini配置文件和监听文件在这一过程中是否发生变化。接下来分别讲如何实现这两个功能。
https://ini.unknwon.io/docs/intro/getting_started介绍了解析ini文件的一个范例,我们的目的是实现其一部分功能,分别是获取段落的方法getSection() 和获取段落中键对应的值的方法getValByKey() 。
section.go中定义了一个段的结构Section,它包含一个字典,字典的键和值都为string类型。
Section这个结构实现了getValByKey() 。
文件中还定义了New一个Section的方法,对其中的字典结构做了初始化,所以在程序中可以这样写:
sec := NewSection()
就获得了一个新分配的Section的指针。
//Section 定义了一个段落的内容
type Section struct {
mp map[string]string
}
func (sec *Section) GetValByKey(key string) string {
return sec.mp[key]
}
func NewSection() *Section {
return &Section {
mp: make(map[string]string),
}
}
你可以在section_test.go中看到相关的测试。
另一个结构iniCFG定义在read.go中,它存储了一整个ini文件的内容,其结构内部也是一个字典,键是string类型,值是Section的指针类型。(使用Section对象的指针而不是Section,一方面是为了函数调用更快,另一方面是希望实现这样的效果:即使一个Section已经存在iniCFG中,修改这个Section时iniCFG中的内容也会跟着修改)。
iniCFG实现了getSection() 方法,以及与Section类似,可以通过NewiniCFG来获得一个已经初始化好的iniCFG对象的指针。
//iniCFG 定义了配置文件内容的存储结构
type iniCFG struct {
mp map[string]*Section
}
func NewIniCFG() *iniCFG {
return &iniCFG {
mp: make(map[string]*Section),
}
}
func (cfg *iniCFG) GetSection(secName string) (*Section, error) {
mpSecName, isPresent := cfg.mp[secName]
if isPresent == false {
return mpSecName, SecNameDoesNotExist {
secName}
}
return mpSecName, nil
}
iniCFG的测试在read_test.go文件中第一个函数。
我的实现方法比较笨,先将文件内容转化为一个字符串,然后遍历字符串的每一个字符,找到段名、变量名和变量值并存入iniCFG结构中。
最后将iniCFG结构传入信道中,留待其他线程读取和使用。
func Read(filename string, ch_cfg chan *iniCFG) {
//获取文件内容
content, err := ioutil.ReadFile("data.ini")
if err != nil {
panic(err)
}
//fmt.Print(string(content))
//readCount++
//解析文件内容并存储在cfg中
cfg := NewIniCFG()
sec := NewSection()
cfg.mp[""] = sec
var key, value string
var j int
for i := 0; i < len(content); {
//下面的一行仅在测试时需要用到
//time.Sleep(time.Duration(150) * time.Millisecond)
ch := content[i]
//如果是注释符号,则将整行忽略掉
if ch == commentSymbol {
for i < len(content) && content[i] != '\n' {
i++
}
} else if ch == '[' {
//如果是左中括号,则获取括号中的字符串作为段名,注意不能包括左右括号
i++
for i < len(content) && (content[i] == ' ' || content[i] == '\t' || content[i] == '\n') {
i++
}
j = i
for i < len(content) && !(content[i] == ' ' || content[i] == '\t' || content[i] == '\n' || content[i] == ']') {
i++
}
secName := string(content[j:i])
sec = NewSection()
cfg.mp[secName] = sec
// fmt.Print("hahahahaha")
// fmt.Print(secName)
for i < len(content) && content[i] != ']' {
i++
}
i++
} else if ch == ' ' || ch == '\t' || ch == '\n' {
//如果是空格等,则跳过
i++
} else {
//是键值对,则分别读取等号左侧和右侧字符串,并存入当前的段对应的字典中
j = i
for i < len(content) && !(content[i] == '=' || content[i] == '\t' || content[i] == ' ' || content[i] == '\n') {
i++
}
key = string(content[j:i])
// fmt.Print("hahahahaha")
// fmt.Print(key)
for i < len(content) && content[i] != '=' {
i++
}
i++
for i < len(content) && (content[i] == ' ' || content[i] == '\t' || content[i] == '\n') {
i++
}
j = i
for i < len(content) && !(content[i] == ' ' || content[i] == '\t' || content[i] == '\n') {
i++
}
value = string(content[j:i])
sec.mp[key] = value
}
}
finishRead = true
//readCount--
ch_cfg <- cfg
}
注意到一点,当文件读取完后,全局变量finishRead被设为true,这在后面会用到。
关于读取ini配置文件应该有更简洁的方法,比如每次读取一行。
可以参考一下这个http://c.biancheng.net/view/5407.html
可以在read_test.go文件中的第二个函数TestRead看到对读取整个ini文件的测试。
不过现在还不急,因为监听还未实现。
listener接口只包含了一个方法listen,参数是要监听的文件的名字,以及一个信道,用于向主线程watch传递信息。(前面也讲过,Read函数同样有一个信道,向主线程传递存储文件信息的iniCFG结构)
MyListener实现了listen方法。大致的实现如下:
type Listener interface {
listen(filename string, ch chan int )
}
type MyListener struct {
}
func (listener MyListener) listen(filename string, ch chan int ) {
lastModTime := GetFileModTime(filename)
for {
modTime := GetFileModTime(filename)
if (modTime != lastModTime) {
lastModTime = modTime
fmt.Print("fie changed, restart reading.\n")
ch <- 1
}
if (finishRead) {
ch <- 0
return
}
}
}
watch函数分别调用了Read函数和listen函数,且它们都在新的go程中运行。
首先运行listen函数,开始监听文件是否被修改
紧接着运行Read函数,开始读取ini配置文件
在一个无限for循环中获取来自listen传到信道ch中的值,如前所述,值为1时说明文件在读的过程被修改了,那么新开一个go程重新运行Read函数,新开的go程传到信道ch_cfg中的值会覆盖以前的go程传到ch_cfg中的值(其实也不一定,毕竟线程的运行顺序比较难把控,有可能以前的go程覆盖掉现在的go程,但暂时不细究这一点);如果信道ch中的值为0,说明最新的go程中运行的Read函数执行结束,且这个过程中文件没有被修改,那么就可以获取ch_cfg中的值并返回了。
//Watch 读取ini配置文件,将信息存储在CFG结构中并返回
//listener 是监听器,在另一个go程中运行,如果读取文件过程中文件内容发生改变,则通过信道告知当前进程,当前进程重开一个go程,重新读取
func Watch(filename string ,listener Listener) (*iniCFG, error) {
ch := make(chan int)
ch_cfg := make(chan *iniCFG)
go listener.listen(filename, ch)
go Read(filename, ch_cfg)
for {
ret := <-ch
if (ret == 0) {
return <-ch_cfg, nil
} else if (ret == 1) {
go Read(filename, ch_cfg)
}
}
}
到这里还没有结束,很容易发现有一个问题:listen函数在finishRead为true时就向信道ch中传一个值0并return,但如果这发生在文件已经被修改过的情况下,第二个Read函数正在运行当中,运行结束的是第一个Read函数,会导致什么?
相当于返回的还是一个Read读到的内容,并没有读到文件修改后的最新信息。
所以需要对listen函数作一点修改,增加一个全局变量readCount,初始化为0。每次发现文件被修改时即将readCount的值加1,代表有一个新的线程正在读取文件,在finishRead为true时再加一层判断:如果readCount不为0,代表还有线程在读取文件,并且很有可能是文件被修改后才运行的线程,那么我们忽略这一次的finishRead,将readCount的值减1,finishRead设为false,等待最新的Read函数返回最新的iniCFG信息(这才是我们要的)。
修改后listen函数如下:
func (listener MyListener) listen(filename string, ch chan int ) {
lastModTime := GetFileModTime(filename)
for {
modTime := GetFileModTime(filename)
if (modTime != lastModTime) {
lastModTime = modTime
fmt.Print("fie changed, restart reading.\n")
readCount++
ch <- 1
}
if (finishRead) {
if (readCount > 0) {
//有新开的read 线程未结束
readCount--
finishRead = false
continue
}
ch <- 0
return
}
}
}
至此大致的思路就讲完啦。
data.ini文件内容如下:
# possible values : production, development
app_mode = development
[ paths]
# Path to where grafana can store temp files, sessions, and the sqlite3 db (if that is used)
data = /home/git/grafana
[server ]
# Protocol (http or https)
protocol = http
# The http port to use
http_port = 9999
# Redirect to correct domain if host header does not match domain
# Prevents DNS rebinding attacks
enforce_domain = true
Section和iniCFG的测试较为简单,略过不讲。主要讲一下watch函数的测试(即包含了Read和listener两部分)。
比较两个iniCFG结构的不同,cfg0是运行watch函数读取filename对应文件得到的iniCFG结构,cfg则存储了预期的内容。
func TestRead(t *testing.T) {
filename := "data.ini"
var listener MyListener
cfg0, err := Watch(filename, listener)
if err != nil {
t.Error(err)
}
cfg := NewIniCFG()
// app_mode
sec := NewSection()
cfg.mp[""] = sec
sec.mp["app_mode"] = "development"
//不能直接比较两个map是否相同,即使内部完全相同,也会因为地址不同而不同
if (cfg.mp[""].mp["app_mode"] != cfg0.mp[""].mp["app_mode"]) {
t.Errorf("want %v, got %v.", cfg.mp[""].mp["app_mode"], cfg0.mp[""].mp["app_mode"] );
}
//paths
sec1 := NewSection()
cfg.mp["paths"] = sec1
sec1.mp["data"] = "/home/git/grafana"
if (cfg.mp["paths"].mp["data"] != cfg0.mp["paths"].mp["data"]) {
t.Errorf("want %v, got %v.", cfg.mp["paths"].mp["data"] , cfg0.mp["paths"].mp["data"] );
}
//server
sec2 := NewSection()
cfg.mp["server"] = sec2
sec2.mp["enforce_domain"] = "true"
if (cfg.mp["server"].mp["enforce_domain"] != cfg0.mp["server"].mp["enforce_domain"]) {
t.Errorf("want %v, got %v.", cfg.mp["server"].mp["enforce_domain"] , cfg0.mp["server"].mp["enforce_domain"] );
}
//全部打印出来,用于快速人工检查
// for key, value := range cfg0.mp {
// fmt.Print(key)
// fmt.Print(value)
// }
// t.Error(1)
}
首先是不阻塞读文件
由于读文件的速度太快,根本来不及在读文件过程中修改文件,所以为了测试listen的功能,我们在Read函数中每读一个字符就阻塞一下,利用time.Sleep()睡眠一段时间。
//下面一行只在测试时为了有充足时间修改文件才需要
time.Sleep(time.Duration(100) * time.Millisecond)
在命令行敲下命令运行go test后,打开data.ini文件,修改appmode,在development后加一个s,然后保存,切换到控制台等待程序运行结束。发现这样的结果:
如果得不到以上结果,可能是修改和保存文件的速度不够快,可以再手动调节一下读每个字符后的阻塞时间。
可以看到,watch函数在读的过程中能够通过listener监听文件的变化,如果文件被修改了,watch将读到修改后的文件内容。说明listener是可以与Read正常搭配工作的。
error.go中定义了SecNameDoesNotExist错误,在getSection() 中使用,当试图访问一个iniCFG结构中不存在的段时会返回这个错误。
定义这个错误的原因是如果不经判断地使用cfg.GetSection(sectionName).getValByKey(key),当sectionName并不存在时,GetSection() 返回的是一个空指针,对空指针调用方法会导致空指针访问异常。
//SecNameDoesNotExist 自定义错误,当试图访问一个iniCFG中不存在的Section时返回
type SecNameDoesNotExist struct {
secName string
}
func (err SecNameDoesNotExist) Error() string {
return fmt.Sprintf("Error: section %s does not exist!", err.secName)
}
注释符号默认为‘#’,在windows系统下变为’;’
//全局变量
var (
commentSymbol byte = '#'
finishRead = false
readCount = 0
)
func init() {
if runtime.GOOS == "windows" {
commentSymbol = ';'
}
}
请在包中查看。
包含了一个如何使用这个包的例子。
请在包中查看。
文章浏览阅读553次。在 jdbc.properties 文件中的 url 后面加上 ?serverTimezone=UTC加入之前的jdbc.properties文件:user=rootpassword=12345678url=jdbc:mysql://localhost:3306/testdriverClass=com.mysql.cj.jdbc.Driver加入之后:user=rootpassword=12345678url=jdbc:mysql://localhost:3306/test?serv_jdbc.properties timezone
文章浏览阅读1.4k次。计算机图形学基础教程孔令德答案【篇一:大学计算机图形学课程设】息科学与工程学院课程设计任务书题目:小组成员:巴春华、焦国栋成员学号:专业班级:计算机科学与技术、2009级本2班课程:计算机图形学指导教师:燕孝飞职称:讲师完成时间: 2011年12 月----2011年 12 月枣庄学院信息科学与工程学院制2011年12 月20日课程设计任务书及成绩评定12【篇二:计算机动画】第一篇《计算机图形学》..._计算机图形学基础教程 孔令德 答案
文章浏览阅读1k次。原标题:大数据分析Python库xlwings提升Excel工作效率教程Excel在当今的企业中非常非常普遍。在AAA教育,我们通常建议出于很多原因使用代码,并且我们的许多数据科学课程旨在教授数据分析和数据科学的有效编码。但是,无论您偏爱使用大数据分析Python的程度如何,最终,有时都需要使用Excel来展示您的发现或共享数据。但这并不意味着仍然无法享受大数据分析Python的某些效率!实际上,..._xlwings通过索引添加数据
文章浏览阅读911次。iefans为用户提供的jre8 64位是针对64位windows平台而开发的java运行环境软件,全称为java se runtime environment 8,包括Java虚拟机、Java核心类库和支持文件,不包含开发工具--编译器、调试器和其它工具。jre需要辅助软件--JavaPlug-in--以便在浏览器中运行applet。本次小编带来的是jre8 64位官方版下载,版本小号u211版..._jre8是什么
文章浏览阅读5k次。KASP基因分型介绍KASP(Kompetitive Allele-Specific PCR),即竞争性等位基因特异性PCR,原理上与TaqMan检测法类似,都是基于终端荧光信号的读取判断,每孔反应都是采用双色荧光检测一个SNP位点的两种基因型,不同的SNP对应着不同的荧光信号。KASP技术与TaqMan法类似,它与TaqMan技术不同的是,它不需要每个SNP位点都合成特异的荧光引物,它基于独特的..._kasp是什么
文章浏览阅读154次。华为现在比较火的还真就是新开发的鸿蒙系统了,那么在即将上市的华为p50手机上会不会预装鸿蒙系统呢?接下来我们就来一起了解一下华为官方发布的最新消息吧。1.华为p50最新消息相信大家都知道,随着华为鸿蒙OS系统转正日期临近,似乎全网的花粉们都在关注华为鸿蒙OS系统优化、生态建设等等,直接忽略了不断延期发布的华为P50手机,如今华为P50系列手机终于传来了最新的好消息,在经过一系列方案修改以后,终于被..._华为手机p50直接预装鸿蒙系统
文章浏览阅读2.1k次。Python编程的软件其实许多,作为一门面向大众的编程言语,许多修正器都有对应的Python插件,当然,也有特地的PythonIDE软件,下面我简单引见几个不错的Python编程软件,既有修正器,也有IDE,感兴味的朋友可以本人下载查验一下:1.VSCode:这是一个轻量级的代码修正器,由微软规划研发,免费、开源、跨途径,轻盈活络,界面精练,支撑常见的自动补全、语法提示、代码高亮、Git等功用,插..._python入门学什么好
文章浏览阅读3.2w次,点赞30次,收藏307次。准备数据集及加载,ImageFolder在很多机器学习或者深度学习的任务中,往往我们要提供自己的图片。也就是说我们的数据集不是预先处理好的,像mnist,cifar10等它已经给你处理好了,更多的是原始的图片。比如我们以猫狗分类为例。在data文件下,有两个分别为train和val的文件夹。然后train下是cat和dog两个文件夹,里面存的是自己的图片数据,val文件夹同train。这样我们的..._torch vgg训练自己的数据集
文章浏览阅读968次。论文+系统+远程调试+重复率低+二次开发+毕业设计_论文系统设计法
文章浏览阅读134次。1. 为什么要有转义?ASCII 表中一共有 128 个字符。这里面有我们非常熟悉的字母、数字、标点符号,这些都可以从我们的键盘中输出。除此之外,还有一些非常特殊的字符,这些字符,我通常很难用键盘上的找到,比如制表符、响铃这种。为了能将那些特殊字符都能写入到字符串变量中,就规定了一个用于转义的字符 \ ,有了这个字符,你在字符串中看的字符,print 出来后就不一定你原来看到的了。举个例子>..._pytyhon2、python3对%转义吗
文章浏览阅读1.3k次。我这几天需要做一个Java程序,需要通过jar的形式运行,还要生成文件。最终这个程序是要给被人用的,可能那个用的人还不懂代码。于是我面临一个问题:生成的文件一定不能存绝对路径。刚开始我想得很简单,打绝对路径改成相对路径不就行了吗?于是有了这样的代码:String path = "../test.txt";File file = new File(path);……这个写法本身并没有问题,直接运行代码..._jar启动文件路径中存在!
文章浏览阅读598次。如果你知道 VSCode,一说起它,你可能第一个想到的就是把它当做一个代码编辑器,而它的界面应该可能大概率是这样的——如果你恰好又是个程序员,那你可能经常会用到它,不管是 Python、JS 还是 C++ 等各种语言对应的文件,都可以用它来进行简单的编辑和整理,甚至是运行和 debug......但是今天要讲的显然不是这些,经过小美的多方研究,发现了即使是对于大多数并不了解 VSCode,也完全不..._vscode weixin read