- 浏览: 52690 次
- 性别:
文章分类
最新评论
Redis 简介
Redis 是完全开源免费的,遵守BSD协议,是一个高性能的key-value数据库。
Redis 与其他 key - value 缓存产品有以下三个特点:
Redis支持数据的持久化,可以将内存中的数据保存在磁盘中,重启的时候可以再次加载进行使用。
Redis不仅仅支持简单的key-value类型的数据,同时还提供list,set,zset,hash等数据结构的存储。
Redis支持数据的备份,即master-slave模式的数据备份。
Redis 优势
性能极高 – Redis能读的速度是110000次/s,写的速度是81000次/s 。
丰富的数据类型 – Redis支持二进制案例的 Strings, Lists, Hashes, Sets 及 Ordered Sets 数据类型操作。
原子 – Redis的所有操作都是原子性的,同时Redis还支持对几个操作全并后的原子性执行。
丰富的特性 – Redis还支持 publish/subscribe, 通知, key 过期等等特性。
Redis与其他key-value存储有什么不同?
Redis有着更为复杂的数据结构并且提供对他们的原子性操作,这是一个不同于其他数据库的进化路径。Redis的数据类型都是基于基本数据结构的同时对程序员透明,无需进行额外的抽象。
Redis运行在内存中但是可以持久化到磁盘,所以在对不同数据集进行高速读写时需要权衡内存,因为数据量不能大于硬件内存。在内存数据库方面的另一个优点是,相比在磁盘上相同的复杂的数据结构,在内存中操作起来非常简单,这样Redis可以做很多内部复杂性很强的事情。同时,在磁盘格式方面他们是紧凑的以追加的方式产生的,因为他们并不需要进行随机访问。
redis的MAVEN依赖
<dependency> <groupId>org.springframework.data</groupId> <artifactId>spring-data-redis</artifactId> <version>${spring.data.redis}</version> </dependency> <dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> <version>${redis.client.version}</version> </dependency>
redis的spring配置
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:context="http://www.springframework.org/schema/context" xmlns:mvc="http://www.springframework.org/schema/mvc" xsi:schemaLocation=" http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-3.2.xsd http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.2.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.2.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.2.xsd" default-lazy-init="true"> <!-- jedis 连接池配置 --> <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig"> <!--<property name="maxActive" value="1000" />--> <!--<property name="maxActive" value="${redis.pool.maxActive}" />--> <property name="maxIdle" value="${redis.pool.maxIdle}" /> <property name="maxWait" value="${redis.pool.maxWait}" /> <property name="testOnBorrow" value="${redis.pool.testOnBorrow}" /> </bean> <bean id="jedisPool" class="redis.clients.jedis.JedisPool" destroy-method="destroy"> <constructor-arg index="0" ref="jedisPoolConfig" /> <constructor-arg index="1" value="${redis.host}" /> <constructor-arg index="2" value="${redis.port}" /> </bean> </beans>
package com.ppfuns.core.service; import org.apache.log4j.Logger; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Repository; import redis.clients.jedis.BinaryClient.LIST_POSITION; import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisPool; import redis.clients.jedis.SortingParams; import redis.clients.jedis.Tuple; import java.util.Collection; import java.util.List; import java.util.Map; import java.util.Set; @Repository("redisClientTemplate") public class RedisClientTemplate { private static final Logger log = Logger.getLogger(RedisClientTemplate.class); @Autowired private JedisPool jedisPool; private Jedis getRedisClient() { try { Jedis jedis = jedisPool.getResource(); return jedis; } catch (Exception e) { log.error("getRedisClent error", e); } return null; } private void returnResource(Jedis jedis, boolean broken) { if (broken) { jedisPool.returnBrokenResource(jedis); } else { jedisPool.returnResource(jedis); } } public void disconnect() { Jedis jedis = this.getRedisClient(); jedis.disconnect(); } /** * 设置单个值 * * @param key * @param value * @return */ public String set(String key, String value) { String result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.set(key, value); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } /** * 获取单个值 * * @param key * @return */ public String get(String key) { String result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.get(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } /** * 删除匹配的key * @param key * @return */ public long delKeys(String key) { long count = 0; Jedis jedis = this.getRedisClient(); if (jedis == null) { return count; } boolean broken = false; try { Set<String> keys = jedis.keys(key + "*"); if(keys != null && keys.size() > 0){ jedis.del(keys.toArray(new String[]{})); } } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return count; } /** * 清空redis数据库 * @param key * @return */ public void flushAll() { Jedis jedis = this.getRedisClient(); if (jedis == null) { return; } boolean broken = false; try { jedis.flushDB(); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } } /** * 判断key是否存在 * @param key * @return */ public Boolean exists(String key) { Boolean result = false; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.exists(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public String type(String key) { String result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.type(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } /** * 在某段时间后实现 * * @param key * @param unixTime * @return */ public Long expire(String key, int seconds) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.expire(key, seconds); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } /** * 在某个时间点失效 * * @param key * @param unixTime * @return */ public Long expireAt(String key, long unixTime) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.expireAt(key, unixTime); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long ttl(String key) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.ttl(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public boolean setbit(String key, long offset, boolean value) { Jedis jedis = this.getRedisClient(); boolean result = false; if (jedis == null) { return result; } boolean broken = false; try { result = jedis.setbit(key, offset, value); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public boolean getbit(String key, long offset) { Jedis jedis = this.getRedisClient(); boolean result = false; if (jedis == null) { return result; } boolean broken = false; try { result = jedis.getbit(key, offset); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public long setrange(String key, long offset, String value) { Jedis jedis = this.getRedisClient(); long result = 0; if (jedis == null) { return result; } boolean broken = false; try { result = jedis.setrange(key, offset, value); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public String getrange(String key, long startOffset, long endOffset) { Jedis jedis = this.getRedisClient(); String result = null; if (jedis == null) { return result; } boolean broken = false; try { result = jedis.getrange(key, startOffset, endOffset); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public String getSet(String key, String value) { String result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.getSet(key, value); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long setnx(String key, String value) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.setnx(key, value); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public String setex(String key, int seconds, String value) { String result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.setex(key, seconds, value); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long decrBy(String key, long integer) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.decrBy(key, integer); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long decr(String key) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.decr(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long incrBy(String key, long integer) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.incrBy(key, integer); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long incr(String key) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.incr(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long append(String key, String value) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.append(key, value); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public String substr(String key, int start, int end) { String result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.substr(key, start, end); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long hset(String key, String field, String value) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.hset(key, field, value); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public String hget(String key, String field) { String result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.hget(key, field); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long hsetnx(String key, String field, String value) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.hsetnx(key, field, value); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public String hmset(String key, Map<String, String> hash) { String result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.hmset(key, hash); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public List<String> hmget(String key, String... fields) { List<String> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.hmget(key, fields); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long hincrBy(String key, String field, long value) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.hincrBy(key, field, value); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Boolean hexists(String key, String field) { Boolean result = false; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.hexists(key, field); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long del(String key) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.del(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long hdel(String key, String field) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.hdel(key, field); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long hlen(String key) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.hlen(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Set<String> hkeys(String key) { Set<String> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.hkeys(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public List<String> hvals(String key) { List<String> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.hvals(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Map<String, String> hgetAll(String key) { Map<String, String> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.hgetAll(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } // ================list ====== l表示 list或 left, r表示right==================== public Long rpush(String key, String string) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.rpush(key, string); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long lpush(String key, String string) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.lpush(key, string); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long llen(String key) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.llen(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public List<String> lrange(String key, long start, long end) { List<String> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.lrange(key, start, end); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public String ltrim(String key, long start, long end) { String result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.ltrim(key, start, end); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public String lindex(String key, long index) { String result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.lindex(key, index); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public String lset(String key, long index, String value) { String result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.lset(key, index, value); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long lrem(String key, long count, String value) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.lrem(key, count, value); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public String lpop(String key) { String result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.lpop(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public String rpop(String key) { String result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.rpop(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } //return 1 add a not exist value , //return 0 add a exist value public Long sadd(String key, String member) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.sadd(key, member); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Set<String> smembers(String key) { Set<String> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.smembers(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long srem(String key, String member) { Jedis jedis = this.getRedisClient(); Long result = null; if (jedis == null) { return result; } boolean broken = false; try { result = jedis.srem(key, member); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public String spop(String key) { Jedis jedis = this.getRedisClient(); String result = null; if (jedis == null) { return result; } boolean broken = false; try { result = jedis.spop(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long scard(String key) { Jedis jedis = this.getRedisClient(); Long result = null; if (jedis == null) { return result; } boolean broken = false; try { result = jedis.scard(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Boolean sismember(String key, String member) { Jedis jedis = this.getRedisClient(); Boolean result = null; if (jedis == null) { return result; } boolean broken = false; try { result = jedis.sismember(key, member); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public String srandmember(String key) { Jedis jedis = this.getRedisClient(); String result = null; if (jedis == null) { return result; } boolean broken = false; try { result = jedis.srandmember(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long zadd(String key, double score, String member) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zadd(key, score, member); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Set<String> zrange(String key, int start, int end) { Set<String> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zrange(key, start, end); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long zrem(String key, String member) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zrem(key, member); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Double zincrby(String key, double score, String member) { Double result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zincrby(key, score, member); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long zrank(String key, String member) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zrank(key, member); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long zrevrank(String key, String member) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zrevrank(key, member); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Set<String> zrevrange(String key, int start, int end) { Set<String> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zrevrange(key, start, end); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Set<Tuple> zrangeWithScores(String key, int start, int end) { Set<Tuple> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zrangeWithScores(key, start, end); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Set<Tuple> zrevrangeWithScores(String key, int start, int end) { Set<Tuple> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zrevrangeWithScores(key, start, end); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long zcard(String key) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zcard(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Double zscore(String key, String member) { Double result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zscore(key, member); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public List<String> sort(String key) { List<String> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.sort(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public List<String> sort(String key, SortingParams sortingParameters) { List<String> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.sort(key, sortingParameters); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long zcount(String key, double min, double max) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zcount(key, min, max); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Set<String> zrangeByScore(String key, double min, double max) { Set<String> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zrangeByScore(key, min, max); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Set<String> zrevrangeByScore(String key, double max, double min) { Set<String> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zrevrangeByScore(key, max, min); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Set<String> zrangeByScore(String key, double min, double max, int offset, int count) { Set<String> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zrangeByScore(key, min, max, offset, count); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Set<String> zrevrangeByScore(String key, double max, double min, int offset, int count) { Set<String> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zrevrangeByScore(key, max, min, offset, count); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Set<Tuple> zrangeByScoreWithScores(String key, double min, double max) { Set<Tuple> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zrangeByScoreWithScores(key, min, max); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Set<Tuple> zrevrangeByScoreWithScores(String key, double max, double min) { Set<Tuple> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zrevrangeByScoreWithScores(key, max, min); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Set<Tuple> zrangeByScoreWithScores(String key, double min, double max, int offset, int count) { Set<Tuple> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zrangeByScoreWithScores(key, min, max, offset, count); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Set<Tuple> zrevrangeByScoreWithScores(String key, double max, double min, int offset, int count) { Set<Tuple> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zrevrangeByScoreWithScores(key, max, min, offset, count); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long zremrangeByRank(String key, int start, int end) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zremrangeByRank(key, start, end); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long zremrangeByScore(String key, double start, double end) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zremrangeByScore(key, start, end); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long linsert(String key, LIST_POSITION where, String pivot, String value) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.linsert(key, where, pivot, value); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public String set(byte[] key, byte[] value) { String result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.set(key, value); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public byte[] get(byte[] key) { byte[] result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.get(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Boolean exists(byte[] key) { Boolean result = false; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.exists(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public String type(byte[] key) { String result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.type(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long expire(byte[] key, int seconds) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.expire(key, seconds); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long expireAt(byte[] key, long unixTime) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.expireAt(key, unixTime); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long ttl(byte[] key) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.ttl(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public byte[] getSet(byte[] key, byte[] value) { byte[] result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.getSet(key, value); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long setnx(byte[] key, byte[] value) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.setnx(key, value); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public String setex(byte[] key, int seconds, byte[] value) { String result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.setex(key, seconds, value); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long decrBy(byte[] key, long integer) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.decrBy(key, integer); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long decr(byte[] key) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.decr(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long incrBy(byte[] key, long integer) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.incrBy(key, integer); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long incr(byte[] key) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.incr(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long append(byte[] key, byte[] value) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.append(key, value); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public byte[] substr(byte[] key, int start, int end) { byte[] result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.substr(key, start, end); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long hset(byte[] key, byte[] field, byte[] value) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.hset(key, field, value); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public byte[] hget(byte[] key, byte[] field) { byte[] result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.hget(key, field); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long hsetnx(byte[] key, byte[] field, byte[] value) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.hsetnx(key, field, value); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public String hmset(byte[] key, Map<byte[], byte[]> hash) { String result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.hmset(key, hash); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public List<byte[]> hmget(byte[] key, byte[]... fields) { List<byte[]> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.hmget(key, fields); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long hincrBy(byte[] key, byte[] field, long value) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.hincrBy(key, field, value); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Boolean hexists(byte[] key, byte[] field) { Boolean result = false; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.hexists(key, field); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long hdel(byte[] key, byte[] field) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.hdel(key, field); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long hlen(byte[] key) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.hlen(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Set<byte[]> hkeys(byte[] key) { Set<byte[]> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.hkeys(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Collection<byte[]> hvals(byte[] key) { Collection<byte[]> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.hvals(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Map<byte[], byte[]> hgetAll(byte[] key) { Map<byte[], byte[]> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.hgetAll(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long rpush(byte[] key, byte[] string) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.rpush(key, string); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long lpush(byte[] key, byte[] string) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.lpush(key, string); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long llen(byte[] key) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.llen(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public List<byte[]> lrange(byte[] key, int start, int end) { List<byte[]> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.lrange(key, start, end); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public String ltrim(byte[] key, int start, int end) { String result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.ltrim(key, start, end); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public byte[] lindex(byte[] key, int index) { byte[] result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.lindex(key, index); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public String lset(byte[] key, int index, byte[] value) { String result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.lset(key, index, value); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long lrem(byte[] key, int count, byte[] value) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.lrem(key, count, value); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public byte[] lpop(byte[] key) { byte[] result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.lpop(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public byte[] rpop(byte[] key) { byte[] result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.rpop(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long sadd(byte[] key, byte[] member) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.sadd(key, member); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Set<byte[]> smembers(byte[] key) { Set<byte[]> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.smembers(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long srem(byte[] key, byte[] member) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.srem(key, member); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public byte[] spop(byte[] key) { byte[] result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.spop(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long scard(byte[] key) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.scard(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Boolean sismember(byte[] key, byte[] member) { Boolean result = false; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.sismember(key, member); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public byte[] srandmember(byte[] key) { byte[] result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.srandmember(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long zadd(byte[] key, double score, byte[] member) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zadd(key, score, member); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Set<byte[]> zrange(byte[] key, int start, int end) { Set<byte[]> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zrange(key, start, end); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long zrem(byte[] key, byte[] member) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zrem(key, member); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Double zincrby(byte[] key, double score, byte[] member) { Double result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zincrby(key, score, member); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long zrank(byte[] key, byte[] member) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zrank(key, member); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long zrevrank(byte[] key, byte[] member) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zrevrank(key, member); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Set<byte[]> zrevrange(byte[] key, int start, int end) { Set<byte[]> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zrevrange(key, start, end); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Set<Tuple> zrangeWithScores(byte[] key, int start, int end) { Set<Tuple> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zrangeWithScores(key, start, end); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Set<Tuple> zrevrangeWithScores(byte[] key, int start, int end) { Set<Tuple> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zrevrangeWithScores(key, start, end); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long zcard(byte[] key) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zcard(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Double zscore(byte[] key, byte[] member) { Double result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zscore(key, member); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public List<byte[]> sort(byte[] key) { List<byte[]> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.sort(key); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public List<byte[]> sort(byte[] key, SortingParams sortingParameters) { List<byte[]> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.sort(key, sortingParameters); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long zcount(byte[] key, double min, double max) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zcount(key, min, max); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Set<byte[]> zrangeByScore(byte[] key, double min, double max) { Set<byte[]> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zrangeByScore(key, min, max); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Set<byte[]> zrangeByScore(byte[] key, double min, double max, int offset, int count) { Set<byte[]> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zrangeByScore(key, min, max, offset, count); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Set<Tuple> zrangeByScoreWithScores(byte[] key, double min, double max) { Set<Tuple> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zrangeByScoreWithScores(key, min, max); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Set<Tuple> zrangeByScoreWithScores(byte[] key, double min, double max, int offset, int count) { Set<Tuple> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zrangeByScoreWithScores(key, min, max, offset, count); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Set<byte[]> zrevrangeByScore(byte[] key, double max, double min) { Set<byte[]> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zrevrangeByScore(key, max, min); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Set<byte[]> zrevrangeByScore(byte[] key, double max, double min, int offset, int count) { Set<byte[]> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zrevrangeByScore(key, max, min, offset, count); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Set<Tuple> zrevrangeByScoreWithScores(byte[] key, double max, double min) { Set<Tuple> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zrevrangeByScoreWithScores(key, max, min); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Set<Tuple> zrevrangeByScoreWithScores(byte[] key, double max, double min, int offset, int count) { Set<Tuple> result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zrevrangeByScoreWithScores(key, max, min, offset, count); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long zremrangeByRank(byte[] key, int start, int end) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zremrangeByRank(key, start, end); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long zremrangeByScore(byte[] key, double start, double end) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.zremrangeByScore(key, start, end); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public Long linsert(byte[] key, LIST_POSITION where, byte[] pivot, byte[] value) { Long result = null; Jedis jedis = this.getRedisClient(); if (jedis == null) { return result; } boolean broken = false; try { result = jedis.linsert(key, where, pivot, value); } catch (Exception e) { log.error(e.getMessage(), e); broken = true; } finally { this.returnResource(jedis, broken); } return result; } public boolean redisExist(){ Jedis jedis = this.getRedisClient(); if(null == jedis){ return false; } boolean broken = false; this.returnResource(jedis, broken); return true; } }
发表评论
-
java 之sftp实现
2018-03-31 17:41 656上周进行了linux环境下sftp的配置和用户权限的创建:ht ... -
java webService之CXF的使用
2018-03-29 14:25 446使用场景:华为VOD系统与媒资系统的接口,资产数据(元数据XM ... -
java 中jstat的用法
2018-03-20 18:06 715JDK自带VM分析工具jps,jstat,jmap,jcons ... -
javaEE性能优化
2018-03-20 16:41 500性能的优化一般可以从多方面入手,前端资源,java程序,数据传 ... -
jvm gc日志检查
2018-03-20 15:08 367JVM的GC日志的主要参数包括如下几个: -XX:+Pr ... -
负载均衡的几种原理
2018-03-19 16:05 468什么是负载均衡? 就 ... -
基于TCP协议实现RPC
2018-03-19 11:28 711RPC的全称:Remote Process Call,即远程过 ... -
java 多线程
2018-03-16 13:29 350Java 多线程编程 Java 给 ... -
SpringMVC执行流程图
2018-03-15 10:46 466SpringMVC 流程图 DispatcherServle ... -
Java中BIO、NIO、AIO的原理及其区别
2018-03-12 17:34 656IO的处理方式通常分为 ... -
基于Spring 自定义标签实现
2017-11-30 09:26 549一、源码分析: Spring标签的定义分为默认标签和自定义 ... -
java二维码的生成和解析
2017-09-26 11:15 431一、本文目的: 为了研究对支付宝和微信支付的统一路口管理 ... -
spring-data-redis
2017-09-18 11:54 731Spring-data-redis使用 1、maven依赖 ... -
Java xml与实体Bean的转换
2017-09-05 15:24 6971、pom.xml依赖包: <dependenc ... -
Java JVM虚拟机知识要点
2017-08-30 10:25 5941、JVM虚拟机图解: ... -
java 上传小于占用空间为4k的jpg图片异常问题处理
2017-07-19 18:02 525javaWeb上传图片 jpg占用空间为4k时,Commons ... -
Springmvc 注入字符串与时间格式的转换
2017-03-24 11:10 1189以下列出两种spring支持的时间转换 -、方式一 1、 ... -
linux下修改war包
2017-03-06 15:32 1097Linux上修改war包上的文件 www.MyExceptio ... -
itellij idea 11.1.3 mybatis 自动构建代码
2016-11-16 09:50 442步骤一: 1、在工程中pom.xml加添 <buil ... -
intellij idea 下resin容器远程调试
2016-11-16 09:27 5382resin远程调试(我使用的是resin-4.0.41版本): ...
相关推荐
在Java开发中,Redis是一个非常流行的高性能键值存储系统,常用于缓存、消息队列等场景。本文将深入探讨如何使用Java与Redis进行各种类型的操作,并基于Maven项目管理来构建我们的示例代码。 首先,为了在Java项目...
在Java中操作Redis,我们通常会借助于一些客户端库,如Jedis、Lettuce等。本示例将重点讲解如何使用Java与Redis进行基本的增删改查操作。 1. **连接Redis** 在Java中,我们需要先导入相应的库,如Jedis,然后创建...
JAVA Redis的工具类的工具类,下载后配置好指定的Redis地址,可直接调用。
在Java开发中,Redis是一个非常流行的高性能、内存数据结构存储系统,常被用作数据库、缓存和消息中间件。本示例“java redis demo”是关于如何在Java应用程序中集成并有效使用Redis的一个实例,主要涉及Jedis连接池...
lettuce - 高级Java Redis客户端,用于线程安全同步,异步和reactive用法。 支持群集,Sentinel,管道和编解码器。
本篇文章将深入探讨如何使用Java来实现Redis的消息订阅和发布功能,这在分布式系统和实时数据处理中非常关键。 首先,理解Redis的发布/订阅(Pub/Sub)模式是至关重要的。在这一模式下,Redis服务器作为消息的中间...
标题中的“springboot分布式自增id_javaredis_源码”表明我们关注的是一个使用Spring Boot实现的分布式系统中的自增ID生成方案,其中利用了Java Redis客户端库。在分布式环境中,确保全局唯一且顺序递增的ID是常见的...
jedis.jar redis.jar java缓存 jedis.jar redis.jar java缓存 jedis.jar redis.jar java缓存 jedis.jar redis.jar java缓存
在本文中,我们将深入探讨如何使用Java和Redis的有序集合(Zset)来实现一个排行榜功能。Redis是一个高性能的键值存储系统,它的有序集合数据结构非常适合用来构建排行榜,因为可以方便地进行分数排序和成员操作。 ...
Java 连接 Redis 集群的实现 在这个资源中,我们将探讨如何使用 Java 客户端连接 Redis 集群,并实现单例模式和集群模式的连接。 Redis 集群 Redis 集群是一种高可用性的 Redis 部署方式,通过将多个 Redis 节点...
Java Redis Jar 指的是Java语言与Redis数据库交互所使用的库文件,主要包含Spring框架整合Redis所需的依赖。Redis是一款高性能的键值存储系统,常用于数据缓存、消息队列等场景,而Java作为广泛使用的编程语言,通过...
在IT行业中,Java和Redis是两个非常重要的技术组件。Java是一种广泛应用的编程语言,而Redis则是一种高性能的键值数据库,常用于缓存、消息中间件等场景。本篇文章将详细解析如何使用Java来调用Redis,以实现数据的...
在这个"Java-redis-demo"项目中,我们将会探讨如何在Java环境中集成和使用Redis,以便利用它的强大功能。以下是关于Java与Redis交互的一些关键知识点: 1. **Jedis库**: Java连接Redis最常用的客户端库是Jedis。它...
在IT行业中,Java和Redis是两个非常重要的技术组件。Java是一种广泛应用的编程语言,而Redis则是一种高性能的键值数据库,常用于缓存和实时数据处理。本资源"java_redis简单案例"提供了一个演示如何在Java应用中集成...
Redis是一款高性能的键值对数据...这个`redisDemo.zip`文件可能包含了一个简单的Java项目,演示了如何配置连接池以及使用Jedis进行Redis操作。通过阅读和运行这个示例,你可以更好地理解Java中如何与Redis进行交互。
**Java Redis 学习笔记概览** 在Java开发中,Redis作为一个高性能的键值存储系统,常被用于缓存、消息队列、分布式锁等多种场景。本笔记将深入探讨Java与Redis的集成以及如何利用Springboot框架进行高效操作。 1. ...
在Java开发中,Redis作为一个高性能的键值存储系统,常被用作缓存和消息队列,以提高应用的响应速度和数据处理能力。本文将深入探讨如何在Java环境中进行Redis操作,并对这些操作进行封装,以实现更高效、可复用的...
RedisUtil.java,JAVA Redis工具类
《lettuce-core:高级Java Redis客户端的深度解析》 Redis作为一种高性能的键值数据库,在分布式系统和微服务架构中广泛应用。而Lettuce-core作为Java社区中的一个高级Redis客户端,以其丰富的特性和线程安全性备受...
Java基于Redis实现分布式锁代码实例 分布式锁的必要性 在多线程环境中,资源竞争是一个常见的问题。例如,在一个简单的用户操作中,一个线程修改用户状态,首先在内存中读取用户状态,然后在内存中进行修改,然后...