快速导航

当前的操作,我尽可能优化了,如果真实情况使用,还是得需要上网找性能优化,方可高性能使用!

OpenResty 本质是对Nginx的增强,本文实践是通过http请求进来,我们讲请求交由lua处理,通过lua直接处理,避免我们java中tomcat并发能力差的问题!

我们先配置redis.conf 好请求路径,只要访问ip:9000/abc 就触发lua脚本了

worker_processes  1;
error_log logs/error.log;
events {
    worker_connections 1024;
}
http {

        # 加载lua模块
        lua_package_path "/usr/local/openresty/lualib/?.lua;;";
        # 加载c模块
        lua_package_cpath "/usr/local/openresty/lualib/?.so;;";

    server {
        listen 9000;
        location / {
            default_type text/html;
            content_by_lua '
                ngx.say("<p>Hello, World! second test!</p>")
            ';
        }
        location /abc {
            # default_type text/html;
            default_type application/json;
            content_by_lua_file lua/a.lua;
        }
    }
}

创建lua/a.lua文件

lua操作Redis

pipeline即管道,可以理解为把多个命令打包然后一起发送;MTU(Maxitum Transmission Unit 最大传输单元)为二层包大小,一般为1500字节;而MSS(Maximum Segment Size 最大报文分段大小)为四层包大小,其一般是1500-20(IP报头)-20(TCP报头)=1460字节;因此假设我们执行的多个Redis命令能在一个报文中传输的话,可以减少网络往返来提高速度。因此可以根据实际情况来选择走pipeline模式将多个命令打包到一个报文发送然后接受响应,而Redis协议也能很简单的识别和解决粘包。

redis优化:pipeline合并发送redis命令

编辑a.lua 文件

-- 设置keepalive
local function close_redes( red )
  if not red then
    return
  end
  -- 释放连接(连接池实现)
  local pool_max_idle_time = 10000 -- 连接池空闲时间(毫秒) 默认是60秒
  local pool_size = 100 -- 连接池大小 默认是30个
  local ok, err = red:set_keepalive(pool_max_idle_time, pool_size)
  if not ok then
    ngx.say("set keepalive error : ", err)
  else
    ngx.log(ngx.ERR,"放入Redis连接池失败",err) -- 可以在nginx的error.log文件查看
  end
end

-- 引入redis模块
local redis=require 'resty.redis'

-- 创建redis连接对象对象
local redisObj=redis:new()
-- 设置redis超时时间
local connectTimeout = 1000;
local requestTimeout = 1000;
local responseTimeout = 1000;
redisObj:set_timeout(connectTimeout, requestTimeout, responseTimeout)
-- 设置redis连接信息
local ok,err=redisObj:connect('192.168.31.204',6379)
-- 设置redis连接密码才可用
redisObj:auth('123456')
-- 判断是否连接redis成功
if not ok then
    ngx.say('连接Redis失败:',err)
    return
else
    ngx.say('连接Redis成功:',ok)
end

-- 现在没开启pipeline,可以读取数据
local res,err=redisObj:get('username')
ngx.say('没开启pipeline从redis读取到的数据是:',res)

-- 开启init_pipeline 当你使用pipelineredis中间的命令,将不会去执行!最终统一返回在respTable,我们在这里拿数据处理即可!
redisObj:init_pipeline()

-- 存入数据 没开启pipeline这样使用    ok,err=redisObj:set('username','zhangsan')
redisObj:set('username','zhangsan')

-- 从redis中获取数据,现在是去不到的,必须等pipeline提交后才能获取!
local res,err=redisObj:get('username')
ngx.say('开启pipeline后从redis读取到的数据是:',res)
-- 提交
local respTable, err = redisObj:commit_pipeline()


-- 得到数据为空处理
if respTable == ngx.null then
  respTable = {}
end
-- 结果是按照执行顺序返回的一个table
for i, v in ipairs(respTable) do
  ngx.say("msg : ", v, "<br/>")
end

-- 关闭Redis连接
close_redes(redisObj)

ngx.say('redis操作完成,bye~')

测试 访问ip:9000/abc

完成对redis的操作了!

