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);
      }
      }

}

描述: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(</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>
jedis.linsert("l2", LIST_POSITION.BEFORE, "3", "a3"); jedis.linsert("l2", LIST_POSITION.AFTER, "4", "a4");
    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.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(</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.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(</span>"zs1", 60, 90));<span style="color: rgba(0, 128, 0, 1)">//</span><span style="color: rgba(0, 128, 0, 1)">60&lt;=score&lt;=90的value值</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 的 score
    </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)">));
}

}

描述: 操作数据库