Openresty(lua+nginx)-Guava-Redis做多级缓存-阿里云开发者社区
- Openresty(lua+nginx)-Guava-Redis 做多级缓存-阿里云开发者社区
- https://developer.aliyun.com/article/1470012
- Openresty(lua+nginx)-Guava-Redis 做多级缓存
- 2024-11-30 15:38:24
https://www.aliyun.com/ai-assistant备案控制台
Openresty(lua+nginx)-Guava-Redis 做多级缓存
2024-03-2876 发布于海南
版权
举报
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
云数据库 Tair（兼容 Redis），内存型 2GB
推荐场景：
Redis 开源版，标准版 2GB
推荐场景：
简介： Openresty(lua+nginx)-Guava-Redis 做多级缓存
- 开辟一块内存空间
在 Nginx 配置文件 conf/nginx.conf 中开启了一个内存大小为 128M 的内存空间，用来存储缓存数据；
- 定义内存字典业务实现 lua 脚本 memory_shared_dic_java.lua（添加缓存，获取缓存）
---
--- 基于lua+Openresty实现内存字典，直接访问redis缓存
--- 引入Redis lua库文件
local red = require "resty.redis"
--- 调用new方法，获取redis对象
local redis = red:new()
--
local password = "123456";
-- 设置一下redis密码
redis:auth(password)
redis:select(0)
--- 1、实现缓存的添加操作
function set_to_cache(key,value,expr)
if not expr then
expr = 0
end
--- 获取本地内存字典对象
local ngx_cache = ngx.shared.ngx_cache
--- 向内存字典中添加缓存数据
local succ,err,forcible = ngx_cache:set(key,value,expr)
return succ
end
--- 2、从内存字典中获取缓存数据
function get_from_cache(key)
--- 获取本地内存字典对象
local ngx_cache = ngx.shared.ngx_cache
--- 从内存字典中获取数据缓存
local res = ngx_cache:get(key)
-- 如果内存字典缓存不存在
if not res then
-- 查询redis缓存数据
local rev,err = get_from_redis(key)
if not rev then
ngx.say("redis cache not exists",err)
return
end
-- 添加到本地内存字典
set_to_cache(key,rev,60)
end
return res
end
--- 向redis添加缓存数据
function set_to_redis(key,value)
-- 设置连接Redis的超时时间
redis:set_timeout(10000)
-- 连接redis服务器
local ok,err = redis:connect("172.17.61.90",6379)
-- 判断连接redis服务是否成功
if not ok then
ngx.say("failed to connect:",err)
return
end
-- 如果连接成功，向redis添加缓存数据
local succ,err = redis:set(key,value)
if not succ then
ngx.say("failed set redis:",err)
return
end
return succ
end
-- 从Redis中获取缓存数据
function get_from_redis(key)
-- 设置连接Redis的超时时间
redis:set_timeout(10000)
-- 连接redis服务器
local ok,err = redis:connect("172.17.61.90",6379)
-- 判断连接redis服务是否成功
if not ok then
ngx.say("failed to connect:",err)
return
end
-- 从Redis中获取缓存数据
local succ,err = redis:get(key)
if not succ then
ngx.say("failed get redis:",err)
return
end
ngx.say("get cache from redis......")
return succ
end
--- 3、内存字典缓存响应业务实现
--- 获取请求参数
local params = ngx.req.get_uri_args()
--- 获取参数属性值
local id = params.id
--- 从内存字典中获取数据缓存
local goods = get_from_cache("seckill_goods_"..id)
--- 判断内存字典中是否存在缓存数据，如果不存在，将会去查询后端服务数据
if goods == nil then
-- 从后端服务查询数据
local result = ngx.location.capture("/seckill/goods/detail/"..id)
goods = result.body
-- 向内存字典中添加缓存数据
set_to_cache("seckill_goods_"..id,goods,60)
end
-- 输出结果
ngx.say(goods)
这个 lua 脚本写好后，上传到 Nginx/conf 同级目录 lua 目录下，并且在 nginx.conf 文件中配置，然后 sbin/nginx -s reload 生效：
- java 中代码
添加 guava 依赖
<dependency>
<groupId>com.google.guava</groupId>
<artifactId>guava</artifactId>
<version>18.0</version>
</dependency>
@Autowired
private SeckillGoodsMapper seckillGoodsMapper;
//注入redistemplate对象
@Autowired
private RedisTemplate redisTemplate;
//注入guva缓存对象
@Autowired
private Cache<String,Object> guavaCahce;
public TbSeckillGoods findOneByCache(Integer id){
//1、先从jvm堆缓存中读取数据，使用guva缓存
TbSeckillGoods seckillGoods = (TbSeckillGoods) guavaCahce.getIfPresent("seckill_goods_"+id);
//判断jvm堆内缓存是否存在
if(seckillGoods == null){
//2、从分布式缓存中查询
seckillGoods = (TbSeckillGoods) redisTemplate.opsForValue().get("seckill_goods_"+id);
//判断
if(seckillGoods == null){
//3、直接从数据库查询
seckillGoods = seckillGoodsMapper.selectByPrimaryKey(id);
if(seckillGoods != null && seckillGoods.getStatus() == 1){
//添加缓存
redisTemplate.opsForValue().set("seckill_goods_"+id,seckillGoods,1,TimeUnit.HOURS);
}
}
//添加guava缓存
guavaCahce.put("seckill_goods_"+id,seckillGoods);
}
//如果缓存存在，返回Redis缓存
return seckillGoods;
}
标签：缓存,lua,--,Redis,redis,local,---,nginx,ngx From： https://www.cnblogs.com/ypjj/p/18615140/openreasty-lua-nginx-guavaredis-do-multiglass-cach