美文网首页
Java使用Jedis操作Redis数据库(纯代码)

Java使用Jedis操作Redis数据库(纯代码)

作者: 一个不起眼的程序员 | 来源:发表于2019-03-05 16:02 被阅读0次

    RedisUtil工具类

    public final class RedisUtil {
    
        //Redis服务器IP
        private static String ADDR;
    
        //Redis的端口号
        private static int PORT;
    
        //访问密码
        private static String AUTH;
    
        //可用连接实例的最大数目,默认值为8;
        //如果赋值为-1,则表示不限制;如果pool已经分配了maxActive个jedis实例,则此时pool的状态为exhausted(耗尽)。
        private static int MAX_ACTIVE;
    
        //控制一个pool最多有多少个状态为idle(空闲的)的jedis实例,默认值也是8。
        private static int MAX_IDLE;
    
        //等待可用连接的最大时间,单位毫秒,默认值为-1,表示永不超时。如果超过等待时间,则直接抛出JedisConnectionException;
        private static int MAX_WAIT;
    
        private static int TIMEOUT;
    
        //在borrow一个jedis实例时,是否提前进行validate操作;如果为true,则得到的jedis实例均是可用的;
        private static boolean TEST_ON_BORROW = true;
    
        private static JedisPool jedisPool = null;
    
        /**
         * 初始化Redis连接池
         */
        static {
            try {
                //初始化配置
                //redis.properties需放在resource文件夹下
                InputStream fis = RedisUtil.class.getClassLoader().getResourceAsStream("redis.properties");
                PropertyResourceBundle props = new PropertyResourceBundle(fis);
                ADDR = props.getString("addr");
                PORT = Integer.parseInt(props.getString("port"));
                AUTH = props.getString("auth");
                MAX_ACTIVE = Integer.parseInt(props.getString("max_active"));
                MAX_IDLE = Integer.parseInt(props.getString("max_idle"));
                MAX_WAIT = Integer.parseInt(props.getString("max_wait"));
                TIMEOUT = Integer.parseInt(props.getString("timeout"));
    
                JedisPoolConfig config = new JedisPoolConfig();
                config.setMaxTotal(MAX_ACTIVE);
                config.setMaxIdle(MAX_IDLE);
                config.setMaxWaitMillis(MAX_WAIT);
                config.setTestOnBorrow(TEST_ON_BORROW);
                //判断有没有AUTH
                if(StringUtils.isEmpty(AUTH)) {//如果没有密码
                    jedisPool = new JedisPool(config, ADDR, PORT, TIMEOUT);
                } else {
                    jedisPool = new JedisPool(config, ADDR, PORT, TIMEOUT, AUTH);
                }
    
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    
        /**
         * 获取Jedis实例
         * @return
         */
        public static Jedis getJedis() {
            try {
                if (jedisPool != null) {
                    Jedis resource = jedisPool.getResource();
    
                    return resource;
                } else {
                    return null;
                }
            } catch (Exception e) {
                e.printStackTrace();
                return null;
            }
        }
    
        /**
         * 释放jedis资源
         * @param jedis
         */
        public static void returnResource(final Jedis jedis) {
            if (jedis != null) {
                jedis.close();
                //jedisPool.returnResource(jedis);
            }
        }
    
        /**
         * redis set操作
         * @param db 操作的数据库编号
         * @param key
         * @param value
         * @return
         */
        public static String set(int db, String key, String value) {
            Jedis jedis = null;
            String result = null;
            try {
                jedis = getJedis();
                if(jedis != null) {
                    jedis.select(db);
                    result = jedis.set(key, value);
                }
                return result;
            } catch (Exception e) {
                e.printStackTrace();
                returnResource(jedis);
                return result;
            } finally {
                returnResource(jedis);
            }
        }
    
        /**
         * redis setex操作
         * @param db 操作的数据库编号
         * @param key
         * @param value
         * @param seconds
         * @return
         */
        public static String setex(int db, String key, String value, int seconds) {
            Jedis jedis = null;
            String result = null;
            try {
                jedis = getJedis();
                if(jedis != null) {
                    jedis.select(db);
                    result = jedis.setex(key, seconds, value);
                }
                return result;
            } catch (Exception e) {
                e.printStackTrace();
                returnResource(jedis);
                return result;
            } finally {
                returnResource(jedis);
            }
        }
    
        /**
         * redis set操作
         * @param db 操作的数据库编号
         * @param key
         * @return
         */
        public static String get(int db, String key) {
            Jedis jedis = null;
            String value = null;
            try {
                jedis = getJedis();
                if(jedis != null) {
                    jedis.select(db);
                    value = jedis.get(key);
                }
                return value;
            } catch (Exception e) {
                e.printStackTrace();
                returnResource(jedis);
                return value;
            } finally {
                returnResource(jedis);
            }
        }
    
        /**
         * redis del操作
         * @param db 操作的数据库编号
         * @param key
         * @return
         */
        public static Long del(int db, String key) {
            Jedis jedis = null;
            Long result = null;
            try {
                jedis = getJedis();
                if(jedis != null) {
                    jedis.select(db);
                    result = jedis.del(key);
                }
                return result;
            } catch (Exception e) {
                e.printStackTrace();
                returnResource(jedis);
                return result;
            } finally {
                returnResource(jedis);
            }
        }
    
        /**
         * redis hmset操作
         * @param db 操作的数据库编号
         * @param key
         * @param value
         * @return
         */
        public static String hmset(int db, String key, Map<String, String> value) {
            Jedis jedis = null;
            String result = null;
            try {
                jedis = getJedis();
                if(jedis != null) {
                    jedis.select(db);
                    result = jedis.hmset(key, value);
                }
                return result;
            } catch (Exception e) {
                e.printStackTrace();
                returnResource(jedis);
                return result;
            } finally {
                returnResource(jedis);
            }
        }
    
        /**
         * redis hmset操作,设置过期时间
         * @param db 操作的数据库编号
         * @param key
         * @param value
         * @param seconds 过期时间
         * @return
         */
        public static String hmsetex(int db, String key, Map<String, String> value, int seconds) {
            Jedis jedis = null;
            String result = null;
            try {
                jedis = getJedis();
                if(jedis != null) {
                    jedis.select(db);
                    result = jedis.hmset(key, value);
                    jedis.expire(key, seconds);
                }
                return result;
            } catch (Exception e) {
                e.printStackTrace();
                returnResource(jedis);
                return result;
            } finally {
                returnResource(jedis);
            }
        }
    
        /**
         * redis hgetAll操作
         * @param db 操作的数据库编号
         * @param key
         * @return
         */
        public static Map<String, String> hgetAll(int db, String key) {
            Jedis jedis = null;
            Map<String, String> value = null;
            try {
                jedis = getJedis();
                if(jedis != null) {
                    jedis.select(db);
                    value = jedis.hgetAll(key);
                }
                return value;
            } catch (Exception e) {
                e.printStackTrace();
                returnResource(jedis);
                return value;
            } finally {
                returnResource(jedis);
            }
        }
    
        /**
         * redis sismember操作
         * @param db 操作的数据库编号
         * @param key
         * @param member
         * @return
         */
        public static boolean sismember(int db, String key, String member) {
            Jedis jedis = null;
            boolean result = false;
            try {
                jedis = getJedis();
                if(jedis != null) {
                    jedis.select(db);
                    result = jedis.sismember(key, member);
                }
                return result;
            } catch (Exception e) {
                e.printStackTrace();
                returnResource(jedis);
                return result;
            } finally {
                returnResource(jedis);
            }
        }
    
        /**
         * redis lpush操作
         * @param db 操作的数据库编号
         * @param key
         * @param value
         * @return
         */
        public static long lpush(int db, String key, String value) {
            Jedis jedis = null;
            long result = 0;
            try {
                jedis = getJedis();
                if(jedis != null) {
                    jedis.select(db);
                    result = jedis.lpush(key, value);
                }
                return result;
            } catch (Exception e) {
                e.printStackTrace();
                returnResource(jedis);
                return result;
            } finally {
                returnResource(jedis);
            }
        }
    
        /**
         * redis rpop操作
         * @param db 操作的数据库编号
         * @param key
         * @return
         */
        public static String rpop(int db, String key) {
            Jedis jedis = null;
            String value = null;
            try {
                jedis = getJedis();
                if(jedis != null) {
                    jedis.select(db);
                    value = jedis.rpop(key);
                }
                return value;
            } catch (Exception e) {
                e.printStackTrace();
                returnResource(jedis);
                return value;
            } finally {
                returnResource(jedis);
            }
        }
    
        /**
         * redis hset操作
         * @param db 操作的数据库编号
         * @param key
         * @param field
         * @param value
         * @return
         */
        public static long hset(int db, String key, String field, String value) {
            Jedis jedis = null;
            long result = 0;
            try {
                jedis = getJedis();
                if(jedis != null) {
                    jedis.select(db);
                    result = jedis.hset(key, field, value);
                }
                return result;
            } catch (Exception e) {
                e.printStackTrace();
                returnResource(jedis);
                return result;
            } finally {
                returnResource(jedis);
            }
        }
    
    }
    

    resource下需要引入的配置文件

    addr=127.0.0.1
    
    port=6379
    
    auth=
    
    max_active=100
    
    max_idle=100
    
    max_wait=10000
    
    timeout=10000
    

    maven需要添加的依赖jar包

          <dependency>
              <groupId>org.apache.commons</groupId>
              <artifactId>commons-lang3</artifactId>
              <version>3.7</version>
          </dependency>
        <dependency>
          <groupId>redis.clients</groupId>
          <artifactId>jedis</artifactId>
          <version>2.9.0</version>
        </dependency>
    

    相关文章

      网友评论

          本文标题:Java使用Jedis操作Redis数据库(纯代码)

          本文链接:https://www.haomeiwen.com/subject/cmqouqtx.html