Score
0
Watch 45 Star 137 Fork 50

Tinywan / lua-nginx-redisLuaMIT

Join us
Explore and code with more than 2 million developers,Free private repositories !:)
Sign up
Redis、Lua、Nginx、OpenResty开发、Lua案例、Nginx模块学习以及性能优化、PHP7性能优化以及详细配置总结等。 spread retract

https://github.com/Tinywan/lua-nginx-redis

Clone or download
redis-lua.md 8.57 KB
Copy Edit Web IDE Raw Blame History
ShaoBo Wan authored 2017-07-22 11:02 . update readme

Redis执行Lua脚本基本用法

基本语法


  • Hello, Lua!

    我们的第一个Redis Lua 脚本仅仅返回一个字符串,而不会去与redis 以任何有意义的方式交互

    local msg = "Hello, world!"
    return msg

    这是非常简单的,第一行代码定义了一个本地变量msg存储我们的信息, 第二行代码表示 从redis 服务端返回msg的值给客户端。 保存这个文件到Hello.lua,像这样去运行:

    www@iZ239kcyg8rZ:~/lua$ redis-cli EVAL "$(cat Hello.lua)" 0
    "Hello, world!"

    运行这段代码会打印"Hello,world!", EVAL在第一个参数是我们的lua脚本, 这我们用cat命令从文件中读取我们的脚本内容。第二个参数是这个脚本需要访问的Redis 的键的数字号。我们简单的 “Hello Script" 不会访问任何键,所以我们使用0

  • redis.call() 与 redis.pcall()的区别

    • 他们唯一的区别是当redis命令执行结果返回错误时
    • redis.call()将返回给调用者一个错误.
    • redis.pcall()会将捕获的错误以Lua表的形式返回.
    • redis.call() 和 redis.pcall() 两个函数的参数可以是任意的 Redis 命令
  • EVAL命令格式

    • 基本语法
      EVAL script numkeys key [key ...] arg [arg ...]
    • 语义
      1. script即为lua脚本或lua脚本文件
      2. key一般指lua脚本操作的键,在lua脚本文件中,通过KEYS[i]获取
      3. arg指外部传递给lua脚本的参数,可以通过ARGV[i]获取
    • eval命令的用法
      127.0.0.1:6379>  eval "return {KEYS[1],KEYS[2],ARGV[1],ARGV[2]}" 2 key1 key2 first second
      1) "key1"
      2) "key2"
      3) "first"
      4) "second"

      这个示例中lua脚本为一个return语句,返回了lua一个数组,这个数组四个元素分别是通过外部传入lua脚本。 因为redis内嵌了Lua虚拟机,因此redis接收到这个lua脚本之后,然后交给lua虚拟机执行。 当lua虚拟机执行结束,即将执行结果返回给redis,redis将结果按自己的协议转换为返回给客户端的回复,最后再通过TCP将回复发回给客户端

    • lua脚本参数的接受
      • 键值:KEYS[i] 来获取外部传入的键值
      • 参数:ARGV[i] 来获取外部传入的参数
  • 案例介绍

    • 通过Redis命令EVAL执行一个简单的Lua脚本文件
      • 给Redis添加测试数据(通过有序集合和哈希对应的集合信息)
        127.0.0.1:6379> ZADD WEB 1 google
        (integer) 1
        127.0.0.1:6379> ZADD WEB 2 apple
        (integer) 1
        127.0.0.1:6379> ZADD WEB 3 baidu
        (integer) 1
        127.0.0.1:6379> ZRANGE WEB 0 3
        1) "google"
        2) "apple"
        3) "baidu"
        127.0.0.1:6379> hmset google domain_name www.google.com ip 192.168.1.100 
        OK
        127.0.0.1:6379> hmset baidu domain_name www.baidu.com ip 192.168.1.200 
        OK
        127.0.0.1:6379> hmset apple domain_name www.apple.com ip 192.168.1.300 
        OK
        127.0.0.1:6379> hgetall google
        1) "domain_name"
        2) "www.google.com"
        3) "ip"
        4) "192.168.1.100"
        127.0.0.1:6379> hgetall apple
        1) "domain_name"
        2) "www.apple.com"
        3) "ip"
        4) "192.168.1.300"
        127.0.0.1:6379> hgetall baidu
        1) "domain_name"
        2) "www.baidu.com"
        3) "ip"
        4) "192.168.1.200"
      • Lua脚本,lua_get_redis.lua 文件
        -- 获取键值/参数
        local key,offset,limit = KEYS[1], ARGV[1], ARGV[2]
        -- 通过ZRANGE获取键为key的有序集合元素,偏移量为offset,个数为limit,即所有WEB信息 
        local names = redis.call('ZRANGE', key, offset, limit)
        -- infos table 存储所有WEB信息
        local infos = {}
        -- 遍历所有WEB信息
        for i=1,#names do
                local ck = names[i]
            -- 通过HGETALL命令获取每WEB的信息
                local info = redis.call('HGETALL',ck)
            -- 并且在WEB信息中插入对应的集合信息
                table.insert(info,'HOST_NAME')
                table.insert(info,names[i])
                --table.insert(info,'author',"Tinywan")
            -- 插入infos中
                infos[i] = info
        end
        -- 将结果返回给redis
        return infos
        1. redis.call() 函数的参数可以是任意的 Redis 命令
        2. table.insert(table, pos, value)

          [1]table.insert()函数在table的数组部分指定位置(pos)插入值为value的一个元素. pos参数可选, 默认为数组部分末尾

      • 执行结果:
        tinywan@:~/Lua$ sudo redis-cli --eval /home/tinywan/Lua/lua_get_redis.lua WEB , 0 2
        1) 1) "domain_name"
           2) "www.google.com"
           3) "ip"
           4) "192.168.1.100"
           5) "HOST_NAME"
           6) "google"
        2) 1) "domain_name"
           2) "www.apple.com"
           3) "ip"
           4) "192.168.1.300"
           5) "HOST_NAME"
           6) "apple"
        3) 1) "domain_name"
           2) "www.baidu.com"
           3) "ip"
           4) "192.168.1.200"
           5) "HOST_NAME"
           6) "baidu"
        • 注意:lua_get_redis.lua WEB , 0 2 之间的空格,不然会提示错误
        • 错误:(error) ERR Error running script command arguments must be strings or integers
    • Ngx_lua 写入Redis数据,通过CURL请求
      • curl_get_redis.lua 文件内容
        local json = require("cjson")
        local redis = require("resty.redis")
        local red = redis:new()
        
        red:set_timeout(1000)
        
        local ip = "127.0.0.1"
        local port = 6379
        local ok, err = red:connect(ip, port)
        if not ok then
                ngx.say("connect to redis error : ", err)
                return ngx.exit(500)
        end
        
        local key = ngx.var[1]
        local new_timer = ngx.localtime()   -- 本地时间:2017-04-16 15:56:59
        local value = key.."::"..new_timer
        local ok , err = red:set(key,value)
        if not ok then
           ngx.say("failed to set "..key, err)
           return
        end
        ngx.say("set result: ", ok)
        
        local res, err = red:get(key)
        if not res then
                ngx.say("get from redis error : ", err)
                return
        end
        if res == ngx.null then
                ngx.say(key.."not found.")
                return
        end
        red:close()
        ngx.say("Success get Redis Data",json.encode({content=res}))
      • nginx.conf
        location ~* /curl_insert_redis/(\w+)$ {
            default_type 'text/html';
            lua_code_cache off;
            content_by_lua_file /opt/openresty/nginx/conf/Lua/curl_get_redis.lua;
        }
      • curl 和浏览器请求结果(查询Redis数据库,数据已经插入成功)
           root@tinywan:# curl http://127.0.0.1/curl_insert_redis/Tinywan1227
           set result: OK
           Success get Redis Data{"content":"Tinywan1227::2017-04-16 15:57:56"}
    • 通过lua脚本获取指定的key的List中的所有数据
      local key=KEYS[1]
      local list=redis.call("lrange",key,0,-1);
      return list;
    • 根据外面传过来的IDList 做“集合去重”的lua脚本逻辑:
          local result={};
          local myperson=KEYS[1];
          local nums=ARGV[1];
          
          local myresult =redis.call("hkeys",myperson);
          
          for i,v in ipairs(myresult) do
             local hval= redis.call("hget",myperson,v);
             redis.log(redis.LOG_WARNING,hval);
             if(tonumber(hval)<tonumber(nums)) then
                table.insert(result,1,v);
             end
          end
          return  result;

Comment ( 0 )

Sign in for post a comment

Lua
1
https://gitee.com/Tinywan/lua-nginx-redis.git
git@gitee.com:Tinywan/lua-nginx-redis.git
Tinywan
lua-nginx-redis
lua-nginx-redis
master

Help Search

191139_cd20d5fd_5186603 191143_ebef6f8d_5186603