redis学习02--使用Jedis调用Redis

1.Jedis连接Redis

1.1 在pom.xml文件中，引入maven依赖

<dependencies>
 <!--1、Jedis依赖包-->
 <!-- https://mvnrepository.com/artifact/redis.clients/jedis -->
 <dependency>
   <groupId>redis.clients</groupId>
   <artifactId>jedis</artifactId>
   <version>2.9.0</version>
 </dependency>
 <!--2、Junit测试-->
 <dependency>
   <groupId>junit</groupId>
   <artifactId>junit</artifactId>
   <version>4.13</version>
 </dependency>
 <!--3、Lombok依赖包-->
 <dependency>
   <groupId>org.projectlombok</groupId>
   <artifactId>lombok</artifactId>
   <version>1.18.12</version>
 </dependency>
</dependencies>

1.2 测试连接Redis

public class Demo1 {
   @Test
   public void set(){
       //1、连接Redis
       Jedis jedis = new Jedis("127.0.0.1",6379);
       //2、操作Redis - redis的命令是什么jedis对应的方法就是什么
       jedis.set("name","zhangsan");
       //3、释放资源
       jedis.close();
  }
   @Test
   public void get(){
       //1、连接Redis
       Jedis jedis = new Jedis("127.0.0.1",6379);
       //2、操作Redis - redis的命令是什么jedis对应的方法就是什么
       String value = jedis.get("name");
       System.out.println(value);
       //3、释放资源
       jedis.close();
  }
}

2.存储一个对象到Redis

2.1 准备一个User类

@Data
@AllArgsConstructor
@NoArgsConstructor
public class User implements Serializable {
   private Long id;
   private String name;
   private Date birthday;
}

导入spring-context依赖

<!--4、导入spring-context-->
<dependency>
   <groupId>org.springframework</groupId>
   <artifactId>spring-context</artifactId>
   <version>4.3.20.RELEASE</version>
</dependency>

2.2 创建demo测试类

public class Demo2 {
   //存储对象 -- 以byte[]形式存储在redis中
   @Test
   public void setByteArray(){
       //1、连接redis服务
       Jedis jedis = new Jedis("127.0.0.1",6379);
       //2.1 准备key(String) - value(User)
       String key = "user";
       User user = new User(1L,"张三",new Date());
       //2.2 将key和value转换为byte[]
       byte[] byteKey = SerializationUtils.serialize(key);
       //user对象序列化和反序列化，需要在User类实现Serializable接口
       byte[] byteValue = SerializationUtils.serialize(user);
       //2.3 将key和value存储到redis
       jedis.set(byteKey,byteValue);
       //3、释放资源
       jedis.close();
  }
   @Test
   public void getByteArray(){
       //1、连接redis服务
       Jedis jedis = new Jedis("127.0.0.1",6379);
       //2.1 准备key(String)
       String key = "user";
       //2.2 将key转换为byte[]
       byte[] byteKey = SerializationUtils.serialize(key);
       //2.3 获取value
       byte[] byteValue = jedis.get(byteKey);
       //2.4 将value反序列化为user对象
       User user2 = (User)SerializationUtils.deserialize(byteValue);
       System.out.println(user2);
       //3、释放资源
       jedis.close();
  }
}

2.3 Jedis如何存储一个对象到Redis，以String的形式存储

导入fastjson依赖

<!--5、导入fastjson-->
<dependency>
   <groupId>com.alibaba</groupId>
   <artifactId>fastjson</artifactId>
   <version>1.2.71</version>
</dependency>

public class Demo3 {
   //存储的对象，以String形式
   @Test
   public void setString(){
       //1、连接redis
       Jedis jedis = new Jedis("127.0.0.1",6379);
       //2.1 准备key(String) - value(User)
       String stringKey = "stringUser";
       User value = new User(2L,"李四",new Date());
       //2.2 使用fastjson将value格式化为json字符串
       String stringVlue = JSON.toJSONString(value);
       //2.3 存储到redis中
       jedis.set(stringKey,stringVlue);
       //3关闭连接
       jedis.close();
  }
   @Test
   public void getString(){
       //1、连接redis
       Jedis jedis = new Jedis("127.0.0.1",6379);
       //2.1 准备key
       String stringKey = "stringUser";
       //2.2 去redis中查询value
       String stringValue =jedis.get(stringKey);
       //2.3 将value反序列化为User
       User user = JSON.parseObject(stringValue,User.class);
       System.out.println(user);
       //3关闭连接
       jedis.close();
  }
}

2.4 Jedis连接池操作

@Test
public void pool2(){
   //1、创建连接池的配置信息
   GenericObjectPoolConfig config = new GenericObjectPoolConfig();
   //连接池中最大的活跃数
   config.setMaxTotal(100);
   //最大空闲数
   config.setMaxIdle(10);
   //最大空闲数
   config.setMinIdle(5);
   //当连接池空了之后，多久没获取到jedis对象就超时，单位毫秒
   config.setMaxWaitMillis(3000);
   //2、创建连接池
   JedisPool pool = new JedisPool(config,"127.0.0.1",6379);
   //3、获取jedis
   Jedis jedis = pool.getResource();
   //4、操作
   String value = jedis.get("stringUser");
   System.out.println(value);
   //6、释放连接
   jedis.close();
}

2.5 Redis管道操作

//Redis的管道操作
@Test
public void pipeline(){
   //1、创建连接
   JedisPool pool = new JedisPool("127.0.0.1",6379);
   long start = System.currentTimeMillis();
   //2、获取一个连接对象
   Jedis jedis = pool.getResource();
//       //3、执行incr - 10000次
//       for (int i = 0; i < 50000; i++) {
//           jedis.incr("pp");
//       }
//       //4、释放资源
//       jedis.close();
   //------------------

   //3、创建管道
   Pipeline pipeline = jedis.pipelined();
   //4、执行incr - 10000次放到管道中
   for (int i = 0; i < 50000; i++) {
       pipeline.incr("qq");
  }
   pipeline.syncAndReturnAll();
   //5、释放资源
   jedis.close();
   long end = System.currentTimeMillis();
   System.out.println(end-start);
}