您好,登錄后才能下訂單哦!
這篇文章將為大家詳細講解有關redis有哪些api,小編覺得挺實用的,因此分享給大家做個參考,希望大家閱讀完這篇文章后可以有所收獲。
一、Redis Client介紹
1.1、簡介
Jedis Client是Redis官網推薦的一個面向java客戶端,庫文件實現了對各類API進行封裝調用。
Jedis源碼工程地址:https://github.com/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:刪除所有數據庫中的所有key
2.對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個值為value的元素,count<0從尾到頭刪除|count|個值為value的元素。 lpop(key):返回并刪除名稱為key的list中的首元素 rpop(key):返回并刪除名稱為key的list中的尾元素 blpop(key1, key2,… key N, timeout):lpop 命令的block版本。即當timeout為0時,若遇到名稱為key i的list不存在或該list為空,則命令結束。如果 timeout>0,則遇到上述情況時,等待timeout秒,如果問題沒有解決,則對key i+1開始的list執行pop操作。 brpop(key1, key2,… key N, timeout):rpop的block版本。參考上一命令。 rpoplpush(srckey, dstkey):返回并刪除名稱為srckey的list的尾元素,并將該元素添加到名稱為dstkey的list的頭部
4.對Set操作的命令
sadd(key, member):向名稱為key的set中添加元素member srem(key, member) :刪除名稱為key的set中的元素member spop(key) :隨機返回并刪除名稱為key的set中一個元素 smove(srckey, dstkey, member) :將member元素從名稱為srckey的集合移到名稱為dstkey的集合 scard(key) :返回名稱為key的set的基數 sismember(key, member) :測試member是否是名稱為key的set的元素 sinter(key1, key2,…key N) :求交集 sinterstore(dstkey, key1, key2,…key N) :求交集并將交集保存到dstkey的集合 sunion(key1, key2,…key N) :求并集 sunionstore(dstkey, key1, key2,…key N) :求并集并將并集保存到dstkey的集合 sdiff(key1, key2,…key N) :求差集 sdiffstore(dstkey, key1, key2,…key N) :求差集并將差集保存到dstkey的集合 smembers(key) :返回名稱為key的set的所有元素 srandmember(key) :隨機返回名稱為key的set的一個元素
5.對zset(sorted set)操作的命令
zadd(key, score, member):向名稱為key的zset中添加元素member,score用于排序。如果該元素已經存在,則根據score更新該元素的順序。 zrem(key, member) :刪除名稱為key的zset中的元素member zincrby(key, increment, member) :如果在名稱為key的zset中已經存在元素member,則該元素的score增加increment;否則向集合中添加該元素,其score的值為increment zrank(key, member) :返回名稱為key的zset(元素已按score從小到大排序)中member元素的rank(即index,從0開始),若沒有member元素,返回“nil” zrevrank(key, member) :返回名稱為key的zset(元素已按score從大到小排序)中member元素的rank(即index,從0開始),若沒有member元素,返回“nil” zrange(key, start, end):返回名稱為key的zset(元素已按score從小到大排序)中的index從start到end的所有元素 zrevrange(key, start, end):返回名稱為key的zset(元素已按score從大到小排序)中的index從start到end的所有元素 zrangebyscore(key, min, max):返回名稱為key的zset中score >= min且score <= max的所有元素 zcard(key):返回名稱為key的zset的基數 zscore(key, element):返回名稱為key的zset中元素element的score zremrangebyrank(key, min, max):刪除名稱為key的zset中rank >= min且rank <= max的所有元素 zremrangebyscore(key, min, max) :刪除名稱為key的zset中score >= min且score <= max的所有元素 zunionstore / zinterstore(dstkeyN, key1,…,keyN, WEIGHTS w1,…wN, AGGREGATE SUM|MIN|MAX):對N個zset求并集和交集,并將最后的集合保存在dstkeyN中。對于集合中每一個元素的score,在進行AGGREGATE運算前,都要乘以對于的WEIGHT參數。如果沒有提供WEIGHT,默認為1。默認的AGGREGATE是SUM,即結果集合中元素的score是所有集合對應元素進行 SUM運算的值,而MIN和MAX是指,結果集合中元素的score是所有集合對應元素中最小值和最大值。
6.對Hash操作的命令
hset(key, field, value):向名稱為key的hash中添加元素field<—>value hget(key, field):返回名稱為key的hash中field對應的value hmget(key, field1, …,field N):返回名稱為key的hash中field i對應的value hmset(key, field1, value1,…,field N, value N):向名稱為key的hash中添加元素field i<—>value i hincrby(key, field, integer):將名稱為key的hash中field的value增加integer hexists(key, field):名稱為key的hash中是否存在鍵為field的域 hdel(key, field):刪除名稱為key的hash中鍵為field的域 hlen(key):返回名稱為key的hash中元素個數 hkeys(key):返回名稱為key的hash中所有鍵 hvals(key):返回名稱為key的hash中所有鍵對應的value hgetall(key):返回名稱為key的hash中所有的鍵(field)及其對應的value
五、Redis命名規則
由于Redis所有數據為鍵值對,即所有數據均只能通過鍵值(Key)來進行管理,故需
要規范命名規則,jedis客戶端包裝了有專門的命名規則生產函數,調用即可!
關于redis有哪些api就分享到這里了,希望以上內容可以對大家有一定的幫助,可以學到更多知識。如果覺得文章不錯,可以把它分享出去讓更多的人看到。
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。