今天在使用LUA脚本操作redis,传入了多个key,发现返回值一直是false,这让我很怀疑,于是开始研究这个事情。

打开redis客户端并连接上服务器,复现问题

redis.rds.aliyuncs.com:6379> eval "return {KEYS[1], KEYS[2]}" 2 '11' '22'
(error) ERR 'EVAL' command keys must in same slot

查找资料说是集群的问题。

连接本机redis服务

127.0.0.1:6379> eval "return {KEYS[1], KEYS[2]}" 2 '11' '22'
1) "11"
2) "22"

查看集群情况,本机没有集群

127.0.0.1:6379> cluster nodes
ERR This instance has cluster support disabled

查看线上集群情况,果然是集群的

redis.rds.aliyuncs.com:6379> cluster nodes
aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa 127.0.0.1:6379 myself,master - 0 0 0 connected 0-16383
bbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbb 127.0.0.1:6379 slave aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa 0 0 0 connected

在Redis集群版实例中,事务、脚本等命令要求所有的key必须在同一个slot中,如果不在同一个slot中将返回以下错误信息(command keys must in same slot)

在集群下,它会将数据自动分布到不同的节点(虚拟的16384个slot)
它数据的路由分发,是通过计算key,所以只要key一样,则一定会被分到同一个slot
Hash Tag是用于hash的部分字符串开始和结束的标记,例如"{}"、"$$"等。

beta:
  listen: 127.0.0.1:3306
  hash: fnv1a_64
  hash_tag: "{}"
  distribution: ketama
  auto_eject_hosts: false
  timeout: 400
  redis: true
  servers:
   - 127.0.0.1:6380:1 server1
   - 127.0.0.1:6381:1 server2
   - 127.0.0.1:6382:1 server3
   - 127.0.0.1:6383:1 server4

当一个key包含 hash_tag 的时候,就不对整个key做hash,而仅对 hash_tag包括的字符串做hash。
比如说我原来的Key是order_total, order_detail 然后我为了保证这两个Key能分到同一个slot,所以用{}把order包起来
{order}_total, {order}_detail就可以了

Laravel 官方文档在队列模块中也提到过:https://learnku.com/docs/laravel/5.7/queues/2286
因为Laravel的redis队列使用了大量的LUA脚本,而且是多个key。

如果你的 Redis 队列驱动使用了 Redis 集群,你的队列名必须包含一个 key hash tag 。这是为了确保所有的 Redis 键对于一个
队列都被放在同一哈希中。

'redis' => [
	'driver' => 'redis',
	'connection' => 'default',
	'queue' => '{default}',
	'retry_after' => 90,
],

综上所述,如果你可以通过在key前面增加带有 {xxx} 的部分来使这些key被分配到同一个slot中去。因为对于头部带有 {xxx} 的key,redis服务就不会对整个key做hash,只会对 {xxx} 做hash。

所以优化的后的操作:

redis.rds.aliyuncs.com:6379> eval "return {KEYS[1], KEYS[2]}" 2 {prefix}_11 {prefix}_22
1) "{prefix}_11"
2) "{prefix}_22"
redis.rds.aliyuncs.com:6379> eval "redis.call('set', KEYS[1], ARGV[1])" 1 {prefix}_11 11
(nil)
redis.rds.aliyuncs.com:6379> eval "redis.call('set', KEYS[1], ARGV[1])" 1 {prefix}_22 22
(nil)
redis.rds.aliyuncs.com:6379> eval "return {KEYS[1], KEYS[2]}" 2 {prefix}_11 {prefix}_22
1) "{prefix}_11"
2) "{prefix}_22"
redis.rds.aliyuncs.com:6379> eval "return {redis.call('get', KEYS[1]), redis.call('get', KEYS[2])}" 2 {prefix}_11 {prefix}_22
1) "11"
2) "22"

这样就能正常使用了,只是这个前缀不太好看。

Logo

鸿蒙生态一站式服务平台。

更多推荐