Lua+OpenResty+nginx+redis+canal实现缓存策略

一、OpenResty介绍

OpenResty(又称:ngx_openresty) 是一个基于 nginx的可伸缩的 Web 平台,由中国人章亦春发起,提供了很多高质量的第三方模块。

OpenResty 是一个强大的 Web 应用服务器,Web 开发人员可以使用 Lua 脚本语言调动 Nginx 支持的各种 C 以及 Lua 模块,更主要的是在性能方面,OpenResty可以 快速构造出足以胜任 10K 以上并发连接响应的超高性能 Web 应用系统。

360,UPYUN,阿里云,新浪,腾讯网,去哪儿网,酷狗音乐等都是 OpenResty 的深度用户。

OpenResty 简单理解成 就相当于封装了nginx,并且集成了LUA脚本,开发人员只需要简单的其提供了模块就可以实现相关的逻辑,而不再像之前,还需要在nginx中自己编写lua的脚本,再进行调用了。


安装openresty

linux安装openresty:


1.添加仓库执行命令

Lua+OpenResty+nginx+redis+canal实现缓存策略安装nginx

默认已经安装好了nginx,在目录:/usr/local/openresty/nginx 下。

修改/usr/local/openresty/nginx/conf/nginx.conf,将配置文件使用的根设置为root,目的就是将来要使用lua脚本的时候 ,直接可以加载在root下的lua脚本。

Lua+OpenResty+nginx+redis+canal实现缓存策略二、广告缓存的载入与读取

需求分析

需要在页面上显示广告的信息。


解决方法 Lua+Nginx配置

(1)实现思路-查询数据放入redis中


实现思路:

定义请求:用于查询数据库中的数据更新到redis中。

a.连接mysql ,按照广告分类ID读取广告列表,转换为json字符串。

b.连接redis,将广告列表json字符串存入redis 。

定义请求:

Lua+OpenResty+nginx+redis+canal实现缓存策略请求地址:http://192.168.xxx.xxx/update_content?id=1

创建/root/lua目录,在该目录下创建update_content.lua: 目的就是连接mysql 查询数据 并存储到redis中。Lua+OpenResty+nginx+redis+canal实现缓存策略修改/usr/local/openresty/nginx/conf/nginx.conf文件: 添加头信息,和 location信息Lua+OpenResty+nginx+redis+canal实现缓存策略定义lua缓存命名空间,修改nginx.conf,添加如下代码即可:Lua+OpenResty+nginx+redis+canal实现缓存策略请求http://192.168.xxx.xxx/update_content?id=1可以实现缓存的添加


(2)实现思路-从redis中获取数据


实现思路:

定义请求,用户根据广告分类的ID 获取广告的列表。通过lua脚本直接从redis中获取数据即可。

定义请求:

请求:/read_content

参数:id

返回值:json


在/root/lua目录下创建read_content.lua:

Lua+OpenResty+nginx+redis+canal实现缓存策略在/usr/local/openresty/nginx/conf/nginx.conf中配置如下:

Lua+OpenResty+nginx+redis+canal实现缓存策略(3)加入openresty本地缓存


如上的方式没有问题,但是如果请求都到redis,redis压力也很大,所以我们一般采用多级缓存的方式来减少下游系统的服务压力。参考基本思路图的实现。

先查询openresty本地缓存 如果 没有

再查询redis中的数据,如果没有

再查询mysql中的数据,但凡有数据 则返回即可。

修改read_content.lua文件,代码如下:

ngx.header.content_type="application/json;charset=utf8"
local uri_args = ngx.req.get_uri_args();
local id = uri_args["id"];
--获取本地缓存
local cache_ngx = ngx.shared.dis_cache;
--根据ID 获取本地缓存数据
local contentCache = cache_ngx:get('content_cache_'..id);
if contentCache == "" or contentCache == nil then
    local redis = require("resty.redis");
    local red = redis:new()
    red:set_timeout(2000)
    red:connect("192.168.211.132", 6379)
    local rescontent=red:get("content_"..id);
    if ngx.null == rescontent then
        local cjson = require("cjson");
        local mysql = require("resty.mysql");
        local db = mysql:new();
        db:set_timeout(2000)
        local props = {
            host = "192.168.211.132",
            port = 3306,
            database = "xxx_content",
            user = "root",
            password = "123456"
        }
        local res = db:connect(props);
        local select_sql = "select url,pic from tb_content where status ='1' and category_id="..id.." order by sort_order";
        res = db:query(select_sql);
        local responsejson = cjson.encode(res);
        red:set("content_"..id,responsejson);
        ngx.say(responsejson);
        db:close()
    else
        cache_ngx:set('content_cache_'..id, rescontent, 10*60);
        ngx.say(rescontent)
    end
    red:close()
else
    ngx.say(contentCache)
end

测试地址:http://192.168.211.132/update_content?id=1


此时会将分类ID=1的所有广告查询出来,并存入到Redis缓存。


测试地址:http://192.168.xxx.xxx/read_content?id=1


此时会获取分类ID=1的所有广告信息。


上一篇:[转载] HTTP 协议中 URI 和 URL 的区别


下一篇:Oracle 11g行字段拼接WMSYS.WM_CONCAT问题Not A LOB