使用Spring Boot实现Redis多数据库缓存

Redis多数据库存储实现用户行为缓存

在我的系统中，为了优化用户行为数据的存储与访问服从，我引入了Redis缓存，并将数据分布在不同的Redis数据库中。通过这种方式，可以淘汰单一数据库的负载，进步系统的整体性能。
紧张实现步骤

• Redis配置
  
  
  
  • 配置两个Redis毗连工厂，分别用于存储Token和用户行为数据。
    
  • 创建对应的RedisTemplate实例，指定不同的毗连工厂及序列化方式。
    
  
  
• 用户行为服务
  
  
  
  • 通过UserBehaviorService接口及实在现类UserBehaviorServiceImpl，实现对用户点赞、收藏、品评、浏览行为的记录。
    
  • 在操作数据库的同时，将用户行为数据存储到Redis中以进步读取服从。
    
  
  
• Token拦截器
  
  
  
  • 使用TokenInterceptor类在每次请求前验证Token。
    
  • 验证通过后，将用户信息存储到ThreadLocal中，供后续操作使用。
    
  
  

代码实现

Redis配置类

1. @Configuration
2. public class RedisConfig {
4.     @Value("${spring.data.redis.host}")
5.     private String redisHost;
7.     @Value("${spring.data.redis.port}")
8.     private int redisPort;
10.     @Value("${spring.data.redis.password}")
11.     private String redisPassword;
13.     @Bean(name = "tokenRedisConnectionFactory")
14.     public RedisConnectionFactory tokenRedisConnectionFactory() {
15.         RedisStandaloneConfiguration config = new RedisStandaloneConfiguration(redisHost, redisPort);
16.         config.setPassword(redisPassword);
17.         config.setDatabase(0);
18.         return new LettuceConnectionFactory(config);
19.     }
21.     @Bean(name = "userBehaviorRedisConnectionFactory")
22.     public RedisConnectionFactory userBehaviorRedisConnectionFactory() {
23.         RedisStandaloneConfiguration config = new RedisStandaloneConfiguration(redisHost, redisPort);
24.         config.setPassword(redisPassword);
25.         config.setDatabase(1);
26.         return new LettuceConnectionFactory(config);
27.     }
29.     @Bean(name = "redisTemplate")
30.     public StringRedisTemplate redisTemplate(@Qualifier("tokenRedisConnectionFactory") RedisConnectionFactory redisConnectionFactory) {
31.         StringRedisTemplate template = new StringRedisTemplate();
32.         template.setConnectionFactory(redisConnectionFactory);
33.         template.setKeySerializer(new StringRedisSerializer());
34.         template.setValueSerializer(new StringRedisSerializer());
35.         return template;
36.     }
38.     @Bean(name = "userBehaviorRedisTemplate")
39.     public RedisTemplate<String, Map<String, Integer>> userBehaviorRedisTemplate(@Qualifier("userBehaviorRedisConnectionFactory") RedisConnectionFactory redisConnectionFactory) {
40.         RedisTemplate<String, Map<String, Integer>> template = new RedisTemplate<>();
41.         template.setConnectionFactory(redisConnectionFactory);
42.         template.setKeySerializer(new StringRedisSerializer());
43.         template.setValueSerializer(new Jackson2JsonRedisSerializer<>(Map.class));
44.         return template;
45.     }
46. }

复制代码

用户行为服务实现类

