使用多執行緒做到斷線重連線

圖形參考tomcat接受請求，處理http頭模型

code：

public class RedisUtils implements Runnable {

    public static boolean RedisState = true;

    public static RedisUtils redisUtils = new RedisUtils();

    static{

       new Thread(redisUtils).start();

    }

    @Override

    public void run() {

        while (true) {

            synchronized (redisUtils) {

                while (!RedisState) {

                   try {

                       Jedis jedis = new Jedis("10.0.0.4");

                       jedis.auth("xiaoxiao");

                       String ping = jedis.ping();

                       if (ping.equals("PONG")) {

                           RedisState = true;

                           System.out.println("redis連線成功，停止當前執行緒");

                           synchronized (redisUtils){

                               redisUtils.wait();

                           }

                       }

                   }catch (Exception e){

                       System.out.println("redis連線失敗 10s繼續嘗試連線");

                       try {

                           Thread.sleep(10000);

                       } catch (InterruptedException e1) {

                           e1.printStackTrace();

                       }

                   }

                }

                try {

                    redisUtils.wait();

                } catch (InterruptedException e) {

                    e.printStackTrace();

                }

            }

        }

    }

}

Code:

String cache_name = cache.value();

    Object resule = null;

    if (RedisUtils.RedisState) {

        try {

            Object caches = redisTemplate.opsForHash().get(cache_name, joinPoint.getArgs()[0]);

            System.out.println(caches);

            if (caches != null) {

                logger.info("Redis 取值");

                return caches;

            }

        } catch (Exception e) {

            logger.error(e.toString());

            RedisUtils.RedisState = false;

            synchronized (RedisUtils.redisUtils) {

                RedisUtils.redisUtils.notify();

            }

        }

    }

    try {

        resule = joinPoint.proceed();

        logger.info("資料庫取值");

        if (RedisUtils.RedisState) {

            redisTemplate.opsForHash().put(cache_name, joinPoint.getArgs()[0], resule);

        }

    } catch (Throwable throwable) {

        throwable.printStackTrace();

    }

    return resule;

}