Redis【4】Java Jedis 操作 Redis~
阿新 • • 發佈：2019-05-28
package redis.redis;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
/**
* 描述:Jedis連線池工具類
* 【時間 2019-05-20 15:13:34 作者 陶攀峰】
*/
public class JedisPoolUtil
{
private static volatile JedisPool jedisPool=null;
private JedisPoolUtil() {}
/**
* 描述:獲取
* 【時間 2019-05-21 11:02:24 作者 陶攀峰】
*/
public static JedisPool getJeidPoolInstance()
{
if (jedisPool==null)
{
synchronized (JedisPoolUtil.class)
{
if (jedisPool==null)
{
jedisPool=new JedisPool("192.168.37.160",6379);
}
}
}
return jedisPool;
}
/**
* 描述:關閉
* 【時間 2019-05-21 11:02:13 作者 陶攀峰】
*/
public static void close(JedisPool jedisPool,Jedis jedis)
{
if (jedis!=null)
{
jedisPool.returnResourceObject(jedis);
}
}
}
描述:Jedis連線池工具類package redis.redis;
import redis.clients.jedis.BinaryClient.LIST_POSITION;
import java.util.HashMap;
import java.util.Map;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.Transaction;
/**
* 描述:操作資料庫
* 【時間 2019-05-20 15:28:46 作者 陶攀峰】
*/
public class Redis_Test {
public static void main(String[] args) {
JedisPool jedisPool=JedisPoolUtil.getJeidPoolInstance();
Jedis jedis=null;
try {
jedis=jedisPool.getResource();//獲取
System.out.println("連線:"+jedis.ping());//測試連線性 正常返回PONG
transaction(jedis);//事務
basics(jedis);//基礎操作
} catch (Exception e) {
e.printStackTrace();
}finally {//關閉
JedisPoolUtil.close(jedisPool, jedis);
}
}
/**
* 描述:Redis事務
* 【時間 2019-05-20 15:33:59 作者 陶攀峰】
*/
public static void transaction(Jedis jedis){
int k3=10;
jedis.watch("k1");
//Thread.sleep(7000);
if (Integer.parseInt(jedis.get("k1"))<k3) {
jedis.unwatch();
System.out.println("---modify---");
}else {
Transaction transaction=jedis.multi();
transaction.decrBy("k1", k3);
transaction.incrBy("k2", k3);
transaction.exec();
System.out.println("---"+jedis.get("k1")+"---"+jedis.get("k2"));
}
}
/**
* 描述:Redis基礎
* 【時間 2019-05-21 08:07:33 作者 陶攀峰】
*/
public static void basics(Jedis jedis) {
jedis.set("k1", "v1");
jedis.set("k2", "v2");
System.out.println("當前資料庫記錄："+jedis.dbSize());
System.out.println("jedis.keys(\"*\"):"+jedis.keys("*"));//獲取所有key
jedis.select(1);//切換資料庫 下標從0開始 到 15 ，共16個數據庫
System.out.println(jedis.keys("*"));
System.out.println(jedis.dbSize());//當前庫的資料大小 key的數量
System.out.println(jedis.randomKey());//隨機出一個key
jedis.flushDB();//清空當前資料庫
jedis.flushAll();//清空全部資料庫
//-------------------String--------------------
jedis.set("k1", "v1");
System.out.println(jedis.get("k1"));
jedis.del("k1");
jedis.append("k1", "556677");//追加
System.out.println(jedis.get("k1"));
System.out.println(jedis.strlen("k1"));//得到長度
jedis.set("k2", "2");
jedis.incr("k2");//增加1
jedis.decr("k2");//減少1
jedis.incrBy("k2", 5);//增加5
jedis.decrBy("k2", 20);//減少20
System.out.println(jedis.get("k2"));
jedis.flushAll();//清空全部資料庫
jedis.set("k3", "tpf951101");
System.out.println(jedis.getrange("k3", 2, 3));//從0開始包括2和3
System.out.println(jedis.setrange("k3", 2, "pf"));//從下標2開始 包括2 開始替換兩個字元pf
System.out.println(jedis.get("k3"));
jedis.setex("k3", 10, "v3");//10為過期時間 單位秒
System.out.println(jedis.get("k3"));
System.out.println(jedis.ttl("k3"));//返回還有多少秒到期，到期自動刪除，-2已過期
jedis.setnx("k4", "v4");//不存在k4才能設值成功
System.out.println(jedis.get("k4"));
jedis.flushAll();
jedis.mset("k1","v11","k2","v22");
System.out.println(jedis.mget("k1","k2"));
System.out.println(jedis.keys("*"));
jedis.set("k5", "v5");
jedis.del("k5");
jedis.msetnx("k4","v44","k5","v55");//全部不存在才能成功
System.out.println(jedis.mget("k4","k5"));
System.out.println(jedis.getSet("k1", "19951101"));//先返回設值前內容再設值
//-------------------List--------------------
jedis.lpush("l1", "1","2","3","4","5");
jedis.rpush("l2", "11","22","33","44","55");
System.out.println(jedis.lrange("l1", 0, -1));//0 -1 查詢全部
System.out.println(jedis.lrange("l2", 0, -1));
System.out.println(jedis.lpop("l1"));//刪除表頭、返回刪除的內容
System.out.println(jedis.lpop("l2"));
System.out.println(jedis.rpop("l1"));//刪除表尾、返回刪除的內容
System.out.println(jedis.rpop("l2"));
System.out.println(jedis.lindex("l1", 1));//返回下標1的內容
System.out.println(jedis.llen("l1"));//相當於list.size()
jedis.ltrim("l1", 2, 3);//擷取2-3 包括2和3替換之前的內容
System.out.println(jedis.lrem("l1", 1, "33"));;//第一個為key 第二個為1 第三個為要刪除的value 返回刪除的條數
jedis.rpoplpush("l1", "l2");//把l1的尾新增到l2的頭
jedis.lset("l2", 0, "333");//把下標為0的值 改為333
jedis.linsert("l2", LIST_POSITION.BEFORE, "3", "a3");
jedis.linsert("l2", LIST_POSITION.AFTER, "4", "a4");
System.out.println(jedis.lrange("l1", 0, -1));
System.out.println(jedis.lrange("l2", 0, -1));
//-------------------Set--------------------
jedis.sadd("s1", "1","2","3","4","5");
System.out.println(jedis.sismember("s1", "6"));//s1中是否存在6 存在true 不存在false
System.out.println(jedis.scard("s1"));//相當於list.size()
System.out.println(jedis.srem("s1", "5"));//刪除s1中的5 成功返回1 失敗返回0
System.out.println(jedis.srandmember("s1"));//隨機出一條記錄
System.out.println(jedis.srandmember("s1",3));//隨機出三條記錄
System.out.println(jedis.srandmember("s1",9));//如果大於等於記錄數 就等於查詢全部
System.out.println(jedis.spop("s1"));//隨機刪除一條資料
System.out.println(jedis.smove("s1", "s2", "3"));//把s1中的3移到s2的頭
System.out.println(jedis.sdiff("s1","s2"));//s1有 s2沒有
System.out.println(jedis.sinter("s1","s2"));//s1 s2 都有
System.out.println(jedis.sunion("s1","s2"));//s1 s2合集
System.out.println(jedis.smembers("s1"));
//-------------------Hash--------------------
jedis.hset("stu", "id", "7");
System.out.println(jedis.hget("stu", "id"));
Map<String, String> map=new HashMap<>();
map.put("id","13");
map.put("name", "daniu");
map.put("sex", "nan");
jedis.hmset("stu", map);
System.out.println(jedis.hmget("stu", "id","name","sex"));
System.out.println(jedis.hgetAll("stu"));
System.out.println(jedis.hdel("stu", "id","sex2"));//返回刪除的數量
System.out.println(jedis.hlen("stu"));
System.out.println(jedis.hexists("stu", "name"));//存在true 不存在false
System.out.println(jedis.hkeys("stu"));
System.out.println(jedis.hvals("stu"));
System.out.println(jedis.hincrBy("stu", "id", 2));//每次增加2 返回增加後的數值
System.out.println(jedis.hincrByFloat("stu", "id", 3.4));//每次增加3.4 返回增加後的數值
System.out.println(jedis.hsetnx("stu", "id1", "99"));//插入成功返回1 失敗返回0
//-------------------Zset--------------------
jedis.zadd("zs1", 60, "v1");
jedis.zadd("zs1", 70, "v2");
jedis.zadd("zs1", 80, "v3");
jedis.zadd("zs1", 90, "v4");
jedis.zadd("zs1", 100, "v5");
System.out.println(jedis.zrange("zs1", 0, -1));
System.out.println(jedis.zrangeByScore("zs1", 60, 90));//60<=score<=90的value值
System.out.println(jedis.zrem("zs1", "v5","v6"));//返回刪除記錄數
System.out.println(jedis.zcard("zs1"));//返回數量
System.out.println(jedis.zcount("zs1", 60, 80));//60<=score<=80的數量
System.out.println(jedis.zrank("zs1", "v4"));//返回所在位置下標
System.out.println(jedis.zscore("zs1", "v1"));//返回v1的score
//zre表示把原本的資料逆轉順序之後，再讀取，不改變原有資料
System.out.println(jedis.zrevrank("zs1", "v4"));
System.out.println(jedis.zrevrange("zs1", 0, -1));
}
}
描