从JedisPool到JedisCluster的转变

Question

我的应用程序在AWS上使用ElastiCache进行缓存。我们目前的设置使用基本的Redis集群，没有分片或故障切换。我们现在需要转移到一个支持分片、故障切换等功能的集群Redis弹性缓存。在AWS上创建一个新集群很容易，但我们对如何修改java代码以从集群读写有点迷茫。

当前实现-初始化一个spool。

JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
jedisPoolConfig.setMaxTotal(100);
jedisPoolConfig.setMaxIdle(10);
jedisPoolConfig.setMaxWaitMillis(50);
jedisPoolConfig.setTestOnBorrow(true);

String host = "mycache.db8e1v.0001.usw2.cache.amazonaws.com";
int port = 6379;
int timeout = 50;

JedisPool jedisPool = new JedisPool(jedisPoolConfig, host, port, timeout)

每次我们需要执行操作时，都会从池中借用Jedis对象

Jedis jedis = JedisPool.getResource();

新的实施将是

JedisPoolConfig jedisPoolConfig = ...
HostAndPort hostAndPort = new HostAndPort(host, port);
jedisCluster = new JedisCluster(Collections.singleton(hostAndPort), jedisPoolConfig);

问题：文件上说，绝地武士团将取代绝地武士（而不是绝地武士）。这是否意味着我需要在每个线程中创建并销毁一个JedisCluster对象。或者我可以重复使用同一个对象，它将处理线程安全？那我什么时候才能关闭绝地武士团？在申请结束时？

Answer 1

用绝地群呼叫取代所有绝地呼叫是迁移的最佳方式。

但我想要管道支持，而绝地武士团目前缺乏这种支持。所以另一个想法是扩展JedisCluster以返回JedisPool

protected Jedis getJedis(String key) {
    int slot = JedisClusterCRC16.getSlot(key);
    return connectionHandler.getConnectionFromSlot(slot);
}

扩展类必须位于命名空间redis中。客户。绝地武士从插槽中获取连接。

现在可以在Jedis上执行管道。

你需要一个不同的杰迪斯为你想要操作的每个关键。这是有意义的——在集群模式下，每个键可以在不同的节点上。

Answer 2

JedisCluster为集群中的每个节点保存内部JedisPools。

这是否意味着我需要在每个线程中创建并销毁一个JedisCluster对象。或者我可以重复使用同一个对象，它将处理线程安全？

可以重复使用同一个对象。

那我什么时候才能关闭绝地武士团？在申请结束时？

是的。