通过信号实现配置文件热更新

简介: 通过信号来实现一遍配置文件热更新

配置文件修改后,要达到及时生效,热加载的目的,那么可以通过2种方式实现

  1. 定时器循环,查看文件更新时间,如果发现有修改,那么重新加载
  2. 监听信号,文件更改后,发送信号,通过捕获信号,再重新加载


例如,线上的应用日志级别为 info ,出现故障后,你需要开启 debug 来排查日志,但是把日志级别改成 debug ,那么你不得不重启应用,可能故障现象就不存在或不好重现了,而且重启服务可能会影响用户体验。


上一篇已经介绍了通过定时器实现配置文件热更新,以下我就介绍另一种信号的方式来实现吧。

signal.go 

packagemainimport (
"encoding/json""fmt""io/ioutil""log""os""os/signal""syscall""time")
//全局自定义拦截varintercept []Interceptvarfilenamestring="intercept.json"typeInterceptstruct {
Urlstring`json:"url"`Methodstring`json:"method"`RespHeadermap[string]string`json:"resp_header"`RespBodyinterface{}       `json:"resp_body"`RespCodeint`json:"resp_code"`}
//读取自定义响应文件funcRead_resp() {
intercept_data, err :=ioutil.ReadFile(filename)
iferr!=nil {
log.Fatalln(err)
    }
err=json.Unmarshal(intercept_data, &intercept)
iferr!=nil {
log.Fatalln(err)
    }
}
funcmain() {
//初始读取Read_resp()
//监听信号sig :=make(chanos.Signal, 1)
signal.Notify(sig, syscall.SIGUSR1)
gofunc() {
for {
select {
//获取到信号,再次执行case<-sig:
Read_resp()
            }
        }
    }()
//循环打印for {
time.Sleep(1*time.Second)
iflen(intercept) >0 {
fmt.Println(intercept[0].RespBody)
        }
    }
}

配置文件

intercept.json 

[{
"url": "http://test.cloudcare.cn/api/v1/workspace/member/list",
"method": "get",
"resp_body": {"msg": "d"},
"resp_header": {"Content-Type": "application/json"},
"resp_code": 200}]


运行程序后,我编辑配置文件内容 resp_body  ,然后手动给进程发送信号

先查找出运行进程的pid

[root@izbp152ke14timzud0du15z signal]# ps -ef|grep signalroot     278002688015:58 pts/1    00:00:00 ./signal
root     2787617301015:58 pts/2    00:00:00 grep--color=auto signal


通过kill给进程发送信号

[root@izbp152ke14timzud0du15z signal]# kill -USR1 27800


程序捕获到信号后,会重新读取配置文件

map[msg:d]
map[msg:d]
map[msg:d]
map[msg:d]
map[msg:ff]
map[msg:ff]
map[msg:ff]
map[msg:ff]
map[msg:ff]
map[msg:ff]
map[msg:dde]
map[msg:dde]
目录
打赏
0
0
0
0
4
分享
相关文章
Ngnix17---Ngnix服务的信号控制值USR2
Ngnix17---Ngnix服务的信号控制值USR2
从源码角度分析 Nacos 配置文件加载以及加载优先级
从源码角度分析 Nacos 配置文件加载以及加载优先级
906 0
【Magisk模块】全局120hz 面具模块
【Magisk模块】全局120hz 面具模块
1672 0
配置热更新/支持 Reload、QUIC 桥接再升级
12月,NanoMQ稳步更新,最新的0.15版本将于近期发布,将增加配置热更新功能和Reload命令;MQTT over QUIC桥接再次得到升级,增加了拥塞控制和QoS消息优先传输。
EMQ
245 0
配置热更新/支持 Reload、QUIC 桥接再升级
从源码研究如何不重启项目实现redis配置动态切换
上一篇Websocket的续篇暂时还没有动手写,这篇算是插播吧。今天讲讲不重启项目动态切换redis服务。
从源码研究如何不重启项目实现redis配置动态切换
Android源码分析--Android系统启动
Android源码分析--Android系统启动
266 0
Android源码分析--Android系统启动
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等