Springboot整合Redis

在Springboot2.x之后，原来使用的Jedis被替换为lettuce!

jedis 底层采用直连，多线程操作是不安全的，如果要避免不安全，要使用Jedis pool连接池

lettuce 采用netty,实例可以在多个线程中进行共享，在不存在线程安全问题的情况下，可以减少线程数据

源码分析

@Bean
@ConditionalOnMissingBean( //可以自定义RedisTemplate来替换默认的
    name = {"redisTemplate"}
)
public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) throws UnknownHostException {
    //默认的RedisTemplate没有过多的设置，redis对象都输需要序列化
    //两个泛型都是Object，需要强转<String,Object>
    RedisTemplate<Object, Object> template = new RedisTemplate();
    template.setConnectionFactory(redisConnectionFactory);
    return template;
}

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

简单使用

@SpringBootTest
class Redis01ApplicationTests {

    @Autowired
    private RedisTemplate redisTemplate;

    @Test
    void contextLoads() {
        redisTemplate.opsForValue();//操作字符串
        redisTemplate.opsForList();//操作List
        redisTemplate.opsForSet();//操作Set
        redisTemplate.opsForHash();
        redisTemplate.opsForZSet();
        redisTemplate.opsForGeo();
        redisTemplate.opsForHyperLogLog();

        //除了基本的操作，我们常用的方法都可以直接通过redisTemplate操作，比如事务和基本的CRUD


        //获取连接对象
        RedisConnection connection = redisTemplate.getConnectionFactory().getConnection();
        connection.flushDb();
        connection.flushAll();
    }
}

默认采用JDK序列化，我们可能采用Json序列化

自定义redisTemplate

传递的对象需要序列化，否则会传递失败，报错

可以采用Json序列化，或者实现Serializable接口序列化

在企业中，一般所有的POJO类都会序列化

@Configuration
public class RedisConfig {

    //编写自己的redisTemplate
    @Bean
    public RedisTemplate<String,Object> redisTemplate(RedisConnectionFactory redisConnectionFactory)
        throws UnknownHostException {
        RedisTemplate<String,Object> template = new RedisTemplate<>();

        //配置具体的序列化方式,Json序列化
        Jackson2JsonRedisSerializer<Object> objectJackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<Object>();
        template.setConnectionFactory(redisConnectionFactory);
        return template;
    }
}