Redis：6.SpringBoot集成Redis

2020-04-08 阅读量

1.SpringBoot整合

SpringBoot操作数据：使用SpringData（SpringData包含：jpa、jdbc、mongodb、redis等）
SpringData是和SpringBoot齐名的项目。

说明：在SpringBoot2.x之后，原来使用的Jedis被替换为了lettuce。

Jedis：底层采用的是直连，若有多个线程操作的话，是不安全的。（若想避免不安全，使用jedis pool连接池）更像BIO模式。
lettuce：底层采用netty，实例可以在多个线程中共享，不存在线程不安全的情况。可以减少线程数量（不需要开连接池了）。更像NIO模式。

1.源码分析

SpringBoot所有的配置类，都有一个自动配置类 XXXAutoConfiguration。
自动配置类都会绑定一个properties 配置文件，RedisProperties。
RedisAutoConfiguration源码分析：

public class RedisAutoConfiguration {
    
    public RedisAutoConfiguration() {
    }

    // @ConditionalOnMissingBean 即redisTemplate方法不存在，才会生效。所以我们可以自己定义
    // redisTemplate来替换这个默认的。
    @Bean
    @ConditionalOnMissingBean(name = "redisTemplate")
    public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) throws UnknownHostException {
        // 默认的RedisTemplate 没有过多的设置。（而redis对象是需要序列化的，所以只能手动序列化）
        // RedisTemplate两个泛型都是Object类型，所以使用时要注意强制转换。
        RedisTemplate<Object, Object> template = new RedisTemplate();
        template.setConnectionFactory(redisConnectionFactory);
        return template;
    }

    // 由于String类型 是redis最长使用的类型，所以这里单独提出来了一个bean
    @Bean
    @ConditionalOnMissingBean
    public StringRedisTemplate stringRedisTemplate(RedisConnectionFactory redisConnectionFactory) throws UnknownHostException {
        StringRedisTemplate template = new StringRedisTemplate();
        template.setConnectionFactory(redisConnectionFactory);
        return template;
    }
}

2.整合测试

1.创建springboot项目的时候，在noSql里把Redis勾选上。
或者导入依赖

<!--Redis-->
<dependency>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

2.在配置文件中进行配置（配置内容到 RedisProperties 类里面）

# 默认就是localhost 所以在本地用，这个可以不写
spring.redis.host=127.0.0.1
# 默认就是6379 所以这个可以不写
spring.redis.port=6379

3.编写测试程序

// 1.注入Redis模板类
@Autowired
private RedisTemplate redisTemplate;

@Test
void contextLoads() {

    // opsForValue：操作字符串，类似于String
    // opsForList： 操作List类型
    // opsForSet：  操作Set类型
    // opsForHash： 操作Hash类型
    // opsForZSet： 操作ZSet类型
    // opsForGeo：  操作地图类型
    ValueOperations value = redisTemplate.opsForValue();
    // 这里就可以使用Redis里String的相关命令了
    value.set("name", "aaa");
    value.get("name");

    // 除了基本的操作，常用的方法可直接通过redisTemplate 来操作。
    // 比如事务和常用的增删改查
    redisTemplate.multi();
    redisTemplate.exec();

    // 获取连接对象（一般很少去用）
    RedisConnection connection = redisTemplate.getConnectionFactory().getConnection();
    connection.flushDb();
    connection.flushAll();
}


关于：// opsForValue：操作字符串，类似于String
     // opsForList： 操作List类型
     // opsForSet：  操作Set类型
     // opsForHash： 操作Hash类型
     // opsForZSet： 操作ZSet类型
     // opsForGeo：  操作地图类型
在实际开发中，并不会直接使用这些方式。
而是把这些方法封装成一个RedisUtils工具类。方便自己调用。
假设已经得到了这个工具类。那么使用工具类如下：
    
@Autowired
private RedisUtils redisUtils;

@Test
public void test(){
   redisUtils.set("name", "zhangsan"); 
   redisUtils.get("name");
}

3.自定义RedisTemplate

1.关于序列化

1.无序列化（直接存储对象会报错）

@Test
public void test0(){

    User user = new User("张三", 20);

    // 存数据 （报错：实体类未序列化）
    redisTemplate.opsForValue().set("user", user); 
    
    // 取数据
    User redUser = (User)redisTemplate.opsForValue().get("user");
    System.out.println(redUser);
}

2.序列化的两种方式（开发中，所有的实体类都会序列化）

方式一：实体类实现Serializable接口

  // 实体类实现Serializable接口 
  @Component
  @Data
  @AllArgsConstructor
  @NoArgsConstructor
  public class User implements Serializable{ 
      private String name;
      private Integer age;
  }
  
  
  // 调用
  还是调用前面的代码，程序正常执行。
  ```  


- 方式二：把实体类 单独序列化  
  ```java
  @Test
  public void test1() throws JsonProcessingException {
  
      User user = new User("张三", 20);
  
      // 开发一般使用json传递对象 (这里进行序列化)
      String jsonUser = new ObjectMapper().writeValueAsString(user);
  
      // 存数据
      redisTemplate.opsForValue().set("user", jsonUser);
      // 取数据
      User redUser = (User)redisTemplate.opsForValue().get("user");
  
      System.out.println(redUser);
  }

编写自己的RedisTemplate。

*系统默认的RedisTemplate 序列化方式为jdk序列化。我们需要编写自己的序列化RedisTemplate *

// 这是一个固定的模板，拿来就能用
@Configuration
public class RedisConfig {

    // 编写自己的RedisTemplate
    @Bean
    @SuppressWarnings("all")
    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) throws UnknownHostException {

        // 为了开发方便，一般用<String, Object>
        RedisTemplate<String, Object> template = new RedisTemplate<>();
        template.setConnectionFactory(factory);


        // Json 的序列化配置
        Jackson2JsonRedisSerializer<Object> objectJson = new Jackson2JsonRedisSerializer(Object.class);
        ObjectMapper om = new ObjectMapper();// 用来对序列化进行转义
        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
        objectJson.setObjectMapper(om);

        // String 的序列化
        StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();

        // key 采用String的序列化方式
        template.setKeySerializer(stringRedisSerializer);

        // hash 的key 也采用String的序列化方式
        template.setHashKeySerializer(stringRedisSerializer);

        // value序列化方式采用jackson
        template.setValueSerializer(objectJson);

        // hash 的value序列化方式采用jackson
        template.setHashValueSerializer(objectJson);

        // 把所有的配置 set进去
        template.afterPropertiesSet();

        return template;
    }
}

测试：

// 这里确保导入自己定义的RedisTemplate
@Autowired
@Qualifier("redisTemplate")
private RedisTemplate redisTemplate;

@Test
public void test0(){

    User user = new User("张三", 20);

    // 存数据
    redisTemplate.opsForValue().set("user", user);
    // 取数据
    User redUser = (User)redisTemplate.opsForValue().get("user");

    System.out.println(redUser);
}