如何有效地使用 JedisCluster

debugcn 发表于 Dev

汤姆

我是 Redis 的新手，我正在使用 Redis Java Client 来处理 Redis 集群。

我有以下代码：

public class HelloRedisCluster {
    public static void main(String[] args) {
        Set<HostAndPort> nodes = new HashSet<HostAndPort>();
        nodes.add(new HostAndPort("127.0.0.1", 6001));
        nodes.add(new HostAndPort("127.0.0.1", 6002));
        JedisPoolConfig config = new JedisPoolConfig();
        config.setMaxTotal(10000);
        config.setMaxIdle(500);

        JedisCluster cluster = new JedisCluster(nodes);
        cluster.set("abc", "123");
        System.out.println(cluster.get("abc"));
        cluster.close();
    }
}

在上面的代码中，它只是简单地打开集群，用Redis设置/获取，然后关闭集群。

如果代码作为服务运行（例如在 Servlet 中），那么它会频繁地打开和关闭集群，这会导致性能不佳。

请问如何有效地使用JedisCluster？

谢谢！

汤姆

我已经弄清楚 JedisCluster 的工作方式。在内部，它已经使用了 Jedis Pool。

JedisCluster 提供的操作也遵循相同的模式，set例如：

1. Borrow a Jedis object from Jedis Pool
2. Call Jedis#set method
3. Release the Jedis object back to the pool.

这样，我们可以将 JedisCluster 实例保存在 Singleton 对象中，然后在 JVM 退出时关闭 JedisCluster 对象，代码如下：

import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.JedisCluster;
import redis.clients.jedis.JedisPoolConfig;

import java.util.HashSet;
import java.util.Set;

public class JedisClusterUtil {
    private static JedisCluster cluster;

    static {
        Set<HostAndPort> nodes = new HashSet<HostAndPort>();
        nodes.add(new HostAndPort("127.0.0.1", 6001));
        nodes.add(new HostAndPort("127.0.0.1", 6002));
        JedisPoolConfig config = new JedisPoolConfig();
        config.setMaxTotal(10000);
        config.setMaxIdle(500);

        cluster = new JedisCluster(nodes, config);

        Runtime.getRuntime().addShutdownHook(new Thread() {
            @Override
            public void run() {
                if (cluster != null) {
                    cluster.close();
                }
            }
        });
    }

    public static JedisCluster getCluster() {
        return cluster;
    }
}

本文收集自互联网，转载请注明来源。

如有侵权，请联系[email protected] 删除。