上述案例pipeline的形式是无法实现redis命令a结果作为redis命令b参数去使用的,也就是pipeline只适合多条命令互不影响的前提使用的。如果我们多条命令相互需要,我们可以想一下redis支持lua操作吧,我们一条命令,执行一个lua文件,这个lua文件直接操作多条redis命令不就行了嘛!本质就是通过openresty调用lua操作redis时,让redis自己执行lua!

Redis与脚本相关的命令如下

- EVAL
- EVALSHA
- SCRIPT EXISTS
- SCRIPT FLUSH
- SCRIPT KILL
- SCRIPT LOAD

我们就可以通过redis操作lua的案例来实现我们的自己的功能!

我们先学一下eval 命令 eval "lua script" keynumbers ...
我们脚本要执行可传递参数,参数分为KEYS、ARGV两种类型,我个人认为没啥区别
命令分为3部分,lua script、key的数量、可变参数
key的数量含义是:key是几,那就代表可变参数前几个就是从KEYS[]取出来,其他可以作为ARGV[]取

eval "return {KEYS[1],KEYS[2],ARGV[1],ARGV[2]}" 2 key1 key2 first second
我们可以看到上述命令讲述的是 返回传递的参数,以此顺序是 key第一个,key第二个,argv第一个,argv第二个
可想而知:如果要输出的结果就是 key1,key2,first,second

openresty也封装了redis执行lua的方法redis对象:eval(‘lua script’,keysnumber,…)

redis优化:压缩script示例

我们通过定义 set name lisi后,去get name,如果value等于lisi,就执行set age 10

这里没用到连接池,真实环境自己从本文上面一个案例提取

-- 引入redis模块
local redis=require 'resty.redis'

-- 创建redis连接对象对象
local redisObj=redis:new()
-- 设置redis超时时间为1s
redisObj:set_timeout(1000)
-- 设置redis连接信息
local ok,err=redisObj:connect('192.168.31.204',6379)
-- 设置redis连接密码才可用
redisObj:auth('123456')
-- 判断是否连接redis成功
if not ok then
    ngx.say('连接Redis失败:',err)
    return
else
    ngx.say('连接Redis成功:',ok)
end

-- 定义年龄
local age = 10

-- 注意在 Redis 执行脚本的时候,从 KEYS/ARGV 取出来的值类型为 string
local res, err = redisObj:eval([[
                redis.call('set', 'name', 'lisi')
		local nameRes = redis.call('get','name')
		if nameRes ~= nil and nameRes == 'lisi' then
                    return redis.call('set','age',ARGV[1])
                else
                    return 'name值不对!'
                end
                ]], 0, age,age)
                -- this 0 is key 0 (if 0 changes to 1,it means the first arguments as KEYS),others as ARGV arguments
-- redis:eval( command,keysnumber ...)
if not err then
    ngx.say('redis设置成功了:',res)
else
    ngx.say('redis has an error when lua is running',err)
end
-- 关闭redis
redisObj:close()

操作mysql

当前DB格式

修改a.lua文件

科普一下lua [[ ]] 是多行字符,字符串是””,多行就是[[ ]]

-- 引入Lua Mysql模块
local mysqL=require("resty.mysql")
-- 创建DB对象
local db=mysqL:new()
local ok,err=db:connect{
    host="192.168.31.204",
    port=3306,
    user='root',
    password='740969606',
    database='test'
}
-- 设置DB超时时间,避免长时间阻塞
db:set_timeout(1000)

