（转）nginx+redis+lua 共享内存

潇洒紫焰

转自：http://blog.sina.com.cn/s/blog_6f67b91d0101664g.html

环境：nginx + redis
起因：项目中有些接口是需要客户端轮询去访问的，这样所造成的后果就是这些接口一直占用redis内存，造成其他接口效率的降低（如果此时正好赶上JOB运行，redis的消耗就会变得更高），此时考虑将这些问题接口的数据放到nginx共享内存里去，将redis的内存解放出来，然后当这些问题接口的数据发生变化时我们去手动刷新共享内存中的值，具体的使用 nginx + lua

lua的安装这里不做说明，网上很多教程，可以参考下面的两篇文章去实现。
具体实现:我这里一共分成三个部分 取，增加，减少(增加和减少 暂未做合并)
主要配置文件 nginx.conf 和三个lua文件(做主要的业务处理)

我这里的调用方式的url方式。和调用接口一样

1.nginx.conf server节点下新建
location /msg/get.json {
            content_by_lua_file /xx/xx/lua/msg_get.lua;
        }
location /msg/add.json {
            content_by_lua_file /xx/xx/lua/msg_add.lua;
        }
        location /msg/reduce.json {
            content_by_lua_file /xx/xx/lua/msg_reduce.lua;
        }
2.取 msg_get.lua
ngx.header.content_type = "application/json; charset=UTF-8";
local redisEnv = require "resty.redis";
--redis对象，请参考redis命令
local redis = redisEnv:new();
--声明共享内存config
local config = ngx.shared.config;
local uid=ngx.var.arg_uid
--业务上的验证
local ok, err = redis:connect('10.xxx.xx5.1xx', 'xx79');
if not ok then
    ngx.log(ngx.ERR, err);
    ngx.exit(ngx.HTTP_SERVICE_UNAVAILABLE);
end
--得到url中的参数uid
local uid=ngx.var.arg_uid
--业务  验证是否登录
local redistoken=redis:get(uid.."utoken");
if redistoken~=ngx.var.arg_token then
        ngx.say("not login");
        ngx.exit(ngx.HTTP_SERVICE_UNAVAILABLE);
end
--从共享内存中取数据
local msg2 = config:get("BPF"..uid)
if not msg2 then
msg2 = redis:llen("BPF"..uid)
if not msg2 then
msg2=0
end
--写入共享内存
config:set("BPF"..uid, msg2);
end
--拼接json
local cjson = require "cjson"
local data = {}
    data.message= "ok";
    data.status=200;
    data.attachment={}
    data.attachment["102"]=msg2
redis:set_keepalive(1000,1024);
local json=cjson.encode(data);
ngx.say(json);#ngx.say 是 lua 显露給模块的接口
ngx.exit(ngx.HTTP_OK);
3.增加 msg_add.lua
ngx.header.content_type = "application/json; charset=UTF-8";
local redisEnv = require "resty.redis";
local redis = redisEnv:new();
--声明共享内存
local config = ngx.shared.config;
--得到请求参数 key
local key=ngx.var.arg_key
local oldNum=config:get(key)
if not oldNum then
oldNum=redis:llen(key)
if not oldNum then
oldNum=0
end
end
--写入共享内存  我这里是每次加1，根据需要可以将变化的值已参数形式传递过来
config:set(key, oldNum+1);
ngx.say("ok");
ngx.exit(ngx.HTTP_OK);
4.减少 msg_reduce.lua
ngx.header.content_type = "application/json; charset=UTF-8";
local redisEnv = require "resty.redis";
local redis = redisEnv:new();
--声明共享内存
local config = ngx.shared.config;
--得到请求参数 key
local key=ngx.var.arg_key
local oldNum=config:get(key)
if not oldNum then
oldNum=redis:llen(key)
if not oldNum then
oldNum=0
end
end
if oldNum>0 then
--写入共享内存
config:set(key, oldNum-1);
end
ngx.say("ok");
ngx.exit(ngx.HTTP_OK);
5.重启nginx  nginx -s reload
6.测试
取： http://12.1x1.1x1.72/msg/get.json?uid=123
增加:http://12.1x1.1x1.72/msg/add.json?key=BPF123
减少:http://12.1x1.1x1.72/msg/reduce.json?key=BPF123

PS:参考 ：http://huoding.com/2012/08/31/156
          http://www.udpwork.com/item/8177.html这两篇文章