1. @Service
2. public class UserBehaviorServiceImpl implements UserBehaviorService {
4.     private static final long CACHE_EXPIRATION_DAYS = 1;
5.     private static final String CACHE_PREFIX = "articleCounts:";
7.     @Autowired
8.     private UserBehaviorMapper userBehaviorMapper;
10.     @Autowired
11.     @Qualifier("userBehaviorRedisTemplate")
12.     private RedisTemplate<String, Map<String, Integer>> userBehaviorRedisTemplate;
14.     @Override
15.     public void setLikeArticle(Likes likes) {
16.         likes.setCreateTime(LocalDateTime.now());
17.         Integer userId = ThreadLocalUtil.getUser("id");
18.         if (userId != null) {
19.             likes.setUserId(userId);
20.         }
21.         userBehaviorMapper.insertLike(likes);
22.     }
24.     @Override
25.     public void setFavoriteArticle(Favorites favorites) {
26.         favorites.setCreateTime(LocalDateTime.now());
27.         Integer userId = ThreadLocalUtil.getUser("id");
28.         if (userId != null) {
29.             favorites.setUserId(userId);
30.         }
31.         userBehaviorMapper.insertFavorite(favorites);
32.     }
34.     @Override
35.     public void setCommentArticle(Comments comments) {
36.         comments.setCreateTime(LocalDateTime.now());
37.         Integer userId = ThreadLocalUtil.getUser("id");
38.         if (userId != null) {
39.             comments.setUserId(userId);
40.         }
41.         userBehaviorMapper.insertComment(comments);
42.     }
44.     @Override
45.     public void setViewArticle(Views views) {
46.         views.setCreateTime(LocalDateTime.now());
47.         Integer userId = ThreadLocalUtil.getUser("id");
48.         if (userId != null) {
49.             views.setUserId(userId);
50.         }
51.         userBehaviorMapper.insertView(views);
52.     }
54.     @Override
55.     public Map<String, Integer> getArticleCounts(Integer articleId) {
56.         String key = CACHE_PREFIX + articleId;
57.         Map<String, Integer> counts = userBehaviorRedisTemplate.opsForValue().get(key);
58.         if (counts == null) {
59.             counts = fetchArticleCountsFromDB(articleId);
60.             cacheArticleCounts(articleId, counts);
61.         }
62.         return counts;
63.     }
65.     private Map<String, Integer> fetchArticleCountsFromDB(Integer articleId) {
66.         Map<String, Integer> counts = new HashMap<>();
67.         counts.put("likesCount", userBehaviorMapper.selectLikesCount(articleId));
68.         counts.put("favoritesCount", userBehaviorMapper.selectFavoritesCount(articleId));
69.         counts.put("commentsCount", userBehaviorMapper.selectCommentsCount(articleId));
70.         counts.put("viewsCount", userBehaviorMapper.selectViewsCount(articleId));
71.         return counts;
72.     }
74.     private void cacheArticleCounts(Integer articleId, Map<String, Integer> counts) {
75.         String key = CACHE_PREFIX + articleId;
76.         userBehaviorRedisTemplate.opsForValue().set(key, counts, CACHE_EXPIRATION_DAYS, TimeUnit.DAYS);
77.     }
78. }

复制代码

Token拦截器

1. @Component
2. public class TokenInterceptor implements HandlerInterceptor {
4.     @Autowired
5.     private StringRedisTemplate redisTemplate;
7.     @Override
8.     public boolean preHandle(HttpServletRequest request, @NotNull HttpServletResponse response, @NotNull Object handler) throws Exception {
9.         String token = request.getHeader("Authorization");
10.         if (token == null || token.isEmpty()) {
11.             response.setStatus(HttpStatus.UNAUTHORIZED.value());
12.             return false;
13.         }
15.         try {
16.             ValueOperations<String, String> operations = redisTemplate.opsForValue();
17.             String redisToken = operations.get(token);
18.             if (redisToken == null) {
19.                 response.setStatus(HttpStatus.UNAUTHORIZED.value());
20.                 return false;
21.             }
23.             Map<String, Object> claims = JwtUtil.parseToken(token);
24.             ThreadLocalUtil.setUser(claims);
25.             return true;
26.         } catch (Exception e) {
27.             response.setStatus(HttpStatus.UNAUTHORIZED.value());
28.             return false;
29.         }
30.     }
32.     @Override
33.     public void postHandle(@NotNull HttpServletRequest request, @NotNull HttpServletResponse response, @NotNull Object handler, ModelAndView modelAndView) throws Exception {
34.     }
36.     @Override
37.     public void afterCompletion(@NotNull HttpServletRequest request, @NotNull HttpServletResponse response, @NotNull Object handler, Exception ex) throws Exception {
38.         ThreadLocalUtil.remove();
39.     }
40. }

复制代码

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