使用了不到200行的核心代码就实现了一个美轮美奂的Redis客户端

package com.madou.dbtool.redis.manager;

import com.madou.common.annotation.HideClass;
import com.madou.dbtool.language.redis.parser.RedisContentTypeParser;
import com.madou.inters.util.TipUtils;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisMonitor;
import redis.clients.jedis.Protocol;
import redis.clients.jedis.params.ScanParams;
import redis.clients.jedis.resps.ScanResult;

import java.io.UnsupportedEncodingException;
import java.util.*;

/**
 * @author miukoo
 * Redis 直连客户端
 */
@HideClass("directRedisSourceManager")
public class DirectRedisSourceManager implements RedisSourceManager {
    String host;
    int port;
    Jedis jedis;
    String password;
    // 标记是否为集群
    boolean cluster=false;
    // 集群连接器
    ClusterRedisSourceManager clusterRedisSourceManager;

    public DirectRedisSourceManager(String host,int port,String password){
        this.host = host;
        this.port = port;
        this.password = password;
    }

    private synchronized Jedis connection(){
        if(jedis==null||!jedis.isConnected()) {
            try {
                jedis = new Jedis(host, port);
                if (password != null && password != "") {
                    jedis.auth(password);
                }
                jedis.info();
            }catch (Exception e){
                TipUtils.showErrorDialog("连接失败："+e.getMessage(),"Tips");
            }
        }
        return  jedis;
    }

    @Override
    public int getDBCount() {
        connection();
        return Integer.parseInt(jedis.configGet("databases").get(1));
    }

    @Override
    public boolean isCluster() {
        return cluster;
    }

    @Override
    public List<RedisNodeInfo> getNodes() {
        connection();
        String info = jedis.info();
        List<RedisNodeInfo> list = new ArrayList<>();
        if(info.contains("cluster_enabled:1")){
            cluster=true;
            ClusterRedisSourceManager clusterRedisSourceManager = new ClusterRedisSourceManager(host,port,password);
            String[] nodes = jedis.clusterNodes().split("\n");
            for (String node : nodes) {
                String tmp[] = node.split(" ");
                String addr[] = tmp[1].split("@");
                RedisNodeInfo redisNodeInfo = new RedisNodeInfo();
                redisNodeInfo.setIp(addr[0].split(":")[0]);
                redisNodeInfo.setPort(Integer.valueOf(addr[0].split(":")[1]));
                redisNodeInfo.setRole(tmp[2]);
                if(redisNodeInfo.getIp().equals(host)&&redisNodeInfo.getPort()==port){
                    redisNodeInfo.setRedisSourceManager(new ClusterRedisSourceManager(host,port,password,this));
                }else {
                    redisNodeInfo.setRedisSourceManager(new ClusterRedisSourceManager(redisNodeInfo.getIp(),redisNodeInfo.getPort(),password));
                }
                list.add(redisNodeInfo);
            }
        }else {
            RedisNodeInfo redisNodeInfo = new RedisNodeInfo();
            redisNodeInfo.setIp(host);
            redisNodeInfo.setPort(port);
            redisNodeInfo.setRedisSourceManager(this);
            list.add(redisNodeInfo);
        }
        return list;
    }

    @Override
    public Long getDBSize(int index) {
        connection();
        jedis.select(index);
        return jedis.dbSize();
    }

    /**
     * 获取第一页的数据
     * @return
     */
    @Override
    public List<String> getFirst(int index) {
        connection();
        jedis.select(index);
        return jedis.scan("").getResult();
    }

    /**
     * 执行命令
     * @param commandText
     * @return
     */
    @Override
    public Object execute(int index,String commandText){
        connection();
        if(index>=0) {
            jedis.select(index);
        }
        String[] temp = commandText.trim().split(" ");
        Protocol.Command command = Protocol.Command.valueOf(temp[0].toUpperCase(Locale.ROOT));
        List<String> args = new ArrayList<>();
        for (int i = 1; i < temp.length; i++) {
            if(temp[i]!=""&&temp[i]!=" "){
                args.add(temp[i]);
                if(i==1) {
                    RedisContentTypeParser.redisKeywordTrieLoader.addWord(temp[i]);
                }
            }
        }
        String[] commandArgs = new String[args.size()];
        args.toArray(commandArgs);
        if(commandText.length()<20){
            RedisContentTypeParser.redisKeywordTrieLoader.addWord(commandText);
        }
        return jedis.sendCommand(command, commandArgs);
    }

    /**
     * 开启监控
     * @param jedisMonitor
     * @return
     */
    @Override
    public void monitor(JedisMonitor jedisMonitor){
        connection();
        jedis.monitor(jedisMonitor);
    }

    @Override
    public RedisSourceManager cloneDirect() {
        return new DirectRedisSourceManager(host,port,password);
    }

    @Override
    public RedisSourceManager cloneCluster() {
        return cloneDirect();
    }

    @Override
    public void close() {
        if(jedis!=null){
            jedis.disconnect();
            jedis.close();
            jedis = null;
        }
    }

}