Nginx+Lua实现分布式缓存

2 years ago

source link: https://wakzz.cn/2018/12/11/nginx/Nginx+Lua%E5%AE%9E%E7%8E%B0%E5%88%86%E5%B8%83%E5%BC%8F%E7%BC%93%E5%AD%98/
Go to the source link to view the article. You can view the picture content, updated content and better typesetting reading experience. If the link is broken, please click the button below to view the snapshot at that time.

Nginx+Lua实现分布式缓存

祈雨的博客

2018-12-11

nginx

local redis = require("resty.redis")
local cjson = require("cjson")
local cjson_encode = cjson.encode
local ngx_log = ngx.log
local ngx_ERR = ngx.ERR
local ngx_exit = ngx.exit
local ngx_print = ngx.print
local ngx_re_match = ngx.re.match
local ngx_var = ngx.var

local function close_redis(red)
	if not red then
		return
	end
	-- 释放连接(连接池实现)
	local pool_max_idle_time = 10000 -- 毫秒
	local pool_size = 100  -- 连接池大小
	local ok, err = red:set_keepalive(pool_max_idle_time, pool_size)

if not ok then
		ngx_log(ngx_ERR, "set redis keepalive error : ", err)
	end
end

local function read_redis(id)
	local red = redis:new()
	red:set_timeout(1000)
	local ip = "127.0.0.1"
	local port = 1111
	local ok, err = red:connect(ip, port)
	if not ok then
		ngx_log(ngx_ERR, "connect to redis error : ", err)
		return close_redis(red)
	end

local resp, err = red:get(id)
	if net resp then
		ngx_log(ngx_ERR, "get redis connect error : ", err)
		return close_redis(red)
	end
	-- 得到的数据为空处理
	if resp == ngx.null then
		resp = nil
	end
	close_redis(red)

return resp
end

local function read_http(id)
	local resp = ngx.location.capture("/backend", {
		method = ngx.HTTP_GET,
		args = {id = id}
	})

if not resp then
		ngx_log(ngx_ERR, "request error :", err)
		return
	end

if resp.status ~= 200 then
		ngx_log(ngx_ERR, "request error, status :", resp.status)
		return
	end

return resp.body
end

-- 获取id
local id = ngx_var.id

-- 从redis获取
local content = read_redis(id)

-- 如果redis没有，则回源到tomcat
if not content then
	ngx_log(ngx_ERR, "redis not found content, back to http, id : ", id)
	content = read_http(id)
end

-- 如果还没有，则返回404
if not content then
	ngx_log(ngx_ERR, "http not found content, id : ", id)
	return ngx_exit(404)
end

-- 输出内容
ngx.print("show_ad(")
ngx.print(cjson_encode({content = content}))
ngx.print(")")

Recommend

charlesleifer.com 2 years ago
Cache

Measuring Nginx Cache Performance using Lua and Redis

Measuring Nginx Cache Performance using Lua and Redis February 23, 2016 22:15 / lua

wakzz.cn 2 years ago
Cache

Nginx+Lua环境搭建

Nginx+Lua环境搭建祈雨的博客 2018-12-15

wakzz.cn 2 years ago
Cache

Nginx+Lua实现动态黑名单

通过nginx+lua+redis可以实现nginx动态从redis读取需要拒绝的ip黑名单列表，并拒绝黑名单ip的访问请求。其中redis中的ip黑名单列表既可以人工后台手动添加，也可以用类似logstash+elasticsearch的组合，实现logstash实时读取nginx的访问日志acces...