缓存预热与二级缓存查询

步骤一:编写lua脚本实现缓存预热(将mysql里的数据查询出来存入redis)
缓存预热即数据的预加载,nginx执行lua脚本后会执行查询数据库的功能,将查询结果返回nginx,nginx将数据存入redis

image.png

步骤二:编写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语句解析


image.png

修改/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

测试:http://192.168.200.128/ad_update?position=web_index_lb

©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。