zoukankan      html  css  js  c++  java
  • 一些常用的 redis 的操作配置(对String、hash)

    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;
        }
    }
  • 相关阅读:
    安装和使用 PyInstaller 遇到的问题
    Mininet 系列实验(七)
    Mininet 系列实验(六)
    Mininet 系列实验(五)
    Mininet 系列实验(三)
    Mininet 系列实验(一)
    Linux进程间通信(消息队列/信号量+共享内存)
    bugku 输入密码查看flag
    bugku 头等舱
    bugku 你必须让他停下
  • 原文地址:https://www.cnblogs.com/zouhong/p/12074750.html
Copyright © 2011-2022 走看看