Redis客户端jedis

普通类

/**
 * 基础测试类
 */
public class JedisTest {

    public static void main(String[] args) {
        Jedis jedis = new Jedis("192.168.1.9",6379);
        jedis.auth("machao");
/*        jedis.set("jedis","hello");
        System.out.println(jedis.get("jedis"));

        String key = "jedis";
        System.out.println(jedis.exists(key));
        jedis.expire(key,200);
        try{
            Thread.sleep(1000);
        }catch (Exception e){

        }
        System.out.println(jedis.ttl(key));

        jedis.setnx("jedis11","hell011");
        System.out.println(jedis.get("jedis11"));

        //键值命令
        Set set = jedis .keys("*");
        System.out.println(set);*/

        //非字符串
//        jedis.lpush("list6","guanyu","zhangfei","zhaoyun","machao","huagnzhogn");
//        List list = jedis.lrange("list6",0,-1);
//        System.out.println(list);

        //排序
        SortingParams params = new SortingParams();
        System.out.println(jedis.sort("list6",params.alpha()));
        jedis.close();
    }
}

管道测试类

/**
 * 管道测试类
 */
public class JedisPipeTest {

    public static void main(String[] args) {
        Jedis jedis = new Jedis("192.168.1.9",6379);
        jedis.auth("machao");

        String key = "pipe1";

        jedis.set(key,"10");
        //使用管道
        Pipeline pipeline = jedis.pipelined();
        for (int i=0;i<10;i++){
            pipeline.incr(key);
        }
        pipeline.sync();
        System.out.println(jedis.get(key));

        jedis.close();

    }
}

事务类

/**
 * 事务测试类
 */

public class JedisTransTest {
    public static void main(String[] args) {
        Jedis jedis = new Jedis("192.168.1.9",6379);
        jedis.auth("machao");

        jedis.set("xiaoyanzi","8888");
        jedis.set("xiaomaque","6666");

        jedis.watch("xiaoyanzi");
        jedis.watch("xiaomaque");

        if(Integer.parseInt(jedis.get("xiaoyanzi"))>=2222){
            Transaction transaction = jedis.multi();
            transaction.decrBy("xiaoyanzi",2222);
            transaction.incrBy("xiaomaque",2222);
            transaction.exec();
        }
//        transaction.discard();
        //验证结果
        List list = jedis.mget("xiaoyanzi","xiaomaque");
        System.out.println(list);
        jedis.close();

    }
}

线程池类

public class JedisPoolTest {
    public static void main(String[] args) {

        JedisPoolConfig config = new JedisPoolConfig();
        config.setMaxTotal(10);

        JedisPool pool = new JedisPool(config,"192.168.1.9",6379,"machao","machao");
        Jedis jedis = null;

        try{
            System.out.println(1111);
            jedis = pool.getResource();
            System.out.println(222);
            jedis.set("pool","hello");
            System.out.println(jedis.get("pool"));
        }catch (Exception e){

        }finally {
            if(jedis != null){
                jedis.close();
            }
        }
        pool.close();
    }
}