1.1、簡介
Jedis Client是Redis官網推薦的壹個面向java客戶端,庫文件實現了對各類API進行封裝調用。
Jedis源碼工程地址:/xetorthio/jedis
1.2、使用
Redis Client最好選用與服務端對應的版本,本例中使用Redis 2.8.19客戶端使用jedis -2.6.3,Maven工程添加如下引用即可。
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.6.3</version>
<type>jar</type>
<scope>compile</scope>
</dependency>1.3、註意事項
Redis Client擁有眾多對接版本,本項目目前使用Jedis為官方推薦Java對接客戶端,是基於其對Redis良好的版本支持和API對接,另外編碼中盡量避免使用廢棄接口。
Redis目前正在新版過渡期,3.0版本暫未穩定,但是由於3.0版本提供了最新的集群功能,可能在日後穩定版發布以後升級到3.0,目前使用的Jedis支持3.0的目前版本API。
二、Redis Client常用API
2.1、環境要求
語言:Java
JDK:1.7
Redis : 2.8.19(穩定版)
2.2、系統使用
2.2.1、建立連接
普通連接
Jedis jedis = new Jedis("localhost");
jedis.set("foo", "bar");
String value = jedis.get("foo");
System.out.println(value);設置連接池配置
該方法用於得到redis連接池連接使用的連接池配置,該連接池配置也可以通過spring註入的方式來進行相對應的配置,連接池采用的是平時比較常用的org.apache.commons.pool2.impl.GenericObjectPoolConfig來進行的連接池管理
配置文件如下
#redis服務器ip #
redis.ip=172.30.5.117
#redis服務器端口號#
redis.port=6379
###jedis##pool##config###
#jedis的最大分配對象#
jedis.pool.maxActive=1024
#jedis最大保存idel狀態對象數 #
jedis.pool.maxIdle=200
#jedis池沒有對象返回時,最大等待時間 #
jedis.pool.maxWait=1000
#jedis調用borrowObject方法時,是否進行有效檢查#
jedis.pool.testOnBorrow=true
#jedis調用returnObject方法時,是否進行有效檢查 #
jedis.pool.testOnReturn=true連接池配置實例化代碼(也可通過spring註入進行配置):
/**
* 獲取化連接池配置
* @return JedisPoolConfig
* */
private JedisPoolConfig getPoolConfig(){
if(config == null){
config = new JedisPoolConfig();
//最大連接數
config.setMaxTotal(Integer.valueOf(getResourceBundle().getString("redis.pool.maxTotal")));
//最大空閑連接數
config.setMaxIdle(Integer.valueOf(getResourceBundle().getString("redis.pool.maxIdle")));
//獲取連接時的最大等待毫秒數(如果設置為阻塞時BlockWhenExhausted),如果超時就拋異常, 小於零:阻塞不確定的時間, 默認-1
config.setMaxWaitMillis(Long.valueOf(getResourceBundle().getString("redis.pool.maxWaitMillis")));
//在獲取連接的時候檢查有效性, 默認false
config.setTestOnBorrow(Boolean.valueOf(getResourceBundle().getString("redis.pool.testOnBorrow")));
//在獲取返回結果的時候檢查有效性, 默認false
config.setTestOnReturn(Boolean.valueOf(getResourceBundle().getString("redis.pool.testOnReturn")));
}
return config;
}普通連接池連接
這裏展示的是普通的連接池方式鏈接redis的方案,跟普通的數據庫連接池的操作方式類似;
/**
* 初始化JedisPool
* */
private void initJedisPool(){
if(pool == null){
//獲取服務器IP地址
String ipStr = getResourceBundle().getString("redis.ip");
//獲取服務器端口
int portStr = Integer.valueOf(getResourceBundle()
.getString("redis.port"));
//初始化連接池
pool = new JedisPool(getPoolConfig(), ipStr,portStr);
}
}Sentinel連接池連接
該連接池用於應對Redis的Sentinel的主從切換機制,能夠正確在服務器宕機導致服務器切換時得到正確的服務器連接,當服務器采用該部署策略的時候推薦使用該連接池進行操作;
private void initJedisSentinelPool(){
if(sentinelpool == null){
//監聽器列表
Set<String> sentinels = new HashSet<String>();
//監聽器1
sentinels.add(new HostAndPort("192.168.50.236",
26379).toString());
//監聽器2
sentinels.add(new HostAndPort("192.168.50.237",
26379).toString());
//實際使用的時候在properties裏配置即可:redis.sentinel.hostandports
=192.168.50.236:26379,192.168.50.237:26379
getResourceBundle().getString("redis.sentinel.hostandports")
//mastername是服務器上的master的名字,在master服務器的sentinel.conf中配置:
//[sentinel monitor server-1M 192.168.50.236 6379 2]
//中間的server-1M即為這裏的masterName
String masterName = getResourceBundle()
.getString("redis.sentinel.masterName");
//初始化連接池
sentinelpool = new JedisSentinelPool(masterName,
sentinels, getPoolConfig());
}
}ShardedJedisPool連接池分片連接
/**
* 初始化ShardedJedisPool
* Redis在容災處理方面可以通過服務器端配置Master-Slave模式來實現。
* 而在分布式集群方面目前只能通過客戶端工具來實現壹致性哈希分布存儲,即key分片存儲。
* Redis可能會在3.0版本支持服務器端的分布存儲
* */
private void initShardedJedisPool() {
if (shardPool == null) {
// 創建多個redis***享服務
String redis1Ip = getResourceBundle().getString("redis1.ip");
int redis1Port = Integer.valueOf(bundle.getString("redis.port"));
JedisShardInfo jedisShardInfo1 = new JedisShardInfo(redis1Ip, redis1Port);
String redis2Ip = getResourceBundle().getString("redis2.ip");
int redis2Port = Integer.valueOf(bundle.getString("redis.port"));
JedisShardInfo jedisShardInfo2 = new JedisShardInfo(redis2Ip, redis2Port);
List<JedisShardInfo> serverlist = new LinkedList<JedisShardInfo>();
serverlist.add(jedisShardInfo1);
serverlist.add(jedisShardInfo2);
// 初始化連接池
shardPool = new ShardedJedisPool(getPoolConfig(),serverlist);
}
}讀寫刪除操作
// 從池中獲取壹個Jedis對象
Jedis jedis = sentinelpool.getSentinelpoolResource();
String keys = "name";
// 刪除key-value對象,如果key不存在則忽略此操作
jedis.del(keys);
// 存數據
jedis.set(keys, "snowolf");
// 判斷key是否存在,不存在返回false存在返回true
jedis.exists(keys);
// 取數據
String value = jedis.get(keys);
// 釋放對象池(3.0將拋棄該方法)
sentinelpool.returnSentinelpoolResource(jedis);三、示例代碼
1. String的簡單追加
// 從池中獲取壹個Jedis對象
JedisUtil.getInstance().STRINGS.append(key, value);2. 價格時間排序(前提是已經存儲了價格,時間的SortSet)
//執行2級排序操作()
String stPriceSet = “stPriceSet”;//stPriceSet價格的sortset列表名
String stTimeSet = “stTimeSet”; // stTimeSet時間的sortset列表名
Set<Tuple> sumSet = JedisUtilEx.getInstance()
.getSortSetByPirceUpAndTimeDown(stPriceSet, stTimeSet);
//排序以後可以重復獲取上次排序結果(緩存時間10分鐘)
Set<Tuple> sumSet = JedisUtilEx.getInstance()
getLastPirceUpAndTimeDownSet();3. 價格時間排序(前提是已經存儲了價格,時間的SortSet)
//執行2級排序操作
String stPriceSet = “stPriceSet”;//stPriceSet價格的sortset列表名
String stTimeSet = “stTimeSet”; // stTimeSet時間的sortset列表名
Set<Tuple> sumSet = JedisUtilEx.getInstance()
. getSortSetByPirceDownAndTimeDown (stPriceSet, stTimeSet);
//排序以後可以重復獲取上次排序結果(緩存時間10分鐘)
Set<Tuple> sumSet = JedisUtilEx.getInstance()
getLastPirceDownAndTimeDownSet ();4. 保存JavaBean到hash表中
// bean繼承至RedisBean
JedisUtilEx.getInstance().setBeanToHash(bean);5. 從hash表中讀取JavaBean
//uuid為業務制定的唯壹標識符規則(相當於主鍵)
String uuid = “1”; //該ID是我們提前就知道的
//T繼承至RedisBean;
JedisUtilEx.getInstance().getBeanFromHash (uuid,Class<T> cls);6. 將JavaBean列表裝入hash中
//list中的bean繼承至RedisBean
List<T> beanList = ?;
JedisUtilEx.getInstance().setBeanListToHash(beanList);
//異步版本的存儲列表到hash
JedisUtilEx.getInstance().setBeanListToHashSyn(beanList);7. 普通的操作流程示例
//獲取jedis引用
Jedis jedis = JedisUtil.getInstance().getJedis();
//執行業務以及調用jedis提供的接口功能
jedis.hset(?);
//執行完成以後務必釋放資源
JedisUtil.getInstance().returnJedis(jedis);
//若以後不會使用JEDIS,需要關閉所有鏈接池
RedisConnetcion.destroyAllPools();8. 事務執行流程
//獲取連接資源
Jedis jd = JedisUtil.getInstance().getJedis();
//開啟事務
Transaction ts = jd.multi();
//執行業務以及調用jedis提供的接口功能
jedis.hset(?);
//執行事務
List<Object> list = ts.exec();
//釋放資源
JedisUtil.getInstance().returnJedis(jd);9. 異步執行
//獲取連接資源
Jedis jedis = JedisUtil.getInstance().getJedis();
//獲取管道
Pipeline pipeline = jedis.pipelined();
//執行業務以及調用jedis提供的接口功能
jedis.hset(?);
//提交並釋放管道
pipeline.syncAndReturnAll();
//釋放資源
JedisUtil.getInstance().returnJedis(jedis);10. 如何獲取Jedis命名規則的合成KEY
//獲取類的唯壹鍵值key,例如:User:1(User為class,1為uuid)其中user繼承於Reidsbean
JedisUtilEx.getInstance().getBeanKey(user);
//另壹種獲取類的唯壹鍵值key的方法
JedisUtilEx.getInstance().getBeanKey(String uuid,Class<T> cls);
//獲取bean對應的KEY(對應列的唯壹鍵值key)
JedisUtilEx.getInstance().getBeanKey(String uuid,Class<T> cls,String... fileds);
//獲取bean對應的KEY(集群key)
JedisUtilEx.getInstance().getBeanKey(Class<T> cls,String... fileds);四、jedis操作命令:
1.對value操作的命令
exists(key):確認壹個key是否存在
del(key):刪除壹個key
type(key):返回值的類型
keys(pattern):返回滿足給定pattern的所有key
randomkey:隨機返回key空間的壹個key
rename(oldname, newname):將key由oldname重命名為newname,若newname存在則刪除newname表示的key
dbsize:返回當前數據庫中key的數目
expire:設定壹個key的活動時間(s)
ttl:獲得壹個key的活動時間
select(index):按索引查詢
move(key, dbindex):將當前數據庫中的key轉移到有dbindex索引的數據庫
flushdb:刪除當前選擇數據庫中的所有key
flushall:刪除所有數據庫中的所有key2.對String操作的命令
set(key, value):給數據庫中名稱為key的string賦予值value
get(key):返回數據庫中名稱為key的string的value
getset(key, value):給名稱為key的string賦予上壹次的value
mget(key1, key2,?, key N):返回庫中多個string(它們的名稱為key1,key2?)的value
setnx(key, value):如果不存在名稱為key的string,則向庫中添加string,名稱為key,值為value
setex(key, time, value):向庫中添加string(名稱為key,值為value)同時,設定過期時間time
mset(key1, value1, key2, value2,?key N, value N):同時給多個string賦值,名稱為key i的string賦值value i
msetnx(key1, value1, key2, value2,?key N, value N):如果所有名稱為key i的string都不存在,則向庫中添加string,名稱key i賦值為value i
incr(key):名稱為key的string增1操作
incrby(key, integer):名稱為key的string增加integer
decr(key):名稱為key的string減1操作
decrby(key, integer):名稱為key的string減少integer
append(key, value):名稱為key的string的值附加value
substr(key, start, end):返回名稱為key的string的value的子串3.對List操作的命令
rpush(key, value):在名稱為key的list尾添加壹個值為value的元素
lpush(key, value):在名稱為key的list頭添加壹個值為value的 元素
llen(key):返回名稱為key的list的長度
lrange(key, start, end):返回名稱為key的list中start至end之間的元素(下標從0開始,下同)
ltrim(key, start, end):截取名稱為key的list,保留start至end之間的元素
lindex(key, index):返回名稱為key的list中index位置的元素
lset(key, index, value):給名稱為key的list中index位置的元素賦值為value
lrem(key, count, value):刪除count個名稱為key的list中值為value的元素。count為0,刪除所有值為value的元素,count>0 從頭至尾刪除count個值為val