java使用socket封装一个支持集群可执行读写redis命令并获取返回值的工具类

首先，需要引入Jedis客户端，它是Java中一个流行的Redis客户端。

然后，可以通过以下步骤封装一个支持集群的Redis工具类：

1. 创建JedisCluster对象，该对象可以自动发现和管理Redis集群节点。

Set<HostAndPort> nodes = new HashSet<HostAndPort>();
nodes.add(new HostAndPort("redis-node1", 7000));
nodes.add(new HostAndPort("redis-node2", 7001));
nodes.add(new HostAndPort("redis-node3", 7002));
JedisCluster jedisCluster = new JedisCluster(nodes);

2. 实现工具类的读写方法，使用JedisCluster对象执行Redis命令，并返回结果。

public Object get(String key) {
    return jedisCluster.get(key);
}

public String set(String key, String value) {
    return jedisCluster.set(key, value);
}

3. 在集群中执行命令时，需要使用JedisCluster对象的`execute`方法，并传递一个实现了`JedisClusterCommand`接口的回调函数，将需要执行的Redis命令作为参数传递给回调函数。

public Object execute(JedisClusterCommand<Object> command) {
    return jedisCluster.execute(command);
}

public Long incr(String key) {
    return (Long) execute((JedisClusterCommand<Long>) jedis -> jedis.incr(key));
}

最终的工具类实现如下所示：

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

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

public class RedisClusterUtil {
    private JedisCluster jedisCluster;

    public RedisClusterUtil(String redisClusterNodes) {
        Set<HostAndPort> nodes = new HashSet<>();
        for (String node : redisClusterNodes.split(",")) {
            String[] parts = node.split(":");
            nodes.add(new HostAndPort(parts[0], Integer.parseInt(parts[1])));
        }
        JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
        jedisCluster = new JedisCluster(nodes, jedisPoolConfig);
    }

    public Object get(String key) {
        return jedisCluster.get(key);
    }

    public String set(String key, String value) {
        return jedisCluster.set(key, value);
    }

    public Long incr(String key) {
        return (Long) execute((JedisClusterCommand<Long>) jedis -> jedis.incr(key));
    }

    public Object execute(JedisClusterCommand<Object> command) {
        return jedisCluster.execute(command);
    }
}

使用示例：

RedisClusterUtil redisClusterUtil = new RedisClusterUtil("redis-node1:7000,redis-node2:7001,redis-node3:7002");
redisClusterUtil.set("foo", "bar");
String value = (String) redisClusterUtil.get("foo");
System.out.println(value); // Output: bar

以上是一个简单的支持集群的Redis工具类封装，可以根据需要扩展更多的Redis命令。