多应用+插件架构,代码干净,二开方便,首家独创一键云编译技术,文档视频完善,免费商用码云13.8K 广告
# 自定义函数 调用回调函数,并把一个数组参数作为回调函数的参数 ~~~ local args = {...} or {} methodName(unpack(args, 1, table.maxn(args))) ~~~ # 使用场景 你要调用的函数名是未知的 函数参数类型和数目也是未知的 一般常用于在定时器处理逻辑之中 > 伪代码 ~~~ addTask(endTime, callback, params) if os.time() >= endTime then callback(unpack(params, 1, table.maxn(params))) end ~~~ # 小试牛刀 ~~~ local function run(x, y) ngx.say('run', x, y) end local function attack(targetId) ngx.say('targetId', targetId) end local function doAction(method, ...) local args = {...} or {} method(unpack(args, 1, table.maxn(args))) end doAction(run, 1, 2) doAction(attack, 1111) ~~~ 我们再新建一个模块 sample ~~~ local _M = {} function _M:hello(str) ngx.say('hello', str) end function _M.world(str) ngx.say('world', str) end return _M ~~~ 这个时候我们可以这样调用,代码接上文 因为sample模块的方法声明方式的不同 所以在调用时有些区别 主要是.和:的区别 [https://github.com/humbut/openresty-best-practices/blob/master/lua/dot_diff.md](https://github.com/humbut/openresty-best-practices/blob/master/lua/dot_diff.md) ~~~ local sample = require "sample" doAction(sample.hello, sample, ' 123') -- 相当于sample:hello('123') doAction(sample.world, ' 321') -- 相当于sample.world('321') ~~~ # 实战演练 以下代码为360公司公共组件之缓存模块,正是利用了部分特性 ~~~ -- { -- key="...", cache key -- exp_time=0, default expire time -- exp_time_fail=3, success expire time -- exp_time_succ=60*30, failed expire time -- lock={...} lock opsts(resty.lock) -- } function get_data_with_cache( opts, fun, ... ) local ngx_dict_name = "cache_ngx" -- get from cache local cache_ngx = ngx.shared[ngx_dict_name] local values = cache_ngx:get(opts.key) if values then values = json_decode(values) return values.res, values.err end -- cache miss! local lock = lock:new(ngx_dict_name, opts.lock) local elapsed, err = lock:lock("lock_" .. opts.key) if not elapsed then return nil, string.format("get data with cache not found and sleep(%ss) not found again", opts.lock_wait_time) end -- someone might have already put the value into the cache -- so we check it here again: values = cache_ngx:get(opts.key) if values then lock:unlock() values = json_decode(values) return values.res, values.err end -- get data local exp_time = opts.exp_time or 0 -- default 0s mean forever local res, err = fun(...) if err then exp_time = opts.exp_time_fail or exp_time else exp_time = opts.exp_time_succ or exp_time end -- update the shm cache with the newly fetched value cache_ngx:set(opts.key, json_encode({res=res, err=err}), exp_time) lock:unlock() return res, err end ~~~