OpenResty+nginx+lua+redis实现二级缓存

归档115

Kubernetes39 Java16 中间件14 其他12 Linux10 Nginx10 Docker7 MySQL7

382 字

2 分钟

OpenResty+nginx+lua+redis实现二级缓存

2021-06-24

Nginx

OpenResty

下载OpenResty镜像
Terminal window
```
1
docker pull openresty/openresty
```

运行镜像

1
docker run -d -p 880:80 --name openresty --restart always -v /etc/localtime:/etc/localtime openresty/openresty

进入容器
Terminal window
```
1
docker exec -it openresty /bin/bash
```

安装lua

1
apt-get update -y
2
apt-get install -y gcc
3
apt-get install -y curl
4
apt-get install -y make
5
apt-get install -y vim
6
apt-get install libreadline-dev -y
7
curl -R -O http://www.lua.org/ftp/lua-5.3.5.tar.gz
8
tar -zxf lua-5.3.5.tar.gz
9
cd lua-5.3.5
10
make linux test
11
make install

编写lua脚本并上传到服务器

1
ngx.header.content_type = "application/json;charset=utf8"
2

3
--获取本地缓存
4
local cache_ngx = ngx.shared.dis_cache;
5
-- 获取本地缓存数据
6
local ngCache = cache_ngx:get('lua:application-data')
7
if ngCache == "" or ngCache == nil then
8
    --引入redis库
9
    local cjson = require("cjson")
10
    local redis = require("resty.redis")
11
    local red = redis:new()
12
    red:set_timeout(2000)
13

14
    local ip = "127.0.0.1"
15
    local port = 6379
16
    red:connect(ip, port)
17
    red:auth("123456")
18

19
    local redCache = red:get("lua:application-data")
20
    if redCache == ngx.null or redCache == "" or redCache == nil then
21
        --引入mysql库
22
        local mysql = require("resty.mysql")
23
        local db = mysql:new()
24
        db:set_timeout(3000)
25
        local props = {
26
            host = "127.0.0.1",
27
            port = 3306,
28
            database = "test",
29
            user = "root",
30
            password = "root"
31
        }
32

33
        local res = db:connect(props)
34
        local select_sql = "SELECT xxx from tb_level where xxx"
35
        res = db:query(select_sql)
36
        db:close()
37
        red:set("lua:application-data", cjson.encode(res))
38
        red:close()
39
        --将redis中获取到的数据存入nginx本地缓存10分钟 测试阶段先1分钟
40
        cache_ngx:set('lua-game-milk-tea:level-data', cjson.encode(res), 1 * 60)
41
        ngx.say("{\"code\":0,\"message\":\"sql success\",\"data\":" .. cjson.encode(res) .. "}")
42
    else
43
        --将redis中获取到的数据存入nginx本地缓存10分钟 测试阶段先1分钟
44
        cache_ngx:set('lua:application-data', redCache, 1 * 60)
45
        ngx.say("{\"code\":0,\"message\":\"redis success\",\"data\":" .. redCache .. "}")
46
    end
47
else
48
    ngx.say("{\"code\":0,\"message\":\"nginx success\",\"data\":" .. ngCache .. "}")
49
end

特别说明

1
lua读取redis数据返回结果为空时，返回的结果不是nil而是userdata类型的ngx.null

在http节点下开启nginx共享内存

1
vim /usr/local/openresty/nginx/conf/nginx.conf

1
lua_shared_dict dis_cache 10m;

在server节点添加lua配置

1
location /lua {
2
    content_by_lua_file /opt/lua/cache.lua;
3
    add_header Access-Control-Allow-Origin *;
4
    add_header Access-Control-Allow-Methods 'GET, POST, OPTIONS';
5
    add_header Access-Control-Allow-Headers '*';
6
}