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 = ';'
}
}
请在包中查看。
包含了一个如何使用这个包的例子。
请在包中查看。
文章浏览阅读5.3k次,点赞2次,收藏6次。使用stringstream对象简化类型转换C++标准库中的<sstream>提供了比ANSI C的<stdio.h>更高级的一些功能,即单纯性、类型安全和可扩展性。在本文中,我将展示怎样使用这些库来实现安全和自动的类型转换。为什么要学习如果你已习惯了<stdio.h>风格的转换,也许你首先会问:为什么要花额外的精力来学习基于<sstream&g..._stringstream
文章浏览阅读1.5k次。pyspider 是一个用python实现的功能强大的网络爬虫系统,能在浏览器界面上进行脚本的编写,功能的调度和爬取结果的实时查看,后端使用常用的数据库进行爬取结果的存储,还能定时设置任务与任务优先级等。本篇文章只是对这个框架使用的大体介绍,更多详细信息可见官方文档。安装首先是环境的搭建,网上推荐的各种安装命令,如: pip install pyspider但是因为各种权限的..._response.doc
文章浏览阅读3.2k次。vue + blockly 自定义块、工具箱、主题自定义块建议使用 Blockly Developer Tools 方便而且选择多样,随时生成块代码。自定义块块由三个组件组成:块定义对象:定义块的外观和行为,包括文本、颜色、字段和连接。工具箱引用:对工具箱 XML 中块类型的引用,因此用户可以将其添加到工作区。生成器函数:生成此块的代码字符串。它总是用 JavaScript 编写,即使目标语言不是 JavaScript。通过 Blockly Developer Tools _blockly vue
文章浏览阅读158次。最新笔记本显卡性能排名总表最新笔记本显卡性能排名总表以下排名整理自国外网站,以性能排名,越往前性能越好第一梯队:高端显卡GeForce GTX 280M SLIMobility Radeon HD 4870 X2GeForce GTX 260M SLIGeForce 9800M GTX SLIGeForce GTX 280MGeForce 9800M G..._mobility radeon x700 win98
文章浏览阅读2.6k次。解决Python词云库wordcloud不显示中文的问题2018-11-25背景:wordcloud是基于Python开发的词云生成库,功能强大使用简单。github地址:https://github.com/amueller/word_cloudwordcloud默认是不支持显示中文的,中文会被显示成方框。安装:安装命令:pip install wordcloud解决:经过测试发现不支持显示中文..._词云python代码无法输出文字
文章浏览阅读807次。扩展。_jmap 在线分析
文章浏览阅读1.6k次。现在web02项目有了controller 和 service 但还没有dao层,接下来我们就整合dao层1:配置数据源 --- 使用c3p0数据源_ssh框架service层调用dao有的能创建成功
文章浏览阅读725次。前两天在.net平台下要做一个管理系统,其中要用到一个功能就是将word文档转换为加有水印的pdf文档。在网上找了不少代码,贴出来给大家分享一下。 所需软件:word2007 + 微软的SaveAsPDFandXPS.exe(下载地址为http://download.micros_.net webapi word pdf添加水印 开源
文章浏览阅读5.5k次。1.问题说明openweather注册不成功,无法进行机器人验证2.解决方法无法收到谷歌提供的机器人验证信息,科学上网可解决。科学上网用来注册,后续登录和获取数据不需要,直接访问即可。_openweather api 创建账户被禁止了
文章浏览阅读4.7k次,点赞2次,收藏4次。一般需要ssh两个账户或两个设备才能有权限传输数据时经常遇到下面情况:我们一般连接跳板机使用的用户权限很小,能访问的文件不多,要是我想传输数据到我的设备上,却必须用跳板机连接设备怎么办?(别告诉我先在设备上搭个FTP服务器)下载winscp: 下载地址https://winscp.net/eng/downloads.php然后傻瓜式安装一键到底安装好就是配置访问服务器1、直接..._winscp 隧道 跳板机上的密码
文章浏览阅读1.3k次。JAVA语言概括和基本类型,数组,枚举_enum c++ java
文章浏览阅读316次。路由的概念路由器它称之为网关设备。路由器就是用于连接不同网络的设备路由器是位于OSI模型的第三层。路由器通过路由决定数据的转发。网关的背景:当时每家计算机厂商,用于交换数据的通信程序(协议)和数据描述格式各不相同。因此,就把用于相互转换这些协议和格式的计算机称为网关。路由器与三层交换器的对比路由协议对比路由器的作用:1.路由寻址2.实现不同网络之间相连的功能3.通过路由决定数据的转发,转发策略称为 路由选择。VLAN相关技术什么是VLAN?中文名称叫:虚拟局域网。虚_路由和vlan