【Redis快取機制】12.Java連線Redis_Jedis_常用API
阿新 • • 發佈:2019-01-05
上一篇總結我們使用我們本地的Eclipse中建立的jedis工程,連結
到了我們處於VMware虛擬機器上的Linux系統上的Redis服務,我們接下來
講一下jedis的一些常用的API。
(1)jedis儲存字串
檢視一下redis:
說明我們的操作是成功的。
(2)jedis操作Map
檢視一下redis:
說明我們的操作是成功的。
(3)jedis操作List
檢視以下redis:
說明我們的操作是成功的。
(4)jedis操作Set
檢視以下redis:
說明我們的操作是成功的。
(5)jedis排序
檢視以下redis:
(6)Redis連線池
我們每一次使用redis的時候,都要寫Jedis jedis = new Jedis("192.168.248.129",6379);
我們要優化連線,不能使用一次就new一個連線物件,我們要建立一個工具類,管理redis的
連線和一些配置引數的設定。
測試:
結果:
使用連線池獲取jedis物件會更符合開發規範。
到了我們處於VMware虛擬機器上的Linux系統上的Redis服務,我們接下來
講一下jedis的一些常用的API。
(1)jedis儲存字串
效果:package cn.com.redis; import redis.clients.jedis.Jedis; public class Test1 { public static void main(String[] args) { Jedis jedis = new Jedis("192.168.248.129",6379); //新增資料 jedis.set("username", "jack");//向key-->name中放入了value-->jack System.out.println(jedis.get("username"));//執行結果:jack jedis.append("username"," is a Coder");//拼接 System.out.println(jedis.get("username")); jedis.del("username");//刪除某個鍵 System.out.println(jedis.get("username"));//為null //設定多個鍵值對 jedis.mset("username","liuling","age","23","qq","412345678"); jedis.incr("age");//進行加1操作 System.out.println(jedis.get("name")+"-"+jedis.get("age")+"-"+jedis.get("qq")); } }
檢視一下redis:
說明我們的操作是成功的。
(2)jedis操作Map
效果:package cn.com.redis; import java.util.HashMap; import java.util.Iterator; import java.util.List; import java.util.Map; import redis.clients.jedis.Jedis; public class Test2 { public static void main(String[] args) { Jedis jedis = new Jedis("192.168.248.129",6379); //新增資料 Map<String,String> map = new HashMap<String,String>(); map.put("name", "ZhangSan"); map.put("age", "35"); map.put("email", "
[email protected]"); jedis.hmset("user",map); //第一個引數是存入redis中map物件的key,後面跟的是放入map中的物件的key, //後面的key可以跟多個,是可變引數 List<String> rsmap = jedis.hmget("user", "name","age","email"); System.out.println(rsmap); //刪除map中的某個值 jedis.hdel("user","age"); System.out.println(jedis.hmget("user", "age"));//因為刪除了,所以返回的是null System.out.println(jedis.hlen("user"));//返回key為user的鍵中存放值的個數2 System.out.println(jedis.exists("user"));//是否存在key為user的記錄,返回true System.out.println(jedis.hkeys("user"));//返回map物件中的所有key System.out.println(jedis.hvals("user"));//返回map物件中的所有val Iterator<String> iter=jedis.hkeys("user").iterator();//得到iterator物件進行遍歷 while(iter.hasNext()){ String key = iter.next(); System.out.println(key+":"+jedis.hmget("user", key)); } } }
檢視一下redis:
說明我們的操作是成功的。
(3)jedis操作List
package cn.com.redis;
import redis.clients.jedis.Jedis;
public class Test3 {
public static void main(String[] args) {
Jedis jedis = new Jedis("192.168.248.129",6379);
//開始前,先移出所有的內容
jedis.del("java framework");
System.out.println(jedis.lrange("java framework", 0, -1));
//先向key java framework中存放三條資料
//lpush key string 在key對應list的頭部新增字串元素
jedis.lpush("java framework","spring");
jedis.lpush("java framework","struts");
jedis.lpush("java framework","hibernate");
//取出所有資料,jedis.lrange是按範圍取出,
//第一個是key,第二個是起始位置,第三個是結束位置,-1表示取得所有
System.out.println(jedis.lrange("java framework", 0, -1));
//jedis.llen獲取長度
System.out.println(jedis.llen("java framework"));
//刪除資料
jedis.del("java framework");
//rpush key string 在key對應list的尾部新增字串元素
//插入資料的時候如果List不存在,就建立它再插入
jedis.rpush("java framework", "spring");
jedis.rpush("java framework", "struts");
jedis.rpush("java framework", "hibernate");
System.out.println(jedis.lrange("java framework", 0, -1));
}
}
效果:檢視以下redis:
說明我們的操作是成功的。
(4)jedis操作Set
package cn.com.redis;
import redis.clients.jedis.Jedis;
public class Test4 {
public static void main(String[] args) {
Jedis jedis = new Jedis("192.168.248.129",6379);
//新增
jedis.sadd("users", "ZhangSan");
jedis.sadd("users", "LiSi");
jedis.sadd("users", "WangWu");
jedis.sadd("users", "ZhangEr");
jedis.sadd("users", "MaLiu");
//移出MaLiu
jedis.srem("users", "MaLiu");
System.out.println(jedis.smembers("users"));//獲取所有加入的value
System.out.println(jedis.sismember("users", "MaLiu"));//判斷MaLiu是否是user結合的元素
System.out.println(jedis.srandmember("users"));
System.out.println(jedis.scard("users"));//返回集合的元素個數
}
}
效果:檢視以下redis:
說明我們的操作是成功的。
(5)jedis排序
package cn.com.redis;
import redis.clients.jedis.Jedis;
public class Test5 {
public static void main(String[] args) {
Jedis jedis = new Jedis("192.168.248.129",6379);
//jedis排序
//注意,此處的rpush和lpush是List的操作,是一個雙向連結串列
//rpush是從尾部加入資料,lpush是從頭部加入資料
jedis.del("a");//先清楚資料,再加入資料進行測試
jedis.rpush("a", "1");
jedis.rpush("a", "6");
jedis.rpush("a", "3");
jedis.rpush("a", "9");
System.out.println(jedis.lrange("a", 0, -1));//[1,6,3,9]
System.out.println(jedis.sort("a"));//[1,3,6,9] 輸出排序後結果
jedis.del("a");//先清楚資料,再加入資料進行測試
jedis.lpush("a", "1");
jedis.lpush("a", "6");
jedis.lpush("a", "3");
jedis.lpush("a", "9");
System.out.println(jedis.lrange("a", 0, -1));//[9,3,6,1]
System.out.println(jedis.sort("a"));//[1,3,6,9] 輸出排序後結果
}
}
效果:檢視以下redis:
(6)Redis連線池
我們每一次使用redis的時候,都要寫Jedis jedis = new Jedis("192.168.248.129",6379);
我們要優化連線,不能使用一次就new一個連線物件,我們要建立一個工具類,管理redis的
連線和一些配置引數的設定。
package cn.com.redis;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
public class RedisUtil {
//redis伺服器IP
private static String ADDR = "192.168.248.129";
//redis的埠號
private static int PORT = 6379;
//訪問密碼
private static String AUTH = "root";
//可用連線例項的最大數目,預設為8
//如果賦值為-1,則表示不限制;如果pool已經分配了maxActive個jedis例項,則此
//時pool的狀態為exhausted(耗盡)。
private static int MAX_ACTIVE = 1024;
//控制一個pool最多有多少個狀態為idle(空閒)的jedis例項,預設也是8
private static int MAX_IDLE = 200;
//等待可用連線的最大時間,單位毫秒,預設值為-1,表示永不超時。
//如果超過等待時間,則直接丟擲JedisConnectionException
private static int MAX_WAIT = 10000;
private static int TIMEOUT = 10000;
//在borrow一個redis例項時,是否提前進行validate操作;
//如果為true,則得到的jedis例項均是可用的
private static boolean TEST_ON_BORROW = true;
private static JedisPool jedisPool = null;
/**
* 初始化Redis連線池
* Jedis的連線池配置需要用到org.apache.commons.pool.impl.GenericObjectPool.Config.class
* 所以要引入commons-pool.jar
* */
static{
try {
JedisPoolConfig config = new JedisPoolConfig();
config.setMaxTotal(MAX_ACTIVE);//老版本是setMaxActive
config.setMaxIdle(MAX_IDLE);
config.setMaxWaitMillis(MAX_WAIT);//老版本是maxMaxWait
config.setTestOnBorrow(TEST_ON_BORROW);
jedisPool = new JedisPool(config,ADDR,PORT,TIMEOUT);//有密碼的時候傳入AUTH
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 獲取Jedis例項
* */
public synchronized static Jedis getJedis(){
try {
if(jedisPool != null){
Jedis resource = jedisPool.getResource();
return resource;
}else{
return null;
}
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
/**
* 釋放jedis資源
* */
public static void returnResource(final Jedis jedis){
if(jedis != null){
jedisPool.returnResourceObject(jedis);
}
}
}
不要忘記引入commons-pool.jar:測試:
package cn.com.redis;
import redis.clients.jedis.Jedis;
public class Test6 {
public static void main(String[] args) {
RedisUtil redisUtil = new RedisUtil();
Jedis jedis = redisUtil.getJedis();
try {
System.out.println(jedis.lrange("a", 0, -1));
System.out.println(jedis.smembers("users"));
} catch (Exception e) {
e.printStackTrace();
}finally{
redisUtil.returnResource(jedis);
}
}
}
結果:
使用連線池獲取jedis物件會更符合開發規範。