Goland中Redis的set求并集的错误处理

1、 文档介绍

今日在项目里写了一份简单的redis两个set类型求并集的操做

不断报错，在网上查到的资料里都简单介绍了自带的API接口，可是这个并非全部时间都好用的，甚至能够说对分布式而非主机redis来说基本上都是很差用的

 

2、网传解决办法

个人代码

func ListUnion2() ([]string, error){
	res, err := redisClient.SUnion(DB_SET, List_Only_Dump).Result()
	DBIgnoreRedisNil(err)
	return res, err
}

 

3、报错缘由

WARN CROSSSLOT Keys in request don't hash to the same slot

报错如上图所示，意思是“没法将请求中的CROSS SLOT密匙哈希写入同一槽中”

首先咱们简单理解一下，Key咱们称为密匙，咱们要对两个不一样的密匙进行操做不只要求两个密匙位于相同的节点上，还要求位于相同的哈希槽中，报错的缘由就是由于两个密匙不位于相同的哈希槽中，解决办法见下面👇

 

4、简单理解Redis Cluster读写过程

redis集群模式下的读写过程当中， 先对key进行hash找到slot进而找到clusterNode，若是clusterNode不是本节点就返回ASK或者MOVED错误码让客户端向新的节点ip:port发起链接。
也就是按照key->hash值->slot->clusterNode的顺序定位到key保存的clusterNode节点。
在完成clusterNode判断后若是肯定是本节点后执行后续的读写操做便可。

 

5、解决办法

我是采起了比较愚钝的办法，建立了一个SET，将须要合并的两个SET里面的内容取出来以后再add到新的SET里面

这里一个问题就是Goland自己是没有SET结构的，咱们若是想要使用的话须要手动实现，我今天先在REDIS上申请了一个SET类型来调试这个bug，在后续调试晚以后再手动实现SET

代码以下：

func ListUnion() ([]string, error){
	redisClient.Del(Union_List)
	res := []string{}
	dbList, err := redisClient.SMembers(DB_SET).Result()
	if err != nil{
		return res, err
	}
	onlyDumpList, err := redisClient.SMembers(List_Only_Dump).Result()
	if err != nil{
		return res, err
	}
	for _, dbName := range dbList{
		_, err := redisClient.SAdd(Union_List, dbName).Result()
		if err != nil{
			return res, err
		}
	}
	for _, dbName := range onlyDumpList{
		_, err := redisClient.SAdd(Union_List, dbName).Result()
		if err != nil{
			return res, err
		}
	}
	res, err = redisClient.SMembers(Union_List).Result()
	return res, err
}