基于内存的分布式NoSQL数据库Redis(四)Jedis：使用方式

//todo:1-构建客户端连接对象
Connection conn = DriverManager.getConnect(url,username,password)
//todo:2-执行操作：所有操作都在客户端连接对象中：方法
prep.execute(SQL)
//todo:3-释放连接
conn.close

//todo:1-构建连接对象
    Jedis jedis = null;
    @Before
    public void getConnection(){
        //方式一：直接构建Jedis对象
//        jedis = new Jedis("node1",6379);
        //方式二：通过连接池构建Jedis
        //构建连接池配置对象
        JedisPoolConfig config = new JedisPoolConfig();
        config.setMaxTotal(10);//总连接构建
        config.setMaxIdle(5);//最大空闲连接
        config.setMinIdle(2);//最小空闲连接
        //构建连接池对象
        JedisPool jedisPool = new JedisPool(config,"node1",6379);
        //获取连接
        jedis = jedisPool.getResource();
    }
    //todo:2-调用连接对象的方法实现操作
    //todo:3-释放连接
    @After
    public void closeConnection(){
        jedis.close();
    }

set/get/incr/exists/expire/setexp/ttl

@Test
    public void testString(){
        //set/get/incr/exists/expire/setexp/ttl
//        jedis.set("s1","hadoop");
//        System.out.println(jedis.exists("s1"));
//        System.out.println(jedis.exists("s2"));
//        System.out.println(jedis.get("s1"));
//        jedis.set("s2","3");
//        jedis.incr("s2");
//        System.out.println(jedis.get("s2"));
//        jedis.expire("s2",10);
//        while(true){
//            System.out.println(jedis.ttl("s2"));
//        }
        //setex：构建KV时，直接设置生命周期
        jedis.setex("s3",10,"oozie");
    }

hset/hmset/hget/hgetall/hdel/hlen/hexists

public void testHash(){
        //hset/hmset/hget/hgetall/hdel/hlen/hexists
        jedis.hset("m1","name","zhangsan");
        System.out.println(jedis.hget("m1","name"));
        Map<String,String> maps = new HashMap<>();
        maps.put("age","18");
        maps.put("phone","110");
        jedis.hmset("m1",maps);
        List<String> hmget = jedis.hmget("m1", "name", "age");
        System.out.println(hmget);
        System.out.println("=");
        Map<String, String> m1 = jedis.hgetAll("m1");
        for(Map.Entry map : m1.entrySet()){
            System.out.println(map.getKey()+"\t"+map.getValue());
        }
        System.out.println("=");
        System.out.println(jedis.hlen("m1"));
        jedis.hdel("m1","name");
        System.out.println(jedis.hlen("m1"));
        System.out.println(jedis.hexists("m1","name"));
        System.out.println(jedis.hexists("m1","age"));
    }

lpush/rpush/lrange/llen/lpop/rpop

@Test
    public void testList(){
        //lpush/rpush/lrange/llen/lpop/rpop
        jedis.lpush("list1","1","2","3");
        System.out.println(jedis.lrange("list1",0,-1));
        jedis.rpush("list1","4","5","6");
        System.out.println(jedis.lrange("list1",0,-1));
        System.out.println(jedis.llen("list1"));
        jedis.lpop("list1");
        jedis.rpop("list1");
        System.out.println(jedis.lrange("list1",0,-1));
    }

sadd/smembers/sismember/scard/srem

@Test
    public void testSet(){
        //sadd/smembers/sismember/scard/srem
        jedis.sadd("set1","1","2","3","1","2","3","4","5","6");
        System.out.println("长度："+jedis.scard("set1"));
        System.out.println("内容："+jedis.smembers("set1"));
        System.out.println(jedis.sismember("set1","1"));
        System.out.println(jedis.sismember("set1","7"));
        jedis.srem("set1","2");
        System.out.println("内容："+jedis.smembers("set1"));
    }

zadd/zrange/zrevrange/zcard/zrem

@Test
    public void testZset(){
        //zadd/zrange/zrevrange/zcard/zrem
        jedis.zadd("zset1",20.9,"yuwen");
        jedis.zadd("zset1",10.5,"yinyu");
        jedis.zadd("zset1",70.9,"shuxue");
        jedis.zadd("zset1",99.9,"shengwu");
        Set<String> zset1 = jedis.zrange("zset1", 0, -1);
        System.out.println(zset1);
        System.out.println(jedis.zrevrange("zset1",0,-1));
        System.out.println(jedis.zcard("zset1"));
        jedis.zrem("zset1","yuwen");
        System.out.println(jedis.zrangeWithScores("zset1",0,-1));
    }