本文将带领大家精读3个Nginx Lua编程实战案例，学不会就来砍我

---启动调试，正式环境请注释local mobdebug = require("luaScript.initial.mobdebug");mobdebug.start();--导入自定义的RedisOperator模块local redisOp = require("luaScript.redis.RedisOperator");--创建自定义的redis操作对象local red = redisOp:new();--打开连接red:open();--获取访问次数local visitCount = red:incrValue("demo:visitCount");if visitCount ==  then --秒内过期 red:expire("demo:visitCount", );end--将访问次数设置到Nginx变量ngx.var.count = visitCount;--归还连接到连接池red:close();

#点击次数统计的演示 location /visitcount { #定义一个Nginx变量，用于在Lua脚本中保存访问次数 set $count ; access_by_lua_file luaScript/redis/RedisVisitCount.lua; echo "10s内总的访问次数为: " $count; }

---启动调试，正式环境请注释local mobdebug = require("luaScript.initial.mobdebug");mobdebug.start();--导入自定义的基础模块local basic = require("luaScript.module.common.basic");--导入自定义的RedisOperator模块local redisOp = require("luaScript.redis.RedisOperator");local PREFIX = "GOOD_CACHE:"--RedisCacheDemo类local _RedisCacheDemo = { }_RedisCacheDemo.__index = _RedisCacheDemo--类的方法newfunction _RedisCacheDemo.new(self) local object = {} setmetatable(object, self) return object;end--根据商品id取得缓存function _RedisCacheDemo.getCache(self,goodId) --创建自定义的redis操作对象 local red = redisOp:new(); --打开连接 if not red:open() then basic:error("redis连接失败"); return nil; end --获取缓存数据 local json = red:getValue(PREFIX .. goodId); red:close(); if not json or json==ngx.null then basic:log(goodId .. "的缓存没有命中"); return nil; end basic:log(goodId .. "缓存成功命中"); return json;end--通过capture方法回源上游接口function _RedisCacheDemo.goUpstream(self) local request_method = ngx.var.request_method local args = nil --获取参数的值 if "GET" == request_method then args = ngx.req.get_uri_args() elseif "POST" == request_method then ngx.req.read_body() args = ngx.req.get_post_args() end --回源上游接口,比如Java后端rest接口 local res = ngx.location.capture("/java/good/detail",{ method = ngx.HTTP_GET, args = args --重要：将请求参数原样向上游传递 }) basic:log("上游数据获取成功"); --返回上游接口的响应体body return res.body;end--设置缓存，此方法主要用于模拟Java后台代码function _RedisCacheDemo.setCache(self, goodId ,goodString) --创建自定义的redis操作对象local red = redisOp:new(); --打开连接 if not red:open() then basic:error("redis连接失败"); return nil; end --set缓存数据 red:setValue(PREFIX .. goodId,goodString); --秒内过期 red:expire(PREFIX .. goodId, ); basic:log(goodId .. "缓存设置成功"); --归还连接到连接池 red:close(); return json;endreturn _RedisCacheDemo;

首先从缓存中查询商品未命中再回源到后台 #首先从缓存中查询商品，未命中再回源到Java后台 location = /good/detail { content_by_lua_block { local goodId=ngx.var.arg_goodid; --判断goodId参数是否存在 if not goodId then ngx.say("请输入goodId"); return; end --首先从缓存中根据id查询商品 local RedisCacheDemo = require "luaScript.redis.RedisCacheDemo"; local redisCacheDemo = RedisCacheDemo:new(); local json = redisCacheDemo:getCache(goodId); --判断缓存是否被命中 if not json then ngx.say("缓存是否被命中，回源到上游接口<br>"); --若没有命中缓存，则回源到上游接口 json = redisCacheDemo:goUpstream(); else ngx.say("缓存已经被命中<br>"); end ngx.say("商品信息：",json); } }

 #模拟Java后台接口查询商品，然后设置缓存 location = /java/good/detail { #指定规则为internal内部规则，防止外部请求命中此规则 internal; content_by_lua_block { local RedisCacheDemo = require "luaScript.redis.RedisCacheDemo"; --Java后台将从数据库查找商品，这里简化成模拟数据 local json='{goodId:商品id,goodName:商品名称}'; --将商品缓存到Redis local redisCacheDemo = RedisCacheDemo:new(); redisCacheDemo:setCache(ngx.var.arg_goodid, json); --返回商品到下游网关 ngx.say(json); } }

 }

---启动调试，正式环境请注释local mobdebug = require("luaScript.initial.mobdebug");mobdebug.start();--导入自定义的基础模块local basic = require("luaScript.module.common.basic");--导入自定义的RedisOperator模块local redisOp = require("luaScript.redis.RedisOperator");local ip = basic.getClientIP();basic.log("ClientIP:"..ip);--lua_shared_dict black_ip_list m; #配置文件定义的ip_blacklist共享内存变量local black_ip_list = ngx.shared.black_ip_list--获得本地缓存的刷新时间，如果没有过期，就直接使用local last_update_time = black_ip_list:get("last_update_time");if last_update_time ~= nil then local dif_time = ngx.now() - last_update_time if dif_time <  then --缓存分钟，没有过期 if black_ip_list:get(ip) then return ngx.exit(ngx.HTTP_FORBIDDEN) --直接返回 end return endendlocal KEY = "limit:ip:blacklist";--创建自定义的redis操作对象local red = redisOp:new();--打开连接red:open();--获取缓存的黑名单local ip_blacklist = red:getSmembers(KEY);--归还连接到连接池red:close();if not ip_blacklist then basic.log("black ip set is null"); return;else --刷新本地缓存 black_ip_list:flush_all(); --同步redis黑名单到本地缓存 for i,ip in ipairs(ip_blacklist) do --本地缓存redis中的黑名单 black_ip_list:set(ip,true); end --设置本地缓存的最新更新时间 black_ip_list:set("last_update_time",ngx.now());endif black_ip_list:get(ip) then return ngx.exit(ngx.HTTP_FORBIDDEN) --直接返回end

 location /black_ip_demo { access_by_lua_ file luaScript/redis/black_ip_filter.lua; echo "恭喜，没有被拦截"; }

 #定义存储IP黑名单的共享内存变量 lua_shared_dict black_ip_list 1m;

语法：lua_shared_dict　<DICT>　<size>上下文：http配置块。例子：lua_shared_dict black_ip_list 1m; #定义存储IP黑名单的共享内存变量lua_shared_dict指令用于定义一块名为DICT的共享内存空间，其内存大小为size。通过该命令定义的共享内存对于Nginx中所有Worker进程都是可见的。对于共享内存的引用可以使用以下两种形式来完成：方式一：ngx.shared.DICT。方式二：ngx.shared["DICT"]。