一些常用的 redis 的操作配置（对Stringhash）

Posted 2021-03-21 小破孩楼主

import java.util.List;
import java.util.Map;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;

/**
 * 配置一些常用的 redis 的操作
 */
public class RedisClient {

    private Logger log = LogManager.getLogger(RedisClient.class);

    private JedisPool jedisPool;


    public void set(String key, String value) {
        Jedis jedis = null;
        try {
            jedis = jedisPool.getResource();
            jedis.set(key, value);
        }catch (Exception e){
            log.error(e.getMessage(),e);
            throw e;
        }finally {
            if(null != jedis){
                jedis.close();
            }
        }
    }

    public String get(String key) {

        Jedis jedis = null;
        try {
            jedis = jedisPool.getResource();
            return jedis.get(key);
        } catch (Exception e){
            log.error(e.getMessage(),e);
            throw e;
        }finally {
            if(null != jedis){
                jedis.close();
            }
        }
    }
    
    public void hset(String key, String field, String value){
        Jedis jedis = null;
        try {
            jedis = jedisPool.getResource();
            jedis.hset(key, field, value);
        }catch (Exception e){
            log.error(e.getMessage(),e);
            throw e;
        }finally {
            if(null != jedis){
                jedis.close();
            }
        }
    }

    public String hget(String key, String field) {
        Jedis jedis = null;
        try {
            jedis = jedisPool.getResource();
            return jedis.hget(key, field);
        } catch (Exception e){
            log.error(e.getMessage(),e);
            throw e;
        }finally {
            if(null != jedis){
                jedis.close();
            }
        }
    }
    
    public void hmset(String key, Map<String, String> hash){
        Jedis jedis = null;
        try {
            jedis = jedisPool.getResource();
            jedis.hmset(key, hash);
        }catch (Exception e){
            log.error(e.getMessage(),e);
            throw e;
        }finally {
            if(null != jedis){
                jedis.close();
            }
        }
    }

    public List<String> hmget(String key, String... fields) {
        Jedis jedis = null;
        try {
            jedis = jedisPool.getResource();
            return jedis.hmget(key, fields);
        } catch (Exception e){
            log.error(e.getMessage(),e);
            throw e;
        }finally {
            if(null != jedis){
                jedis.close();
            }
        }
    }

    public Long del(String key) {

        Jedis jedis = null;
        try {
            jedis = jedisPool.getResource();
            return jedis.del(key);
        } catch (Exception e){
            log.error(e.getMessage(),e);
            throw e;
        }finally {
            jedis.close();
        }

    }


    public JedisPool getJedisPool() {
        return jedisPool;
    }

    public void setJedisPool(JedisPool jedisPool) {
        this.jedisPool = jedisPool;
    }
}