修改redis连接问题

Pu Zhibing

2024-12-17 3f367b7d7ee0f2297dc1e6ae7b181c74680b942b

 ZuulAHTravel/src/main/java/com/sinata/zuul/util/RedisUtil.java

@@ -19,6 +19,8 @@

    @Autowired
    private JedisPool jedisPool;
    
    private Jedis resource;


    /**
@@ -28,9 +30,10 @@
     */
    public void setStrValue(String key, String value){
        if(StringUtil.isNotEmpty(key)){
            Jedis resource = jedisPool.getResource();
            if(null == resource || !resource.isConnected()){
                resource = jedisPool.getResource();
            }
            String set = resource.set(key, value);
            closeJedis(resource);
        }
    }

@@ -43,9 +46,10 @@
     */
    public void setStrValue(String key, String value, int time){
        if(StringUtil.isNotEmpty(key)){
            Jedis resource = jedisPool.getResource();
            if(null == resource || !resource.isConnected()){
                resource = jedisPool.getResource();
            }
            String setex = resource.setex(key, time, value);
            closeJedis(resource);
        }
    }

@@ -57,9 +61,10 @@
     */
    public String getValue(String key){
        if(StringUtil.isNotEmpty(key)){
            Jedis resource = jedisPool.getResource();
            if(null == resource || !resource.isConnected()){
                resource = jedisPool.getResource();
            }
            String data = resource.get(key);
            closeJedis(resource);
            return data;
        }
        return null;
@@ -73,14 +78,15 @@
     */
    public List<Object> getValues(List<String> kes){
        if(null != kes){
            Jedis resource = jedisPool.getResource();
            if(null == resource || !resource.isConnected()){
                resource = jedisPool.getResource();
            }
            Pipeline pipelined = resource.pipelined();
            for(String key : kes){
                pipelined.get(key);
            }
            List<Object> list = pipelined.syncAndReturnAll();

            closeJedis(resource);
            pipelined.clear();
            try {
                pipelined.close();
@@ -97,7 +103,46 @@
        }
        return null;
    }

    
    /**
     * 添加数据到set集群
     * @param key
     * @param value
     */
    public void addListRight(String key, String value){
        if(null == resource || !resource.isConnected()){
            resource = jedisPool.getResource();
        }
        resource.rpush(key, value);
    }
    
    /**
     * 添加数据到set集群
     * @param key
     * @param value
     */
    public void addListLeft(String key, String value){
        if(null == resource || !resource.isConnected()){
            resource = jedisPool.getResource();
        }
        resource.lpush(key, value);
    }
    
    
    /**
     * 获取list中第一个数据
     * @param key
     * @return
     */
    public String getListFirstValue(String key){
        if(null == resource || !resource.isConnected()){
            resource = jedisPool.getResource();
        }
        String lpop = resource.lpop(key);
        return lpop;
    }
    
    

    /**
     * 删除key
@@ -105,20 +150,13 @@
     */
    public void remove(String key){
        if(StringUtil.isNotEmpty(key)){
            Jedis resource = jedisPool.getResource();
            if(null == resource || !resource.isConnected()){
                resource = jedisPool.getResource();
            }
            Long del = resource.del(key);
            closeJedis(resource);
        }
    }


    /**
     * 删除资源
     * @param jedis
     */
    public void closeJedis(Jedis jedis){
        if(null != jedis){
            jedis.close();
        }
    }

}