底层redis迭代修改不兼容代码

许鹏程

2024-09-26 b3ee22903d12461ee5bf6e3b38e1684a6daa61ea

底层redis迭代修改不兼容代码

 src/main/java/com/product/datasource/service/RedisService.java

@@ -34,7 +34,6 @@
    private JSONObject curObj;
    private static final int CONNECTION_TIMEOUT = 60000;// 连接超时时间
    private static final int SO_TIMEOUT = 60000;// 读取超时时间
    private boolean localFlag;
    private static Map<JSONObject, JedisPool> map = Maps.newHashMap();
    private static Map<JSONObject, JedisSentinelPool> sentinelPoolMap = Maps.newHashMap();
    private static Map<JSONObject, RedisSentinelUtil> redisSentinelUtil = Maps.newHashMap();
@@ -51,10 +50,6 @@
        } catch (Exception e) {
            throw new BaseException(ErrorCode.GET_REDIS_CONNECTION_FAIL);
        }
    }

    public RedisService() {
        this.localFlag = true;
    }

    public void close() {
@@ -75,9 +70,6 @@
     * @return Jedis
     */
    public Jedis getJedis() {
        if (localFlag) {
            return RedisUtil.getJedis();
        }
        String dbType = curObj.getString("db_type");
        Jedis jedis;
        if ("6".equals(dbType)) {