问题描述

需求：从一个变化的列表list中取出第一条数据，list 10s更新一次，10s内不能一直取第一条，需要均衡；

bug代码：

// lua脚本
var copyIndexScript string = `local value = redis.call("Get", KEYS[1])if value == false  thenredis.call("Set" , KEYS[1], "0")redis.call("Expire" , KEYS[1], KEYS[2])return 0elselocal value1 = redis.call("Incr" , KEYS[1])return value1end`
// lua脚本缓存hash值
var copyIndexLuaHash string

//redis初始化
func init() {RedisClient = redis.NewClusterClient(&redis.ClusterOptions{Addrs:    []string{"127.0.0.1:7000","127.0.0.1:7001","127.0.0.1:7002","127.0.0.1:7003","127.0.0.1:7004","127.0.0.1:7005"},Password: "", //密码 })//脚本会产生一个sha1哈希值,下次用的时候可以直接使用这个值copyIndexLuaHash, _ = RedisClient.ScriptLoad(copyIndexScript).Result()
}

// 获取下标值
n, err := RedisClient.EvalSha(copyIndexLuaHash, []string{id, time}).Result()

报错：CROSSSLOT Keys in request don't hash to the same slot
原因：所有key必须在1个slot上

修改为：用参数传参；

// lua脚本
var copyIndexScript string = `local value = redis.call("Get", ARGV[1])if value == false  thenredis.call("Set" , ARGV[1], "0")redis.call("Expire" , ARGV[1], ARGV[2])return 0elselocal value1 = redis.call("Incr" , ARGV[1])return value1end`

// 获取下标值
n, err := RedisClient.EvalSha(copyIndexLuaHash,nil, []string{id, time}).Result()

报错：NOSCRIPT No matching script. Please use EVAL
原因：集群模式，在当前节点，获取缓存sha1，可能获取不到；干脆直接用eval

script load命令用于将脚本script添加到脚本缓存中，但并不立即执行这个脚本。如果给定的脚本已经在缓存里面了，那么不执行任何操作。在脚本被加入到缓存之后，通过EVALSHA命令，可以使用脚本的 SHA1 校验和来调用这个脚本。脚本可以在缓存中保留无限长的时间，直到执行SCRIPT FLUSH为止。
EVAL命令也会将脚本添加到脚本缓存中，但是它会立即执行输入的脚本。

// 获取下标值
n, err := RedisClient.Eval(copyIndexScript,nil, []string{id, time}).Result()

适配阿里云redis集群，报错：ERR for redis cluster, eval/evalsha number of keys can't be negative or zerorn

阿里云Redis集群对lua脚本限制如下： https://developer.aliyun.com/article/645851

所有key都应该由 KEYS 数组来传递，redis.call/pcall 中调用的redis命令，key的位置必须是KEYS array（不能使用Lua变量替换KEYS），否则直接返回错误信息，“-ERR bad lua script for redis cluster, all the keys that the script uses should be passed using the KEYS arrayrn”。

所有key必须在1个slot上，否则返回错误信息，“-ERR eval/evalsha command keys must be in same slotrn”。

调用必须要带有key，否则直接返回错误信息， “-ERR for redis cluster, eval/evalsha number of keys can’t be negative or zerorn”。

解决方案：

按照KEYS，ARGV传参

// lua脚本
var copyIndexScript string = `local value = redis.call("Get", KEYS[1])if value == false  thenredis.call("Set" , KEYS[1], "0")redis.call("Expire" , KEYS[1], ARGV[1])return 0elselocal value1 = redis.call("Incr" , KEYS[1])return value1end`

// 获取下标值
n, err := RedisClient.Eval(copyIndexScript, []string{id}, time).Result()

扩展：redis lua脚本做ip限流

ratelimiting.lua，内容如下

local times = redis.call('incr',KEYS[1])if times == 1 thenredis.call('expire',KEYS[1], ARGV[1])
endif times > tonumber(ARGV[2]) thenreturn 0
end
return 1

在redis客户端机器上，如何测试这个脚本呢？如下：

redis-cli --eval ratelimiting.lua rate.limiting:127.0.0.1 , 10 3

记录go-redis使用集群时，报错：CROSSSLOT Keys in request don‘t hash to the same slot相关推荐

K8S排水错误汇总（忽略DaemonSet管理Pod、Mysql集群排水报错、Mongo集群排水报错）
文章目录 [成功排水展示] 初始状态排水命令正确排水的输出排水后结果恢复节点 [FAQ] 1. 忽略DaemonSet管理的Pod 语法报错示例 2. 删除本地数据语法报错示例(mysq ...
redis集群搭建报错-(error) CLUSTERDOWN The cluster is down
[README] 最近搭建一个redis集群,参考博文 (https://www.cnblogs.com/mafly/p/redis_cluster.html) 对集群配置后,master, slav ...
执行redis命令redis-trib.rb查看集群信息报错cannot load such file -- redis (LoadError)
问题描述: 在执行redis-trib.rb命令查看集群状态的时候,报错: [aiprd@hadoop1 ~]$ redis-trib.rb check 192.168.30.10:7000 Trac ...
关于redis创建集群时出现[ERR] Node x.x.x.x:6379 is not empty. Either the node already knows other nodes (check
独醉F 2020-04-28 18:52:15 576 收藏文章标签: redis linux 数据库版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接 ...
从零开始在ubuntu上安装和使用k8s集群及报错解决
文章目录安装docker 安装kubernetes 配置k8s集群配置虚拟机网络配置Master节点的k8s网络拉取k8s需要的镜像启动 kubeadm 和 kubelet 配置 node节 ...
mysql集群重启报错lock_CentOS7.2 下 MySQL 之 PXC 集群部署【Docker+单机多节点】
背景 [注意]: 鄙人认为本篇适合做入门测试/学习之用,选择的 "单机多节点配置",后面再整理 "多机配置"文章. 近期正突击学习数据库知识想着对 PXC 集 ...
ceph-deploy离线部署ceph集群及报错解决FAQ
Python微信订餐小程序课程视频 https://edu.csdn.net/course/detail/36074 Python实战量化交易理财系统 https://edu.csdn.net/cou ...
zookeeper集群搭建报错日志：Cannot open channel to 3 at election address ecs-db04/192.168.0.4:3888
今日闲来无事搭建个zk集群玩玩,结果遇到一些问题,记录在此,可以参考排错.. 在配置完参数后启动服务,查看服务状态时报一下这个问题: ZooKeeper JMX enabled by default ...
部署k8s集群及报错完美解决方案
目录部署环境一.master操作二.node01操作三.Kubernetes部署容器化应用四.其他报错解决部署环境 Linux版本 CPU MEM CentOS7 双核 4G/node m ...

记录go-redis使用集群时，报错：CROSSSLOT Keys in request don‘t hash to the same slot

问题描述

解决方案：

扩展：redis lua脚本做ip限流

记录go-redis使用集群时，报错：CROSSSLOT Keys in request don‘t hash to the same slot相关推荐

最新文章

热门文章