步骤一:编写lua脚本实现缓存预热(将mysql里的数据查询出来存入redis)
缓存预热即数据的预加载,nginx执行lua脚本后会执行查询数据库的功能,将查询结果返回nginx,nginx将数据存入redis
步骤二:编写lua脚本实现二级缓存读取
客户端查询OpenResty本地缓存,如果本地缓存有数据,将数据直接返回给客户端,本地缓存没有数据将查询redis,将redis数据写入本地缓存,本地缓存后再将数据返回给客户端
代码实现
缓存预热
实现思路:
定义请求:用于查询数据库中的数据更新到redis中。
(1)连接mysql ,按照广告分类ID读取广告列表,转换为json字符串。
(2)连接redis,将广告列表json字符串存入redis 。 定义请求:
请求:
/ad_update
参数:
position ‐‐指定广告位置
返回值:
json
在/root/lua目录下创建ad_load.lua ,实现连接mysql 查询数据 并存储到redis中。
ngx.header.content_type="application/json;charset=utf8"
local cjson = require("cjson")
local mysql = require("resty.mysql")
local uri_args = ngx.req.get_uri_args()
local position = uri_args["position"]
local db = mysql:new()
db:set_timeout(1000)
local props = {
host = "192.168.200.128",
port = 3306,
database = "changgou_business",
user = "root",
password = "root"
}
local res = db:connect(props)
local select_sql = "select url,image from tb_ad where status ='1' and position='"..position.."' and start_time<= NOW() AND end_time>= NOW()"
res = db:query(select_sql)
db:close()
local redis = require("resty.redis")
local red = redis:new()
red:set_timeout(2000)
local ip ="192.168.200.128"
local port = 6379
red:connect(ip,port)
#设置存入redis中的数据
red:set("ad_"..position,cjson.encode(res)) red:close()
ngx.say("{flag:true}")
lua语句解析
修改/usr/local/openresty/nginx/conf/nginx.conf文件: 代码如下:
#user nobody;
user root root;
worker_processes 1;
#error_log logs/error.log;
#error_log logs/error.log notice;
#error_log logs/error.log info;
#pid logs/nginx.pid;
events {
worker_connections 1024;
}
http {
include mime.types;
default_type application/octet‐stream;
sendfile on;
#tcp_nopush on;
#keepalive_timeout 0;
keepalive_timeout 65;
#gzip on;
#在nginx.conf文件中加入相关配置
server {
listen 80;
server_name localhost;
charset utf‐8;
#access_log logs/host.access.log main;
# 添加
location /ad_update {
content_by_lua_file /root/lua/ad_update.lua;
}
# redirect server error pages to the static page /50x.html
#
error_page 500 502 503 504 /50x.html;
location = /50x.html {
root html;
}
}
}
在nginx的sbin目录重新启动nginx
./nginx -s reload