修改redis连接问题

Pu Zhibing

2024-12-17 3f367b7d7ee0f2297dc1e6ae7b181c74680b942b

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

@@ -20,6 +20,8 @@
    @Autowired
    private JedisPool jedisPool;

    private Jedis resource;


    /**
     * 向redis中存储字符串没有过期时间
@@ -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();
@@ -104,9 +110,10 @@
     * @param value
     */
    public void addListRight(String key, String value){
        Jedis resource = jedisPool.getResource();
        if(null == resource || !resource.isConnected()){
            resource = jedisPool.getResource();
        }
        resource.rpush(key, value);
        closeJedis(resource);
    }
    
    /**
@@ -115,9 +122,10 @@
     * @param value
     */
    public void addListLeft(String key, String value){
        Jedis resource = jedisPool.getResource();
        if(null == resource || !resource.isConnected()){
            resource = jedisPool.getResource();
        }
        resource.lpush(key, value);
        closeJedis(resource);
    }
    
    
@@ -127,7 +135,9 @@
     * @return
     */
    public String getListFirstValue(String key){
        Jedis resource = jedisPool.getResource();
        if(null == resource || !resource.isConnected()){
            resource = jedisPool.getResource();
        }
        String lpop = resource.lpop(key);
        return lpop;
    }
@@ -140,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();
        }
    }

}