# 自定义函数
调用回调函数,并把一个数组参数作为回调函数的参数
~~~
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
~~~
- 序
- Lua简介
- Lua环境搭建
- 基础数据类型
- 表达式
- 控制结构
- if/else
- while
- repeat
- 控制结构for的使用
- break,return
- Lua函数
- 函数的定义
- 函数的参数
- 函数的返回值
- 函数回调
- 模块
- String库
- Table库
- 日期时间函数
- 数学库函数
- 文件操作
- 元表
- 面向对象编程
- FFI
- LuaRestyRedisLibrary
- select+set_keepalive组合操作引起的数据读写错误
- redis接口的二次封装(简化建连、拆连等细节)
- redis接口的二次封装(发布订阅)
- pipeline压缩请求数量
- script压缩复杂请求
- LuaCjsonLibrary
- json解析的异常捕获
- 稀疏数组
- 空table编码为array还是object
- 跨平台的库选择
- PostgresNginxModule
- 调用方式简介
- 不支持事务
- 超时
- 健康监测
- SQL注入
- LuaNginxModule
- 执行阶段概念
- 正确的记录日志
- 热装载代码
- 阻塞操作
- 缓存
- sleep
- 定时任务
- 禁止某些终端访问
- 请求返回后继续执行
- 调试
- 调用其他C函数动态库
- 我的lua代码需要调优么
- 变量的共享范围
- 动态限速
- shared.dict 非队列性质
- 如何添加自己的lua api
- 正确使用长链接
- 如何引用第三方resty库
- 使用动态DNS来完成HTTP请求
- 缓存失效风暴
- Lua
- 下标从1开始
- 局部变量
- 判断数组大小
- 非空判断
- 正则表达式
- 不用标准库
- 虚变量
- 函数在调用代码前定义
- 抵制使用module()函数来定义Lua模块
- 点号与冒号操作符的区别
- 测试
- 单元测试
- API测试
- 性能测试
- 持续集成
- 灰度发布
- web服务
- API的设计
- 数据合法性检测
- 协议无痛升级
- 代码规范
- 连接池
- c10k编程
- TIME_WAIT问题
- 与Docker使用的网络瓶颈
- 火焰图
- 什么时候使用
- 显示的是什么
- 如何安装火焰图生成工具
- 如何定位问题