转自:http://blog.sina.com.cn/s/blog_6f67b91d0101664g.html
环境:nginx + redis
起因:项目中有些接口是需要客户端轮询去访问的,这样所造成的后果就是这些接口一直占用redis内存,造成其他接口效率的降低(如果此时正好赶上JOB运行,redis的消耗就会变得更高),此时考虑将这些问题接口的数据放到nginx共享内存里去,将redis的内存解放出来,然后当这些问题接口的数据发生变化时我们去手动刷新共享内存中的值,具体的使用 nginx + lua
lua的安装这里不做说明,网上很多教程,可以参考下面的两篇文章去实现。
具体实现:我这里一共分成三个部分 取,增加,减少(增加和减少 暂未做合并)
主要配置文件 nginx.conf 和三个lua文件(做主要的业务处理)
我这里的调用方式的url方式。和调用接口一样
1.nginx.conf server节点下新建
location /msg/get.json {
content_by_lua_file /xx/xx/lua/msg_get.lua;
}
location /msg/add.json {
content_by_lua_file /xx/xx/lua/msg_add.lua;
}
location /msg/reduce.json {
content_by_lua_file /xx/xx/lua/msg_reduce.lua;
}
2.取 msg_get.lua
ngx.header.content_type = "application/json; charset=UTF-8";
local redisEnv = require "resty.redis";
--redis对象,请参考redis命令
local redis = redisEnv:new();
--声明共享内存config
local config = ngx.shared.config;
local uid=ngx.var.arg_uid
--业务上的验证
local ok, err = redis:connect('10.xxx.xx5.1xx', 'xx79');
if not ok then
ngx.log(ngx.ERR, err);
ngx.exit(ngx.HTTP_SERVICE_UNAVAILABLE);
end
--得到url中的参数uid
local uid=ngx.var.arg_uid
--业务 验证是否登录
local redistoken=redis:get(uid.."utoken");
if redistoken~=ngx.var.arg_token then
ngx.say("not login");
ngx.exit(ngx.HTTP_SERVICE_UNAVAILABLE);
end
--从共享内存中取数据
local msg2 = config:get("BPF"..uid)
if not msg2 then
msg2 = redis:llen("BPF"..uid)
if not msg2 then
msg2=0
end
--写入共享内存
config:set("BPF"..uid, msg2);
end
--拼接json
local cjson = require "cjson"
local data = {}
data.message= "ok";
data.status=200;
data.attachment={}
data.attachment["102"]=msg2
redis:set_keepalive(1000,1024);
local json=cjson.encode(data);
ngx.say(json);#ngx.say 是 lua 显露給模块的接口
ngx.exit(ngx.HTTP_OK);
3.增加 msg_add.lua
ngx.header.content_type = "application/json; charset=UTF-8";
local redisEnv = require "resty.redis";
local redis = redisEnv:new();
--声明共享内存
local config = ngx.shared.config;
--得到请求参数 key
local key=ngx.var.arg_key
local oldNum=config:get(key)
if not oldNum then
oldNum=redis:llen(key)
if not oldNum then
oldNum=0
end
end
--写入共享内存 我这里是每次加1,根据需要可以将变化的值已参数形式传递过来
config:set(key, oldNum+1);
ngx.say("ok");
ngx.exit(ngx.HTTP_OK);
4.减少 msg_reduce.lua
ngx.header.content_type = "application/json; charset=UTF-8";
local redisEnv = require "resty.redis";
local redis = redisEnv:new();
--声明共享内存
local config = ngx.shared.config;
--得到请求参数 key
local key=ngx.var.arg_key
local oldNum=config:get(key)
if not oldNum then
oldNum=redis:llen(key)
if not oldNum then
oldNum=0
end
end
if oldNum>0 then
--写入共享内存
config:set(key, oldNum-1);
end
ngx.say("ok");
ngx.exit(ngx.HTTP_OK);
5.重启nginx nginx -s reload
6.测试
取: http://12.1x1.1x1.72/msg/get.json?uid=123
增加:http://12.1x1.1x1.72/msg/add.json?key=BPF123
减少:http://12.1x1.1x1.72/msg/reduce.json?key=BPF123
PS:参考 :http://huoding.com/2012/08/31/156
http://www.udpwork.com/item/8177.html这两篇文章
分享到:
相关推荐
nginx+lua+redis通过匹配客户端ip进行灰度发布
nginx+lua+redis 集群 连接插件和脚本,原来插件是没有密码功能 故 修改了一下 k可以自己下载使用
nginx+lua+redis实现token验证。实现基本的token验证、反向代理转发内部服务,lua连接redis封装、lua域名解析封装、lua域名脚本等
为处理高并发的请求,采用Nginx+Redis的非阻塞请求加内存数据库方式,采用Lua脚本处理简单业务,返回值为常用的Json
nginx+lua+redis黑名单加载,nginx+lua+redis黑名单加载。
最近有个需求是需要用nginx播放服务器的视频,考虑安全问题,需要在nginx加个lua去取redis的token进行验证,刚开始访问测试环境单机还挺好用,可是要访问生产的是集群环境,找了多了资料趟了数不尽的坑,最终形成这...
nginx+lua+redis.rar
使用Nginx+Lua+Redis来构建高并发Web应用,Curl请求Nginx,Nginx通过Lua查询Redis,返回json数据。
【Redis开发】lua脚本开发nginx 与 redis 模块 (Lua script development nginx and Redis modules) 文件列表: lua_files (0, 2017-05-21) lua_files\access_control.lua ...nginx(lua+1.11.2与 1.12.0) docker imag
lua+redis构建高性能的服务器架构。
本文给大家介绍的是Nginx利用Lua+Redis实现动态封禁IP的方法,下面话不多说了,来一起看看详细的介绍吧 二、架构 实现 IP 黑名单的功能有很多途径: 1、在操作系统层面,配置 iptables,拒绝指定 IP 的网络请求; 2...
基于CentOS 7 web服务环境搭建(包含JDK+Nginx+Tomcat+Mysql+Redis)-附件资源
提到高并发或者抗压力,有这种高qps经验的同学第一反应大都是Nginx+lua+Redis,网上也满天非那种高并发架构方案大都是这种,但是Nginx+lua来做接入层到底是怎么抗住压力的呢?本篇顺序:1、Nginx如何抗住的高并发,...
OpenResty lua redis 实现
数据结构的实现强调内存效率,因此与使用高级编程语言建模的相同数据结构相比,Redis内部的数据结构可能使用较少的内存。 Redis提供了许多自然可以在数据库中找到的功能,例如复制,持久性的可调级别,集群,高可用...
软件开发设计:应用软件开发、系统...云计算与大数据:包括云计算平台、大数据分析、人工智能、机器学习等,云计算是一种基于互联网的计算方式,通过这种方式,共享的软硬件资源和信息可以按需提供给计算机和其他设备。
我们选择使用OpenResty,其是由Nginx核心加很多第三方模块组成,其最大的亮点是默认集成了Lua开发环境,使得Nginx可以作为一个Web Server使用。借助于Nginx的事件驱动模型和非阻塞IO,可以实现高性能的Web应用程 序...
nginx-lua-redis-rate-measuring:一个lua库,可使用nginx + redis提供分布式速率测量,您可以使用它来在许多节点内进行节流系统