多次访问redis造成redis连接断开的解决方案

àì夳堔傛蜴生んèń 2023-10-18 16:05 103阅读 0赞

创建一个数组存储redis链接，失效自动创建加入数组，

附上代码一段简单代码，欢迎吐槽

package test;
    
    import java.util.Random;
    
    import redis.clients.jedis.Jedis;
    
    public class RedisArrayUtil {
        private static Jedis[] jedisArray;
        private static int jedisArraySize;
        private static String jedisHost;
        private static int jedisPort;
        private static Random random = new Random();
    
        private RedisArrayUtil(int jedisArraySize, String jedisHost, int jedisPort) {
            this.jedisArraySize = jedisArraySize;
            this.jedisHost = jedisHost;
            this.jedisPort = jedisPort;
            jedisPool();
        }
    
        @SuppressWarnings("resource")
        public static void jedisPool() {
            jedisArray = new Jedis[jedisArraySize];
            for (int i = 0; i < jedisArraySize; i++) {
                Jedis jedis = new Jedis(jedisHost, jedisPort);
                if (jedis.ping().equals("PONG")) {
                    jedisArray[i] = jedis;
                } else {
                    jedis = new Jedis(jedisHost, jedisPort);
                    jedisArray[i] = jedis;
                }
            }
        }
    
        public Jedis getConnection() {
            int randomCount;
            Jedis jedis;
            while (true) {
                randomCount = random.nextInt(jedisArraySize - 1);
                jedis = jedisArray[randomCount];
                if (jedis.ping().equals("PONG")) {
                    break;
                } else {
                    delete(randomCount, jedisArray);
                    addJedis();
                }
            }
            return jedis;
        }
    
        /** @param 删除数组指定位 */
        public Jedis[] delete(int index, Jedis array[]) {
            Jedis[] jedisArrayNew = new Jedis[array.length - 1];
            for (int i = 0; i < jedisArrayNew.length - 1; i++) {
                if (i < index) {
                    jedisArrayNew[i] = array[i];
                } else {
                    jedisArrayNew[i] = array[i + 1];
                }
            }
            return jedisArrayNew;
        }
    
        public void addJedis() {
            @SuppressWarnings("resource")
            Jedis jedis = new Jedis(jedisHost, jedisPort);
            while (true) {
                if (jedis.ping().equals("PONG")) {
                    jedisArray[jedisArraySize] = jedis;
                    break;
                }
            }
        }
    
        public static void main(String[] args) {
            RedisArrayUtil redisArrayUtil = new RedisArrayUtil(10, "127.0.0.1",
                    6379);
            Jedis jedis = redisArrayUtil.getConnection();
            for (int i = 0; i < 10; i++) {
                System.out.println(redisArrayUtil.getConnection());
            }
            
        }
    }