Spring Boot 整合 Redis 步调详解

文章目录

• 1. 引言
  
• 2. 添加依靠
  
• 3. 配置 Redis 连接信息
  
• 4. 创建 Redis 操纵服务类
  
• 5. 使用 RedisTemplate 或 ReactiveRedisTemplate
  
• 6. 测试 Redis 功能
  
• 7. 注意事项
  
• 8. 总结
  

Redis 是一个高性能的键值存储系统，常用于缓存、消息队列等多种场景。将 Redis 与 Spring Boot 结合使用可以极大提升应用的性能和响应速率。本文将详细先容怎样在 Spring Boot 应用中整合 Redis，并通过示例代码展示具体实现步调。
1. 引言

随着互联网应用对快速读写数据的需求日益增长，传统的数据库已经难以满足某些特定场景下的性能要求。Redis 依附其内存级的数据访问速率、丰富的数据结构支持以及简朴易用的 API，成为了很多开发者的首选。接下来，我们将一步步先容怎样在 Spring Boot 中集成 Redis。
2. 添加依靠

首先，在 pom.xml 文件中添加 Spring Data Redis 和 Jedis（或 Lettuce）客户端的 Maven 依靠：

1. <dependencies>
2.         <dependency>
3.              <groupId>org.springframework.boot</groupId>
4.              <artifactId>spring-boot-starter-web</artifactId>
5.          </dependency>
6.        
7.          <dependency>
8.              <groupId>org.springframework.boot</groupId>
9.              <artifactId>spring-boot-starter-test</artifactId>
10.              <scope>test</scope>
11.          </dependency>
12.        
13.          <!-- Spring Boot Starter for Redis -->
14.          <dependency>
15.              <groupId>org.springframework.boot</groupId>
16.              <artifactId>spring-boot-starter-data-redis</artifactId>
17.          </dependency>
18.        
19.          <dependency>
20.              <groupId>org.projectlombok</groupId>
21.              <artifactId>lombok</artifactId>
22.          </dependency>
23.        
24.          <dependency>
25.              <groupId>com.alibaba</groupId>
26.              <artifactId>fastjson</artifactId>
27.              <version>1.2.83</version>
28.          </dependency>
29.         
30.     <!-- Jedis or Lettuce client -->
31.     <!-- Choose one of the following two dependencies -->
33.     <!-- For Jedis -->
34.     <dependency>
35.         <groupId>redis.clients</groupId>
36.         <artifactId>jedis</artifactId>
37.     </dependency>
39.     <!-- Or for Lettuce -->
40.     <dependency>
41.         <groupId>io.lettuce</groupId>
42.         <artifactId>lettuce-core</artifactId>
43.     </dependency>
44. </dependencies>

复制代码

3. 配置 Redis 连接信息

接下来，在 application.properties 或 application.yml 文件中配置 Redis 的连接参数。这里以 .yml 文件为例：

1. server:
2.   port: 8082
3. spring:
4.   data:
5.     redis:
6.       host: localhost
7.       port: 6379
8.       password: 123456

复制代码

4. 创建 Redis 操纵服务类

Java实体

1. import lombok.AllArgsConstructor;
2. import lombok.Data;
3. import lombok.NoArgsConstructor;
5. /**
6. * @Description
7. * @Author HaleyHu
8. * @Date 2024/12/5 23:41
9. */
10. @Data
11. @NoArgsConstructor
12. @AllArgsConstructor
13. public class User {
14.     private Long id;
15.     private String username;
16.     private int age;
17. }

复制代码

用户接口类

1. import org.hbin.redis.entity.User;
3. /**
4. * @Description
5. * @Author HaleyHu
6. * @Date 2024/12/5 23:44
7. */
8. public interface UserService {
9.     User query(Long id);
11.     Boolean expired(Long id);
12. }

复制代码

接口实现类

