配置jedis集群,代码如下:
def getJedisCluster(): JedisCluster = {
val nodes = new util.HashSet[HostAndPort]()
nodes.add(new HostAndPort("127.0.0.1", 7000))
nodes.add(new HostAndPort("127.0.0.1", 7001))
nodes.add(new HostAndPort("127.0.0.1", 7002))
nodes.add(new HostAndPort("127.0.0.1", 7003))
nodes.add(new HostAndPort("127.0.0.1", 7004))
nodes.add(new HostAndPort("127.0.0.1", 7005))
nodes.add(new HostAndPort("127.0.0.1", 7006))
new JedisCluster(nodes)
}