Spring Boot 揭秘与实战（二） 数据存储篇 - Redis

时间：2023-03-09 03:01:35
Spring Boot 揭秘与实战（二） 数据存储篇 - Redis

本文讲解Spring Boot基础下，如何整合Redis，编写数据访问。

环境依赖

修改 POM 文件，添加 spring-boot-starter-redis 依赖。

  1. <dependency>
  2. <groupId>org.springframework.boot</groupId>
  3. <artifactId>spring-boot-starter-redis</artifactId>
  4. </dependency>

数据源

方案一 使用 Spring Boot 默认配置

在 src/main/resources/application.properties 中配置数据源信息。

  1. spring.redis.host=localhost
  2. spring.redis.port=6379
  3. spring.redis.password=
  4. spring.redis.database=1
  5. spring.redis.pool.max-active=8
  6. spring.redis.pool.max-wait=-1
  7. spring.redis.pool.max-idle=500
  8. spring.redis.pool.min-idle=0
  9. spring.redis.timeout=0

方案二 手动创建

在 src/main/resources/config/redis.properties 中配置数据源信息。

  1. # redis
  2. redis.host=localhost
  3. redis.port=6379
  4. redis.password=
  5. redis.database=1

通过 Java Config 创建redisTemplate。

  1. @Configuration
  2. @PropertySource("classpath:config/redis.properties")
  3. public class RedisConfig {
  4. @Autowired
  5. private Environment env;
  6. @Bean
  7. public RedisConnectionFactory redisConnectionFactory() {
  8. JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
  9. JedisConnectionFactory jedisConnectionFactory = new JedisConnectionFactory();
  10. jedisConnectionFactory.setHostName(env.getProperty("redis.host").trim());
  11. jedisConnectionFactory.setPort(Integer.parseInt(env.getProperty("redis.port").trim()));
  12. jedisConnectionFactory.setPassword(env.getProperty("redis.password").trim());
  13. jedisConnectionFactory.setDatabase(Integer.parseInt(env.getProperty("redis.database").trim()));
  14. jedisConnectionFactory.setUsePool(true);
  15. jedisConnectionFactory.setPoolConfig(jedisPoolConfig);
  16. return jedisConnectionFactory;
  17. }
  18. @Bean
  19. public RedisTemplate<String, String> redisTemplate() {
  20. RedisTemplate<String, String> redisTemplate = new StringRedisTemplate();
  21. redisTemplate.setConnectionFactory(redisConnectionFactory());
  22. redisTemplate.afterPropertiesSet();
  23. return redisTemplate;
  24. }
  25. }

使用 redisTemplate 操作

工具类

  1. @Repository
  2. public class RedisBaseDao {
  3. @Resource(name="redisTemplate")
  4. protected ValueOperations<String, String> valueOperations;
  5. public void addValue(String key, String value){
  6. valueOperations.set(key, value);
  7. }
  8. public String getValue(String key){
  9. return valueOperations.get(key);
  10. }
  11. }

测试类

  1. @Repository
  2. public class ValueRedisDao {
  3. @Autowired
  4. public RedisBaseDao redisBaseDao;
  5. private String getKey(){
  6. return "param";
  7. }
  8. public void save(String param){
  9. this.redisBaseDao.addValue(this.getKey(), param);
  10. }
  11. public String getParam(){
  12. return this.redisBaseDao.getValue(this.getKey());
  13. }
  14. }

单元测试用例

编写单元测试用例，测试Redis是否正常工作。

  1. @RunWith(SpringJUnit4ClassRunner.class)
  2. @SpringApplicationConfiguration(WebMain.class)
  3. public class RedisTest {
  4. @Autowired
  5. private ValueRedisDao valueRedisDao;
  6. @Test
  7. public void test() throws Exception {
  8. this.valueRedisDao.save("LiangGzone");
  9. System.out.println(this.valueRedisDao.getParam());
  10. }
  11. }

总结

上面这个简单的案例，让我们看到了 Spring Boot 整合 Redis 的整个流程。实际上，与 Spring 4 中 通过 Spring Data Redis 整合 Redis 并无二意， Spring Boot 默认集成了一些配置信息，但是个人更加偏向于方案二的手动创建方式，为什么呢，因为更方便扩展。

源代码

相关示例完整代码： springboot-action

(完)

如果觉得我的文章对你有帮助，请随意打赏。

Spring Boot 揭秘与实战（二） 数据存储篇 - Redis

相关文章