Jedis的使用
Jedis
創建一個redis操作的接口
分別創建兩個實現類,對應redis 的單機版和集群版
當使用單機版redis時,配置單機版的實現類
當使用集群版本的時候,配置集群版的實現類
單機版
/*** redis客戶端單機版實現類*/ public class JedisClientSingle implements JedisClient{@Autowiredprivate JedisPool jedisPool;@Overridepublic String set(String key, String value) {Jedis jedis = jedisPool.getResource();String result = jedis.set(key, value);jedis.close();return result;}@Overridepublic String get(String key) {Jedis jedis = jedisPool.getResource();String result = jedis.get(key);jedis.close();return result;}@Overridepublic Long hset(String key, String item, String value) {Jedis jedis = jedisPool.getResource();Long result = jedis.hset(key, item, value);jedis.close();return result;}@Overridepublic String hget(String key, String item) {Jedis jedis = jedisPool.getResource();String result = jedis.hget(key, item);jedis.close();return result;}@Overridepublic Long incr(String key) {Jedis jedis = jedisPool.getResource();Long result = jedis.incr(key);jedis.close();return result;}@Overridepublic Long decr(String key) {Jedis jedis = jedisPool.getResource();Long result = jedis.decr(key);jedis.close();return result;}@Overridepublic Long expire(String key, int second) {Jedis jedis = jedisPool.getResource();Long result = jedis.expire(key, second);jedis.close();return result;}@Overridepublic Long ttl(String key) {Jedis jedis = jedisPool.getResource();Long result = jedis.ttl(key);jedis.close();return result;}}集群版
/*** redis客戶端集群版實現類*/ public class JedisClientCluster implements JedisClient {@Autowiredprivate JedisCluster jedisCluster;@Overridepublic String set(String key, String value) {return jedisCluster.set(key, value);}@Overridepublic String get(String key) {return jedisCluster.get(key);}@Overridepublic Long hset(String key, String item, String value) {return jedisCluster.hset(key, item, value);}@Overridepublic String hget(String key, String item) {return jedisCluster.hget(key, item);}@Overridepublic Long incr(String key) {return jedisCluster.incr(key);}@Overridepublic Long decr(String key) {return jedisCluster.decr(key);}@Overridepublic Long expire(String key, int second) {return jedisCluster.expire(key, second);}@Overridepublic Long ttl(String key) {return jedisCluster.ttl(key);}}總結
- 上一篇: Redis集群的重启
- 下一篇: Jedis的Spring配置