动态更新配置
1. 设计说明
考虑到配置为全局生效,即需对所有工作进程共享。更新频率比较慢,使用lua_shared_dict进行存储。如下定义:
lua_shared_dict sysconfig 10k;
成员包括:
“time”:配置文件的生成的时间戳(用来判断文件是否有更新)eg:1585209315
“kxsip”:与可信控制服务数据交互IP地址eg:192.168.0.1
“kxsport”:与可信控制服务数据交互端口eg:8001
“gettokenapi”:请求userID对应的token的API接口eg:https://192.168.5.4:2233/token
“ssourl”:SSO服务器地址eg: https://12.52.46.82:5555/login
。。。
在nginx初始化中使用init_worker_by_lua_file 指令创建一个循环定时器,每次超时的时候去判断配置文件是否更新了。如果更新了重新加载。
通过在工作线程中使用rewrite_by_lua_block指令,获取任意时刻的配置情况测试代码的可用性。
2.环境搭建
虚拟机部署代理软件,IP:192.168.6.141
3.编码
nginx.conf
update.lua:查看是否有配置更新的定时任务的创建及更新处理。
# Lua
local cjson = require("cjson")
function handler()
local configs = ngx.shared.sysconfigs
local file = io.open("/usr/local/openresty/nginx/conf/sysconfig.json", "r")
local str = file:read("*all")
file:close()
local obj = cjson.decode(str)
if obj.time ~= configs:get("time") then
configs:set("time", obj.time)
configs:set("kxsip", obj.kxsip)
configs:set("kxsport", obj.kxsport)
configs:set("gettokenapi", obj.gettokenapi)
configs:set("ssourl", obj.ssourl)
end
end
if 0 == ngx.worker.id() then
ngx.timer.every(10, handler)
ngx.log(ngx.ALERT, "update timer create")
end
testconfig.lua:测试脚本,主要是为了查看是否更新,验证测试结果。
local configs = ngx.shared.sysconfigs
ngx.say("time:", configs:get("time"))
ngx.say("kxsip:", configs:get("kxsip"))
ngx.say("kxsport:", configs:get("kxsport"))
ngx.say("gettokenapi:", configs:get("gettokenapi"))
ngx.say("ssourl:", configs:get("ssourl"))
ngx.exit(403)
sysconfig.json:更新配置设计样例。
{
"time": "1585805839",
"kxsip": "192.168.0.1",
"kxsport": "8001",
"gettokenapi": "https://192.168.5.4:2233/token",
"ssourl": "https://12.52.46.82:5555/login"
}
4.测试
设置好脚本,及配置文件,访问测试url:
此时sysconfig.json为
输出如下
修改配置
此时sysconfig.json为
输出如下:
详细下载链接
https://download.csdn.net/download/weixin_39407199/12299809
lua+nginx详细指南
https://download.csdn.net/download/weixin_39407199/12363519