阿里云redis集群使用lua脚本

我不是女神ヾ 2022-06-03 00:23 1108阅读 0赞

这里写图片描述

redis集群对lua集群的支持有限，阿里的文档描述也比较简单，没有demo，研究了好久才把单例的lua脚本修改成集群版
单例模式的lua脚本

  1. local strs = {};
  2. local result = {};
  3. local resultIndex = 2;
  4. -- ARGV[1]是操作集合的指令，这里对应的是正序还是倒序zrange、zrevrange
  5. -- KEYS[1]是zset的key
  6. -- ARGV[2]是从第几个元素开始
  7. -- ARGV[3]是第几个元素结束
  8. local list = redis.call(ARGV[1], KEYS[1], ARGV[2], ARGV[3])
  10. if(list[1] == nil) then
  11.  return "[]"
  12. end
  15. result[1] = "[";
  16. for index,v in ipairs(list) do
  17.   -- KEYS[2]是存投票项的hash的key，值是vote:%s:%s:voteItem:list:
  18.   -- 拼写主Key
  19.   local key = KEYS[2]..v
  20.   --大量拼接字符串..效率比table.concat(strs)低很多。
  21.   --Lua的字符串和Java的字符串差不多，都是不可变的，每一次进行连接操作之后，其实就产生了新的字符串，不再是原来的那个了，不断连接，就不断产生新的字符串，产生新字符串是需要复制操作，随着连接操作的不断进行着，字符串越来越大，复制操作也就越来越耗时
  22.   -- 获取hash中的name值
  23.   local id = redis.call("hget", key, "id")
  24.   local itemName = redis.call("hget", key, "itemName")
  25.   local sortIndex = redis.call("hget", key, "sortIndex")
  26.   local details = redis.call("hget", key, "details")
  27.   local videoLink = redis.call("hget", key, "videoLink")
  28.   local itemImg = redis.call("hget", key, "itemImg")
  29.   local voteNumber = redis.call("hget", key, "voteNumber")
  30.   strs[1] = "{\'id\':\'";
  31.   strs[2] = id;
  32.   strs[3] = "\',";
  34.   strs[4] = "\'itemName\':\'";
  35.   strs[5] = itemName;
  36.   strs[6] = "\',";
  38.   strs[7] = "\'sortIndex\':\'";
  39.   strs[8] = sortIndex;
  40.   strs[9] = "\',";
  42.   strs[10] = "\'details\':\'";
  43.   strs[11] = details;
  44.   strs[12] = "\',";
  46.   strs[13] = "\'videoLink\':\'";
  47.   strs[14] = videoLink;
  48.   strs[15] = "\',";
  50.   strs[16] = "\'itemImg\':\'";
  51.   strs[17] = itemImg;
  52.   strs[18] = "\',";
  54.   strs[19] = "\'voteNumber\':\'";
  55.   strs[20] = voteNumber;
  56.   strs[21] = "\'}";
  58.   local voteItemJson = table.concat(strs);
  60.   redis.log(redis.LOG_DEBUG, "voteItemJson:"..voteItemJson)
  61.   result[resultIndex] = voteItemJson;
  62.   resultIndex = resultIndex + 1;
  64.   result[resultIndex] = ",";
  65.   resultIndex = resultIndex + 1;
  66. end
  67. if resultIndex > 2 then
  68.   table.remove(result, resultIndex - 1);
  69. end
  70. result[resultIndex -1] = "]"
  71. return table.concat(result);

这个脚本直接指向会报错

  1. -ERR eval/evalsha command keys must in same slot

集群有一个槽的概念，不同的key根据redis的hash算法会分布在不同的槽，集群是不支持多key查询的，解决办法是使用redis的hash tag，存入的时候把要多key查询的 key用{}括起来。如{key}.1,a.{key},s:{key}:b,这样这3个key都是按照{}内的内容技术槽，就能保证存入同一个槽内。

还可能会遇到这个异常

  1. ERR bad lua script for redis cluster, first parameter of redis.call/redis.pcall must be a single literal string

这是因为redis.call()第一个参数必须是字符串，不能是ARGV传参，我试过在lua里定义变量order，然后吧order放入redis.call，还是会报这个异常，没找到什么好的解决办法，只能把指令写入redis.call(),把正序和倒序写了两个脚本
local list = redis.call(‘zrange’, KEYS[1], ARGV[1], ARGV[2])

上面的脚本还会报一个错误

  1. "-ERR bad lua script for redis cluster, all the keys that the script uses should be passed using the KEYS array\r\n"

这是因为在循环内，我会拼接key，local key = KEYS[2]..v，在下面的redis.call会用到这个key，但是ali的redis集群规定，redis.call里面的key只能使用KEYS数组，所以这里修改代码

  1. KEYS[3] = KEYS[2]..v
  2. local id = redis.call("hget", KEYS[3], "id")

这样就能在redis集群执行这个lua脚本了

发表评论

表情：
评论列表 （有 0 条评论，1108人围观）

还没有评论，来说两句吧...

相关阅读