Redis-Jedis

环境准备

创建一个maven项目

导入redis依赖

<!-- https://mvnrepository.com/artifact/redis.clients/jedis -->
<dependency>
  <groupId>redis.clients</groupId>
  <artifactId>jedis</artifactId>
  <version>3.1.0</version>
</dependency>

启动redis

测试联通

使用jedis.ping()：

/**
 * 测试联通
 */
public static void main(String[] args) {
    Jedis jedis = new Jedis("127.0.0.1", 6379);
    System.out.println(jedis.ping());
}

结果：

测试联通

常用API

key（键）

public static void main(String[] args) {
    Jedis jedis = new Jedis("127.0.0.1", 6379);
    jedis.set("k1", "v1");
    jedis.set("k2", "v2");
    jedis.set("k3", "v3");
    System.out.println(jedis.get("k2"));
    Set<String> keys = jedis.keys("*");
    System.out.println(keys.size());
}

String（字符串）

Hash（哈希）

List（列表）

Set（集合）

Zset（sorted set：有序集合）

事务

正常执行

jedis.multi()

    public static void main(String[] args) {
        Jedis jedis = new Jedis("127.0.0.1", 6379);
        //开启事务
        Transaction transaction = jedis.multi();
        //入队
        transaction.set("k4", "v4");
        transaction.set("k5", "v5");
        //执行事务
        transaction.exec();
        //取消事务
//        transaction.discard();
    }

加锁（watch有问题）

public class TestSW {

    public boolean transMehtod(){
        Jedis jedis = new Jedis("127.0.0.1", 6379);
        int balance;//可用余额
        int debt;//欠额
        int amtToSubtract=10;//实刷额度

        jedis.watch("balance");
        balance = Integer.parseInt(jedis.get("balance"));
        if (balance < amtToSubtract) {
            jedis.unwatch();
            System.out.println("失败");
            return false;
        }else{
            System.out.println("*****************transaction");
            Transaction transaction = jedis.multi();
            transaction.decrBy("balance", amtToSubtract);
            transaction.incrBy("debt", amtToSubtract);
            transaction.exec();
            balance = Integer.parseInt(jedis.get("balance"));
            debt = Integer.parseInt(jedis.get("debt"));

            System.out.println("**********  :"+balance);
            System.out.println("**********  :" + debt);
            return true;
        }
    }

    /**
     * watch命令就是一个标记键，如果标记了一个键，在提交事务前如果键被别人修改过，那事务就会失败，
     * 这种情况通常可以在程序中重新尝试一次
     * 首先标记了键balance，然后检查余额是否足够，不足就取消标记，并不做扣减
     * 足够的话，就启动事务进行更新操作
     * 如果在此期间键banlace被其他人修改，那在提交事务（执行exec）时就会报错，
     * 程序中通常可以捕获这类错误再重新执行一次，直到成功
     */
    public static void main(String[] args) {
        TestSW testSW = new TestSW();
        boolean retValue = testSW.transMehtod();
        System.out.println("main retValue.......:"+retValue);
    }
}

正常执行

主从复制

public static void main(String[] args) {
    Jedis jedis_M = new Jedis("127.0.0.1", 6379);
    Jedis jedis_S = new Jedis("127.0.0.1", 6380);
    jedis_S.slaveof("127.0.0.1", 6379);
    jedis_M.set("class", "1122");
    String result = jedis_S.get("class");
    System.out.println(result);
}