1. 连接redis

默认有三种方式连接redis.

第一种:jedis—传统的项目–ssm

第二种:lettuce:---->刚出现没有多久就被springboot整合进来。

第三种:springboot连接redis

1.1 jedis操作redis服务器

（1）引入jedis依赖

    redis.clients
    jedis
    4.3.1

（2）编写相关的代码

    @Test
    public void test01(){
//        Jedis(String host, int port)
        Jedis jedis = new Jedis("192.168.80.128",6379);
//        该类包含很多对redis操作的方法，这些方法和原来我们使用的命令一样
        Set keys = jedis.keys("*");
        System.out.println(keys);
//        对string数据类型操作
        jedis.set("k1", "坤");
        String k1 = jedis.get("k1");
        System.out.println("k1: " + k1);
        jedis.setex("k2",16,"有很多");
        String k2 = jedis.get("k2");
        System.out.println("k2: " + k2);
//        对hash数据类型操作
        Map map = new HashMap<>();
        map.put("name","座右铭");
        map.put("age","18");
        map.put("hobby","优惠点");
        jedis.hset("k3",map);
        Map k3 = jedis.hgetAll("k3");
        System.out.println(k3);
//        对list类型数据操作
        jedis.lpush("k4","座右铭","优惠点","老油条","屏幕膜","万美元");
        List k4 = jedis.lrange("k4", 0, -1);
        System.out.println(k4);
        jedis.close();
    }

每次使用jedis对象时 都需要自己创建，当使用完后，需要关闭该对象。===>jedis中也存在连接池.

1.2 jedis连接池的使用

    @Test
    public void testPool(){
        //连接池的配置信息
        JedisPoolConfig config=new JedisPoolConfig();
        config.setMaxTotal(10);//最多的连接个数
        config.setMaxIdle(10); //最多空闲的连接个数
        config.setMinIdle(2); //最小的空闲个数
        config.setTestOnBorrow(true);//在获取连接对象时是否验证该连接对象的连通性
        //创建连接池对象
        JedisPool jedisPool=new JedisPool(config,"192.168.80.128",6379);
        Jedis jedis = jedisPool.getResource();
        //清空当前库
        jedis.flushDB();
        String set = jedis.set("k1", "v1");
        String k1 = jedis.get("k1");
        System.out.println(k1);
        jedis.close();//归还连接池
    }

1.3 测试jedis使用和不使用连接池的效率

 @Test
    public void test03(){
        //连接池的配置信息
        JedisPoolConfig config=new JedisPoolConfig();
        config.setMaxTotal(100);//最多的连接个数
        config.setMaxIdle(10); //最多空闲的连接个数
        config.setMinIdle(2); //最小的空闲个数
        config.setTestOnBorrow(true);//在获取连接对象时是否验证该连接对象的连通性
        //创建连接池对象
        JedisPool jedisPool=new JedisPool(config,"192.168.80.128",6379);
        long start = System.currentTimeMillis();
        for(int i=0;i<10000;i++){
            Jedis jedis = jedisPool.getResource();
            String ping = jedis.ping();
            jedis.close();
        }
        long end = System.currentTimeMillis();
        System.out.println("耗时:"+(end-start));
    }
    @Test
    public void test02(){
        long start = System.currentTimeMillis();
        //Jedis(String host, int port)
        for(int i=0;i<10000;i++){
            Jedis jedis=new Jedis("192.168.80.128",6379);
            String ping = jedis.ping();
            jedis.close();
        }
        long end = System.currentTimeMillis();
        System.out.println("耗时:"+(end-start));
    }

1.4 springboot整合redis

springboot在整合redis时提高两个模板类,StringRedisTemplate和RedisTemplate.以后对redis的操作都在该模板类中。StringRedisTemplate是RedisTemplate的子类。

  org.springframework.boot
  spring-boot-starter-data-redis


  org.apache.commons
  commons-pool2

修改配置文件

#redis的配置信息
spring.data.redis.host=192.168.80.128
spring.data.redis.port=6379
#最多获取数
spring.data.redis.lettuce.pool.max-active=8
spring.data.redis.lettuce.pool.max-wait=-1ms
spring.data.redis.lettuce.pool.max-idle=8
spring.data.redis.lettuce.pool.min-idle=0

测试:

package com.zym;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.core.*;
import java.util.*;
@SpringBootTest
class SpringbootRedisApplicationTests {
    //因为springboot整合redis时会把StringRedisTemplate创建并交于spring容器管理
    @Autowired
    private StringRedisTemplate redisTemplate;
    @Test
    void contextLoads() {
        //关于key的操作
        System.out.println(redisTemplate.keys("*"));//获取所有的key
        //是否存在指定的key
        Boolean k1 = redisTemplate.hasKey("k1");
        System.out.println("是否存在指定的key:" + k1);
        //    删除指定的key
        Boolean k11 = redisTemplate.delete("k1");
        System.out.println("删除是否成功：" + k11);
    }
    @Test
    void test1() {
        //操作字符串===StringRedisTemplate会把对每一种数据的操作单独封装成一个类。
        //ValueOperations专门操作字符串
        ValueOperations forValue = redisTemplate.opsForValue();
        //set 向指定key中设置value
        forValue.set("k1", "你好");
        //get 获取指定key的值
        String k12 = forValue.get("k1");
        System.out.println("k12==" + k12);
        //mset 同时设置一个或多个 key-value 对
        Map map = new HashMap<>();
        map.put("k1", "座右铭");
        map.put("k2", "有很多");
        map.put("k3", "另一条");
        map.put("k4", "屏幕膜");
        forValue.multiSet(map);
        //mget 获取所有(一个或多个)给定 key 的值
        List list = new ArrayList<>();
        list.add("k1");
        list.add("k2");
        list.add("k3");
        list.add("k4");
        List stringList = forValue.multiGet(list);
        System.out.println(stringList);
        //setnx
        Boolean aBoolean = forValue.setIfAbsent("k2", "你也好");
        System.out.println("是否存入成功：" + aBoolean);
        //incr decr
        Long k3 = forValue.increment("k3", 20);
        System.out.println("k3:" + k3);
        Long decrement = forValue.decrement("k3", 20);
        System.out.println("k3:" + decrement);
    }
    @Test
    void test2() {
        //可以hash操作
        //hset
        HashOperations forHash = redisTemplate.opsForHash();
        forHash.put("k1", "name", "平家祥");
        forHash.put("k1", "age", "16");
        forHash.put("k1", "sex", "男");
        Map map = new HashMap<>();
        map.put("name", "胡萌");
        map.put("age", "17");
        map.put("sex", "女");
        forHash.putAll("k2", map);
        //hget
        System.out.println(forHash.get("k1", "name"));
        //hgetall
        Map k1 = forHash.entries("k1");
        System.out.println(k1);
        //hkeys
        Set