Redis【4】Java Jedis 操作 Redis~
程序员文章站
2022-07-03 18:44:22
package redis.redis; import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisPool; /** * 描述:Jedis连接池工具类 * 【时间 2019-05-20 15:13:34 作者 陶攀峰】 */ ......
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; /** * 描述:操作数据库 * 【时间 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)); } }
上一篇: 日常监控邮件预警(视图无效测试分析)
下一篇: 清理监听日志处理的方法