local name = "陆致远"
local badName = [[陆志远';drop table User;--]]
-- 这一行是模拟执行sql注入的,使用前请务必备份数据表
-- db:send_query(string.format([[select * from User where user_name = '%s']],badName))

-- 设定sql,同时调用ndk.set_var.set_quote_sql_str对特殊符号进行校验防止sql注入
db:send_query(string.format([[select * from User where user_name = %s limit 1]] , ndk.set_var.set_quote_sql_str(name)));
-- 读取数据
local res,err,errcode,sqlstate=db:read_result()
if not res then
    ngx.say("bad result: ", err, ": ", errno, ": ", sqlstate, ".")
    return
else
   -- 关闭sqlSession
    db:close()
    -- 数据存储在res数组中 第一行数据就是res[1],字段是user_name 使用就是res[1].user_name
    if res[1] ~= nil then
        ngx.say('姓名:'..res[1].user_name..' ,学生年龄:'..res[1].user_age)
    else
        ngx.say("no res!")
    end
end

完成对Mysql的操作了

引入Cjson处理

编写a.lua文件

-- 引入lua模块
local myjson = require("cjson")
-- 定义数组,下一步将转为json
local dbRes = {"1","2","3"}
-- 将数组转为json
local returnjson = myjson.encode(dbRes) -- 数据转为json
local returnjson = myjson.decode(dbRes) -- json转为数据
-- 返回
ngx.say(returnjson)                                                                                                                                       

完成对json的处理了!

优化篇

每个lua执行时,都自己加载了各种模块,我们可以提前统一加载

在http块下面添加

  # 在这里配置,这样当前http块内需要用到cjson模块时,都不需要独自加载了  
  init_by_lua_block{
    cjson=require 'cjson'
  }

在每个server下添加,off可以免重启

# 开发调试的时候使用off, 线上运行时设置为on。开发不用重启lua了,第一次识别此配置还是得重启
lua_code_cache off;

# 重启后会提示:nginx: [alert] lua_code_cache is off; this will hurt performance in /www/conf/nginx.conf:31 就是说off会影响性能!

示例

worker_processes  1;
error_log logs/error.log;
events {
    worker_connections 1024;
}
http {

    # 加载lua模块
    lua_package_path "/usr/local/openresty/lualib/?.lua;;";
    # 加载c模块
    lua_package_cpath "/usr/local/openresty/lualib/?.so;;";

    # 在这里配置,这样当前http块内需要用到cjson模块时,都不需要独自加载了
    init_by_lua_block{
        -- 注意,这里面是lua语法,注释是两个杠 不是井号
        cjson=require 'cjson';
        -- mysql=require("resty.mysql");
        -- redis=require 'resty.redis';
    }


    server {
        listen 9000;
        location / {
            default_type text/html;
            content_by_lua '
                ngx.say("<p>Hello, World! second test!</p>")
            ';
        }
        location /abc {
            lua_code_cache off;
            # default_type text/html;
            default_type application/json;
            content_by_lua_file lua/a.lua;
        }
    }
}

测试一下json吧 我们修改a.json文件

-- 引入json我注释了,我们全局统一引入起的名字叫cjson,我们下文还是得依旧遵循cjson去使用
-- local cjson = require("cjson")
-- 定义数组,下一步将转为json
local dbRes = {"1","2","3",nil,"null"}
-- 将数组转为json
local returnjson = cjson.encode(dbRes)
-- 返回
ngx.say(returnjson) 

本文基本就结束了,如果需要具体通过http请求形式,请参考本博客:https://www.zanglikun.com/12845.html

获取Lua 执行时间

local start_time = ngx.now()
-- 这里放入要执行的代码
ngx.say("time used:", ngx.now() - start_time)

-- 这是请求被nginx处理到lua执行结束的时间,更加准确!
ngx.say("time used:", ngx.now() - ngx.req.start_time()

ngx.say()与ngx.print() 都是输出,但是say会换行,print更适合优化文件碎片传输,因为没有换行,保证流传输正确性!

本站所有资源版权均属于原作者所有,这里所提供资源均只能用于参考学习用,请勿直接商用。若由于商用引起版权纠纷,一切责任均由使用者承担。更多说明请参考 VIP介绍。

最常见的情况是下载不完整: 可对比下载完压缩包的与网盘上的容量,若小于网盘提示的容量则是这个原因。这是浏览器下载的bug,建议用百度网盘软件或迅雷下载。 若排除这种情况,可在对应资源底部留言,或联络我们。

对于会员专享、整站源码、程序插件、网站模板、网页模版等类型的素材,文章内用于介绍的图片通常并不包含在对应可供下载素材包内。这些相关商业图片需另外购买,且本站不负责(也没有办法)找到出处。 同样地一些字体文件也是这种情况,但部分素材会在素材包内有一份字体下载链接清单。

如果您已经成功付款但是网站没有弹出成功提示,请联系站长提供付款信息为您处理

源码素材属于虚拟商品,具有可复制性,可传播性,一旦授予,不接受任何形式的退款、换货要求。请您在购买获取之前确认好 是您所需要的资源