[大数据]SpringBoot整合Redis，Jedis

依赖引入

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

依赖解析

在SpringBoot2.×之后，原来使用的jedis 被替换为了lettuce。

• jedis：采用的直连，多个线程操作的话，是不安全的，如果想要避免不安全的，使用jedis pool连接池，更像BIO模式
• lettuce：采用netty，实例可以再多个线程中进行共享，不存在线程不安全的情况，更像NIO模式。（如下从redis依赖点进去可以看到netty）

?

核心类

SpringBoot自动装配会加载spring-boot-autoconfigure下的配置类，并把配置类中被@Bean对应的对象实例化并注入IOC容器（具体位置见下方gif）
注意事项：
接口里的RedisTemplate<Object, Object>第一个Object使用时需要强转，很多时候我们不会使用默认的方法，而是自己定义一个

@Configuration(proxyBeanMethods = false)
@ConditionalOnClass(RedisOperations.class)
@EnableConfigurationProperties(RedisProperties.class)//每个配置类都会对应一个配置文件，可以点开查看这个组件可以在配置文件中配置那些属性
@Import({ LettuceConnectionConfiguration.class, JedisConnectionConfiguration.class })
public class RedisAutoConfiguration {

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

	@Bean
	@ConditionalOnMissingBean // String类型是最常用的，所以单独建了一个
	@ConditionalOnSingleCandidate(RedisConnectionFactory.class)
	public StringRedisTemplate stringRedisTemplate(RedisConnectionFactory redisConnectionFactory) {
		StringRedisTemplate template = new StringRedisTemplate();
		template.setConnectionFactory(redisConnectionFactory);
		return template;
	}

}

整合测试

/**
 * redisTemplate 操作不同的数据类型，api和我们的指令是一样的
 * opsForXXX 对应着Redis的5种基本类型和3中特殊类型
 *
 * 除了以上的，一些常用的命令（方法）可以直接使用redisTemplate调用，比如事务，增删改查等
 * 公司里一般封装方法
 */
@SpringBootTest
class Redis02SpringbootApplicationTests {

    @Autowired
    private RedisTemplate redisTemplate;

    @Test
    void contextLoads() {

//        RedisConnection connection = redisTemplate.getConnectionFactory().getConnection();
//        connection.multi();
//        connection.exec();
//        connection.flushAll();
//        connection.flushDb();

        redisTemplate.opsForValue().set("user","evader");
        System.out.println(redisTemplate.opsForValue().get("user"));
    }

}

RedisTemplate序列化测试

Redis中不存储Java中的对象，一般操作是将对象转json，这个过程需要对象是可序列化的。

User类没有实现序列化接口

User类实现序列化接口

Jedis

依赖引入

<dependency>
  <groupId>redis.clients</groupId>
  <artifactId>jedis</artifactId>
  <version>3.2.0</version>
</dependency>
<dependency>
  <groupId>com.alibaba</groupId>
  <artifactId>fastjson</artifactId>
  <version>1.2.68</version>
</dependency>

连接测试

连接上即可使用，具体可以创建Jedis对象，然后调用相关方法，会发现方法名其实就是Redis的命令

public class TestPing {
    public static void main(String[] args) {
        Jedis jedis = new Jedis("127.0.0.1", 6379);
        System.out.println(jedis.ping());
    }
}