深刻理解Redis系列之SpringBoot集成Redis

SpringBoot环境

快速搭建一个SpringBoot工程

进入 https://start.spring.io 网站, 使用该网站初始化一个SpringBoot工程

 

添加相关依赖

由于使用spring initializer已经帮咱们把Redis的依赖创建好了; 可是因为咱们要使用Jedis客户端访问Redis, 因此还须要添加Jedis的依赖;

<dependency>
 <groupId>redis.clients</groupId>
 <artifactId>jedis</artifactId>
 <version>2.9.0</version> //版本号能够放在properties中做为属性, 这边用${jedis.version}来依赖
 </dependency>

配置Redis节点信息

打开application.properties文件, 初始化的文件是空的; 咱们将spring redis最基本的信息加入进去

spring.redis.host=localhost
spring.redis.port=6379

将Redis信息读入到程序中

新建一个Java类命名为 StandaloneRedisConfig.java ， 放在 com.xxx.example.config 包下

package com.terrylmay.redis.example.config;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;
@Configuration
@ConfigurationProperties(prefix = "spring.redis")
@ConditionalOnProperty(name = {"spring.redis.host"})
public class StandaloneRedisConfig {
 String host;
 int port;
 public String getHost() {
 return host;
 }
 public void setHost(String host) {
 this.host = host;
 }
 public int getPort() {
 return port;
 }
 public void setPort(int port) {
 this.port = port;
 }
}

上面配置中的 @ConditionalOnProperty(name = {"spring.redis.host"}) 若是只是单机的Redis则不须要添加该属性; 可是为了后面一套代码兼容多个Redis部署模式, 使用该属性做为是否建立Bean的条件; 若是是集群模式那么就不会使用 spring.redis.host 来做为链接字符串了;

配置Jedis的链接池

将Redis链接对象放入到Spring容器中进行管理

package com.terrylmay.redis.example;
import com.terrylmay.redis.example.config.StandaloneRedisConfig;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;
import org.springframework.context.annotation.Bean;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.connection.RedisStandaloneConfiguration;
import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
import org.springframework.data.redis.core.StringRedisTemplate;
@SpringBootApplication(scanBasePackages = {"com.terrylmay.redis.example"})
public class RedisExampleApplication {
 public static void main(String[] args) {
 SpringApplication.run(RedisExampleApplication.class, args);
 }
 @Autowired
 StandaloneRedisConfig standaloneRedisConfig;
 @Autowired
 RedisConnectionFactory redisConnectionFactory;
 @Bean
 @ConditionalOnBean(value = {StandaloneRedisConfig.class})
 public RedisConnectionFactory standaloneRedisConnectionFactory() {
 JedisConnectionFactory factory = new JedisConnectionFactory(new RedisStandaloneConfiguration(standaloneRedisConfig.getHost(), standaloneRedisConfig.getPort()));
 return factory;
 }
 @Bean
 public StringRedisTemplate stringRedisTemplate() {
 return new StringRedisTemplate(redisConnectionFactory);
 }
}

这里的 @ConditionalOnBean(value = {StandaloneRedisConfig.class}) 与上面的 ConditionalOnProperty 是一个道理

这里的 scanBasePackages = {"com.terrylmay.redis.example"} 是为了之后将Redis的客户端独立出一个工程而作的, 固然独立出来的工程base包名还要是这个才能够;

由于尚未看Redis支持的数据结构, 那么如今只是把Redis字符串模板类放到Spring 容器中, 后续再增长其余数据类型的支持;

建立操做Redis的接口 以及实现

建立 ICacheProvider.java 接口:

package com.terrylmay.redis.example.provider;
public interface ICacheProvider {
 void setString(String key, String value);
 String getString(String key);
}

Jedis版本的实现：

package com.terrylmay.redis.example.provider.impl;
import com.terrylmay.redis.example.provider.ICacheProvider;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Component;
@Component
public class JedisCacheProvider implements ICacheProvider {
 @Autowired
 StringRedisTemplate stringRedisTemplate;
 @Override
 public void setString(String key, String value) {
 stringRedisTemplate.opsForValue().set(key, value);
 }
 @Override
 public String getString(String key) {
 return stringRedisTemplate.opsForValue().get(key);
 }
}

这样基本上一个能够操做Redis的Java程序就已经就绪了; 那么咱们须要验证一下, 固然若是在主工程中写一个类去验证也是没有问题的, 好比建立一个Bean, 而且放到被 PostContruct 注解的方法里面;

可是更加专业的作法是写一个测试程序来测试, 下面看一下该测试程序应该怎么写

UT测试程序可用性

由于建立工程的时候, 就已经有一个测试类在test目录下面了, 咱们增长咱们想要的功能

package com.terrylmay.redis.example;
import com.terrylmay.redis.example.provider.ICacheProvider;
import org.junit.Assert;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest(classes = {RedisExampleApplication.class})
public class RedisExampleApplicationTests {
 @Autowired
 ICacheProvider jedisCacheProvider;
 @Test
 public void contextLoads() {
 jedisCacheProvider.setString("name", "terrylmay");
 System.out.println(jedisCacheProvider.getString("name")); 
 Assert.assertEquals("terrylmay", jedisCacheProvider.getString("name"));
 }
}

注: 程序中不要有打印, 使用Logger或者直接断言来处理 （原本想用markdown语法来标红的, 可是发现简书居然不支持html的写法; 没办法只能用``来搞定了）

开发过程当中遇到的问题

1、在写好全部的程序以后, 跑测试用例, 可是始终都是报NoSuchBeanException

Caused by: org.springframework.beans.factory.NoSuchBeanDefinitionException:
No qualifying bean of type 'com.terrylmay.redis.example.config.StandaloneRedisConfig' available: expected at least 1 bean which qualifies as autowire candidate. 
Dependency annotations: {
@org.springframework.beans.factory.annotation.Autowired(required=true)}

缘由共有三点：

一、写了 scanBasepackages 来扫描包下面的bean, 扫描的包与类所在的包不同， 只有一个字符之差 com.terrylmay.redis.example 与 com.terrlmay.redis.example , 固然这时候 idea 会报错， 只是我不认识那个错而已; Idea报错如图所示:

 

二、按照网上的application.properties属性的读取方式, 只使用了一个注解:

@ConfigurationProperties(prefix = "spring.redis") 可是点进该注解里面看, 它其实并无Component注解的功能; 因此增长了 @Configuration 注解

三、第三个缘由不仔细断然不会发现这个错误

 

我理解的是只要工程里面父工程是 spring-boot-starter-parent , 那么就不该该存在这类Jar包没有依赖的问题, 打开文档

 

依赖可粘贴版:

<dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-configuration-processor</artifactId>
 <optional>true</optional>
</dependency>

到这里, 一个可以使用Redis的Java工程就已经就绪了