1. import com.alibaba.fastjson.JSON;
2. import lombok.RequiredArgsConstructor;
3. import org.hbin.redis.entity.User;
4. import org.hbin.redis.service.UserService;
5. import org.springframework.data.redis.core.RedisTemplate;
6. import org.springframework.stereotype.Service;
8. /**
9. * @Description
10. * @Author HaleyHu
11. * @Date 2024/12/5 23:46
12. */
13. @Service
14. @RequiredArgsConstructor
15. public class UserServiceImpl implements UserService {
16.     private final RedisTemplate<String, String> redisTemplate;
18.     private final String REDIS_PREFIX_KEY = "User::";
20.     @Override
21.     public User query(Long id) {
22.         Object obj = redisTemplate.opsForValue().get("User::" + id);
23.         if(obj != null) {
24.             return JSON.parseObject(obj.toString(), User.class);
25.         }
27.         // 模拟从DB查询
28.         User user = new User(id, "user" + id, 20);
29.         redisTemplate.opsForValue().set(REDIS_PREFIX_KEY + id, JSON.toJSONString(user));
30.         return user;
31.     }
33.     @Override
34.     public Boolean expired(Long id) {
35.         return redisTemplate.delete(REDIS_PREFIX_KEY + id);
36.     }
37. }

复制代码

Controller代码

1. import lombok.RequiredArgsConstructor;
2. import org.hbin.redis.entity.User;
3. import org.hbin.redis.service.UserService;
4. import org.springframework.web.bind.annotation.GetMapping;
5. import org.springframework.web.bind.annotation.RequestParam;
6. import org.springframework.web.bind.annotation.RestController;
8. /**
9. * @Description
10. * @Author HaleyHu
11. * @Date 2024/12/5 23:46
12. */
13. @RequiredArgsConstructor
14. @RestController
15. public class UserController {
16.     private final UserService userService;
18.     @GetMapping("/query")
19.     public User query(@RequestParam Long id) {
20.         return userService.query(id);
21.     }
23.     @GetMapping("/expired")
24.     public String expired(@RequestParam Long id) {
25.         return userService.expired(id).toString();
26.     }
27. }

复制代码

如果你想处理更复杂的数据类型（如对象），则需要使用 RedisTemplate 并配置序列化器。例如，使用 Jackson JSON 序列化器：

1. import com.fasterxml.jackson.databind.ObjectMapper;
2. import org.springframework.context.annotation.Bean;
3. import org.springframework.context.annotation.Configuration;
4. import org.springframework.data.redis.connection.RedisConnectionFactory;
5. import org.springframework.data.redis.core.RedisTemplate;
6. import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
7. import org.springframework.data.redis.serializer.StringRedisSerializer;
9. @Configuration
10. public class RedisConfig {
12.     @Bean
13.     public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
14.         RedisTemplate<String, Object> template = new RedisTemplate<>();
15.         template.setConnectionFactory(factory);
17.         Jackson2JsonRedisSerializer<Object> serializer = new Jackson2JsonRedisSerializer<>(Object.class);
18.         ObjectMapper objectMapper = new ObjectMapper();
19.         serializer.setObjectMapper(objectMapper);
21.         template.setValueSerializer(serializer);
22.         template.setKeySerializer(new StringRedisSerializer());
23.         template.setHashKeySerializer(new StringRedisSerializer());
24.         template.setHashValueSerializer(serializer);
26.         template.afterPropertiesSet();
27.         return template;
28.     }
29. }

复制代码

5. 使用 RedisTemplate 或 ReactiveRedisTemplate

Spring Data Redis 提供了两种主要的方式来与 Redis 举行交互：同步方式 (RedisTemplate) 和响应式编程方式 (ReactiveRedisTemplate)。根据你的需求选择合适的方式。
同步方式 (RedisTemplate)
这是最常见的方式，适用于大多数应用场景。
响应式编程方式 (ReactiveRedisTemplate)
如果你的应用采取了响应式编程模型（如 WebFlux），那么 ReactiveRedisTemplate 可能更适合你。它允许你以非阻塞的方式与 Redis 举行通信。
6. 测试 Redis 功能

最后，我们可以通过编写单元测试来验证 Redis 的基本功能是否正常工作。也可以摆设运行上述步伐来验证。访问路径：
http://localhost:8082/query?id=1
http://localhost:8082/expired?id=1

7. 注意事项

• 生产环境配置：在生产环境中摆设时，请确保精确配置 Redis 的安全设置（如暗码保护、网络限制等），并考虑启用长期化选项以防止数据丢失。
  
• 性能优化：公道调解连接池参数，避免过多的连接斲丧资源；同时也可以根据业务特点选用合适的序列化器来进步性能。
  
• 监控和维护：定期检查 Redis 的运行状态，及时清算过期数据，保持系统的稳定性和高效性。
  

8. 总结

通过上述步调，我们乐成地在 Spring Boot 应用中集成了 Redis，并实现了基本的数据缓存功能。这不但进步了应用的性能，还为开发者提供了更多灵活的数据管理本领。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。