Redis【4】Java Jedis 操作 Redis~
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);
}
}}
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;/**
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"));
描述: 操作数据库
【时间 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.linsert("l2", LIST_POSITION.BEFORE, "3", "a3"); jedis.linsert("l2", LIST_POSITION.AFTER, "4", "a4");jedis.setex(</span>"k3", 10, "v3");<span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">10为过期时间 单位秒</span> System.out.println(jedis.get("k3"<span style="color: rgba(0, 0, 0, 1)">)); System.out.println(jedis.ttl(</span>"k3"));<span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">返回还有多少秒到期,到期自动删除,-2已过期</span> jedis.setnx("k4", "v4");<span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">不存在k4才能设值成功</span> System.out.println(jedis.get("k4"<span style="color: rgba(0, 0, 0, 1)">)); jedis.flushAll(); jedis.mset(</span>"k1","v11","k2","v22"<span style="color: rgba(0, 0, 0, 1)">); System.out.println(jedis.mget(</span>"k1","k2"<span style="color: rgba(0, 0, 0, 1)">)); System.out.println(jedis.keys(</span>"*"<span style="color: rgba(0, 0, 0, 1)">)); jedis.set(</span>"k5", "v5"<span style="color: rgba(0, 0, 0, 1)">); jedis.del(</span>"k5"<span style="color: rgba(0, 0, 0, 1)">); jedis.msetnx(</span>"k4","v44","k5","v55");<span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">全部不存在才能成功</span> System.out.println(jedis.mget("k4","k5"<span style="color: rgba(0, 0, 0, 1)">)); System.out.println(jedis.getSet(</span>"k1", "19951101"));<span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">先返回设值前内容再设值 </span><span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">-------------------List--------------------</span> jedis.lpush("l1", "1","2","3","4","5"<span style="color: rgba(0, 0, 0, 1)">); jedis.rpush(</span>"l2", "11","22","33","44","55"<span style="color: rgba(0, 0, 0, 1)">); System.out.println(jedis.lrange(</span>"l1", 0, -1));<span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">0 -1 查询全部</span> System.out.println(jedis.lrange("l2", 0, -1<span style="color: rgba(0, 0, 0, 1)">)); System.out.println(jedis.lpop(</span>"l1"));<span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">删除表头、返回删除的内容</span> System.out.println(jedis.lpop("l2"<span style="color: rgba(0, 0, 0, 1)">)); System.out.println(jedis.rpop(</span>"l1"));<span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">删除表尾、返回删除的内容</span> System.out.println(jedis.rpop("l2"<span style="color: rgba(0, 0, 0, 1)">)); System.out.println(jedis.lindex(</span>"l1", 1));<span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">返回下标1的内容</span> System.out.println(jedis.llen("l1"));<span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">相当于list.size()</span> jedis.ltrim("l1", 2, 3);<span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">截取2-3 包括2和3替换之前的内容</span> System.out.println(jedis.lrem("l1", 1, "33"));;<span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">第一个为key 第二个为1 第三个为要删除的value 返回删除的条数</span> jedis.rpoplpush("l1", "l2");<span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">把l1的尾添加到l2的头</span> jedis.lset("l2", 0, "333");<span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">把下标为0的值 改为333</span>
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.lrange(</span>"l1", 0, -1<span style="color: rgba(0, 0, 0, 1)">)); System.out.println(jedis.lrange(</span>"l2", 0, -1<span style="color: rgba(0, 0, 0, 1)">)); </span><span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">-------------------Set--------------------</span> jedis.sadd("s1", "1","2","3","4","5"<span style="color: rgba(0, 0, 0, 1)">); System.out.println(jedis.sismember(</span>"s1", "6"));<span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">s1中是否存在6 存在true 不存在false</span> System.out.println(jedis.scard("s1"));<span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">相当于list.size()</span> System.out.println(jedis.srem("s1", "5"));<span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">删除s1中的5 成功返回1 失败返回0</span> System.out.println(jedis.srandmember("s1"));<span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">随机出一条记录</span> System.out.println(jedis.srandmember("s1",3));<span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">随机出三条记录</span> System.out.println(jedis.srandmember("s1",9));<span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">如果大于等于记录数 就等于查询全部</span> System.out.println(jedis.spop("s1"));<span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">随机删除一条数据</span> System.out.println(jedis.smove("s1", "s2", "3"));<span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">把s1中的3移到s2的头</span>
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.hincrBy(</span>"stu", "id", 2));<span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">每次增加2 返回增加后的数值</span> System.out.println(jedis.hincrByFloat("stu", "id", 3.4));<span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">每次增加3.4 返回增加后的数值</span>
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 的 scoreSystem.out.println(jedis.zrangeByScore(</span>"zs1", 60, 90));<span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">60<=score<=90的value值</span>
</span><span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">zre表示把原本的数据逆转顺序之后,再读取,不改变原有数据</span> System.out.println(jedis.zrevrank("zs1", "v4"<span style="color: rgba(0, 0, 0, 1)">)); System.out.println(jedis.zrevrange(</span>"zs1", 0, -1<span style="color: rgba(0, 0, 0, 1)">)); }
}