深入理解Spring Cloud与微服务构建(第2版)
上QQ阅读APP看书,第一时间看更新

4.6.3 在Spring Boot中使用Redis

新建一个Spring Boot工程,在工程的pom文件中加入Redis的起步依赖spring-boot- starter-data-redis,代码如下:

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

在工程的配置文件application.yml中加上Redis的数据源配置,例如host、port、数据库配置信息等。如果Redis设置了密码,需要提供密码,选择序号为1的数据库,配置Pool的相关配置。配置代码如下:

spring:
  redis:
    host: localhost
    port: 6379
    password: 
    database: 1
    pool:
      max-active: 8
      max-wait: -1
      max-idle: 500

数据操作层的RedisDao类通过@Repository注解来注入Spring IoC容器中,该类是通过RedisTemplate来访问Redis的。通过注入StringRedisTemplate的Bean来对Redis数据库中的字符串类型的数据进行操作,写了两个方法,包括向Redis中设置String类型的数据和从Redis中读取String类型的数据,代码如下:

@Repository
public class RedisDao {
   @Autowired
   private StringRedisTemplate template;
   public void setKey(String key,String value){
     ValueOperations<String, String> ops = template.opsForValue();
     ops.set(key,value,1, TimeUnit.MINUTES);//1分钟过期
   }
   public String getValue(String key){
      ValueOperations<String, String> ops = this.template.opsForValue();
      return ops.get(key);
   }
}

在SpringBootTest的测试类中注入RedisDao,首先通过RedisDao向Redis设置两组字符串值,即name为forezp,age为17的两组字符串,然后分别通过RedisDao从Redis中读取这两个值,并打印出来,代码如下:

@RunWith(SpringRunner.class)
@SpringBootTest
public class SpringbootRedisApplicationTests {
   @Test
   public void contextLoads() {
   }
   @Autowired
   RedisDao redisDao;
   @Test
   public void testRedis(){
      redisDao.setKey("name","forezp");
      redisDao.setKey("age","17");
      logger.info(redisDao.getValue("name"));
      logger.info(redisDao.getValue("age"));
   }
}

启动单元测试,控制台打印了forezp和17的两个字符串值。可见,通过RedisDao首先向Redis数据库中写入了两个数据,然后又读取了这两个数据。