用redis和jpa实现缓存文章和点击量-SpringBoot（23）

实现流程


1. 实现缓存文章

  1.1 实体类

1. package com.intehel.demo.domain;
3. import lombok.AllArgsConstructor;
4. import lombok.Data;
5. import lombok.NoArgsConstructor;
6. import java.io.Serializable;
8. @Data
9. @NoArgsConstructor
10. @AllArgsConstructor
11. public class Article implements Serializable {
12.     private Integer id;
13.     private Integer num;
14. }

复制代码

  1.2 数据库持久层

1. package com.intehel.demo.mapper;
3. import com.intehel.demo.domain.Article;
4. import org.apache.ibatis.annotations.*;
5. import org.springframework.stereotype.Repository;
7. @Repository
8. @Mapper
9. public interface ArticleMapper {
10.     Article findArticleById(Long id);
11.     Long updateArticle(@Param("lviews") Long lviews, @Param("lid") Long lid);
12. }

复制代码

  1.3 mybatis映射文件

1. <?xml version="1.0" encoding="UTF-8" ?>
2. <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
3. <mapper namespace="com.intehel.demo.mapper.ArticleMapper" >
4.     <resultMap id="BaseResultMap" type="com.intehel.demo.domain.Article" >
5.         <id column="id" property="id" jdbcType="INTEGER"/>
6.         <result column="num" property="num" jdbcType="BIGINT"/>
7.     </resultMap>
9.    
10.     <select id="findArticleById" resultMap="BaseResultMap" parameterType="java.lang.Long" >
11.         select * from article where id = #{id}
12.     </select>
14.    
15.     <update id="updateArticle" parameterType="java.lang.Long">
16.         update article set num = #{lviews} where id = #{lid}
17.     </update>
18. </mapper>

复制代码

  1.4 实现服务层的缓存设置

1. package com.intehel.demo.service;
3. import com.intehel.demo.domain.Article;
4. import com.intehel.demo.mapper.ArticleMapper;
5. import org.apache.ibatis.annotations.Param;
6. import org.springframework.beans.factory.annotation.Autowired;
7. import org.springframework.cache.annotation.CacheConfig;
8. import org.springframework.cache.annotation.CachePut;
9. import org.springframework.cache.annotation.Cacheable;
10. import org.springframework.stereotype.Service;
12. @Service
13. @CacheConfig(cacheNames = "articleService")
14. public class ArticleService {
15.     @Autowired
16.     private ArticleMapper articleMapper;
17.     @Cacheable(key = "#id")
18.     public Article findArticleById(Long id) {
19.         return articleMapper.findArticleById(id);
20.     }
21.     @CachePut(key = "#lid")
22.     public Article updateArticle(@Param("lviews") Long lviews, @Param("lid") Long lid) {
23.         articleMapper.updateArticle(lviews,lid);
24.         return articleMapper.findArticleById(lid);
25.     }
26. }

复制代码

  1.5 配置redis

1. package com.intehel.demo.config;
3. import com.fasterxml.jackson.annotation.JsonAutoDetect;
4. import com.fasterxml.jackson.annotation.PropertyAccessor;
5. import com.fasterxml.jackson.databind.ObjectMapper;
6. import org.springframework.cache.CacheManager;
7. import org.springframework.cache.annotation.CachingConfigurerSupport;
8. import org.springframework.cache.interceptor.KeyGenerator;
9. import org.springframework.context.annotation.Bean;
10. import org.springframework.context.annotation.Configuration;
11. import org.springframework.data.redis.cache.RedisCacheConfiguration;
12. import org.springframework.data.redis.cache.RedisCacheManager;
13. import org.springframework.data.redis.connection.RedisConnectionFactory;
14. import org.springframework.data.redis.core.RedisTemplate;
15. import org.springframework.data.redis.core.StringRedisTemplate;
16. import org.springframework.data.redis.serializer.*;
18. import java.lang.reflect.Method;
19. import java.time.Duration;
21. @Configuration
22. public class RedisConfig extends CachingConfigurerSupport {
24.     //在缓存对象集合中，缓存是以key-value形式保存的
25.     //如果没有指定缓存的key，则Spring Boot 会使用SimpleKeyGenerator生成key
26.     @Override
27.     @Bean
28.     public KeyGenerator keyGenerator() {
29.         return new KeyGenerator() {
30.             @Override
31.             //定义缓存key的生成策略
32.             public Object generate(Object target, Method method, Object... params) {
33.                 StringBuilder sb = new StringBuilder();
34.                 sb.append(target.getClass().getName());
35.                 sb.append(method.getName());
36.                 for (Object obj : params) {
37.                     sb.append(obj.toString());
38.                 }
39.                 return sb.toString();
40.             }
41.         };
42.     }
43.     @SuppressWarnings("rawtypes")
44.     @Bean
45.     //缓存管理器 2.X版本
46.     public CacheManager cacheManager(RedisConnectionFactory connectionFactory) {
47.         RedisSerializer<String> strSerializer = new StringRedisSerializer();
48.         Jackson2JsonRedisSerializer jacksonSeial =
49.                 new Jackson2JsonRedisSerializer(Object.class);
51.         // 解决查询缓存转换异常的问题
52.         ObjectMapper om = new ObjectMapper();
53.         om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
54.         om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
55.         jacksonSeial.setObjectMapper(om);
57.         // 定制缓存数据序列化方式及时效
58.         RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig()
59.                 .entryTtl(Duration.ofDays(1))
60.                 .serializeKeysWith(RedisSerializationContext.SerializationPair
61.                         .fromSerializer(strSerializer))
62.                 .serializeValuesWith(RedisSerializationContext.SerializationPair
63.                         .fromSerializer(jacksonSeial))
64.                 .disableCachingNullValues();
65.         RedisCacheManager cacheManager = RedisCacheManager
66.                 .builder(connectionFactory).cacheDefaults(config).build();
67.         return cacheManager;
68.     }
69.     //缓存管理器 1.X版本
70. /*    public CacheManager cacheManager(@SuppressWarnings("rawtypes")RedisTemplate redisTemplate){
71.         return new RedisCacheManager(redisTemplate);
72.     }*/
74.     @Bean
75.     //注册成Bean被Spring管理，如果没有这个Bean，则Redis可视化工具中的中文内容都会以二进制存储，不易检查
76.     public RedisTemplate<String,Object> redisTemplate(RedisConnectionFactory factory){
77.         RedisTemplate<String, Object> template = new RedisTemplate<>();
78.         template.setConnectionFactory(factory);
79.         // 创建JSON格式序列化对象，对缓存数据的key和value进行转换
80.         Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
81.         // 解决查询缓存转换异常的问题
82.         ObjectMapper om = new ObjectMapper();
83.         om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
84.         om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
85.         jackson2JsonRedisSerializer.setObjectMapper(om);
86.         //设置redisTemplate模板API的序列化方式为json
87.         template.setDefaultSerializer(jackson2JsonRedisSerializer);
88.         return template;
89.     }
91.     @Bean
92.     public StringRedisTemplate stringRedisTemplate(RedisConnectionFactory factory){
93.         StringRedisTemplate stringRedisTemplate = new StringRedisTemplate();
94.         stringRedisTemplate.setConnectionFactory(factory);
95.         return stringRedisTemplate;
96.     }
97.     private RedisSerializer<?> keySerializer() {
98.         return new StringRedisSerializer();
99.     }
101.     // 值使用jackson进行序列化
102.     private RedisSerializer<?> valueSerializer() {
103.         return new GenericJackson2JsonRedisSerializer();
104.         // return new JdkSerializationRedisSerializer();
105.     }
106. }

复制代码

2. 实现统计点击量

1. package com.intehel.demo.controller;
3. import com.intehel.demo.domain.Article;
4. import com.intehel.demo.service.ArticleService;
5. import org.springframework.beans.factory.annotation.Autowired;
6. import org.springframework.data.redis.core.RedisTemplate;
7. import org.springframework.web.bind.annotation.PathVariable;
8. import org.springframework.web.bind.annotation.RequestMapping;
9. import org.springframework.web.bind.annotation.RestController;
11. @RestController
12. @RequestMapping("/article")
13. public class ArticleController {
14.     @Autowired
15.     private ArticleService articleService;
16.     @Autowired
17.     private RedisTemplate<String,Object> redisTemplate;
18.     @RequestMapping("/{id}")
19.     public Article testPathVariable(@PathVariable("id") Integer id){
20.         Article article = articleService.findArticleById(Long.valueOf(id));
21.         System.out.println(article);
22.         if (article.getNum()>0){
23.             if (redisTemplate.opsForValue().get("num::"+id)!=null){
24.                 redisTemplate.opsForValue().increment("num::"+id, 1);
25.             }else {
26.                 redisTemplate.boundValueOps("num::"+id).increment(article.getNum()+1);
28.             }
29.         }else {
30.             redisTemplate.boundValueOps("num::"+id).increment(1);
31.         }
32.         return article;
33.     }
34. }

复制代码

3.实现定时同步

1. package com.intehel.demo.config;
3. import com.intehel.demo.service.ArticleService;
4. import org.springframework.beans.factory.annotation.Autowired;
5. import org.springframework.data.redis.core.RedisTemplate;
6. import org.springframework.scheduling.annotation.Scheduled;
7. import org.springframework.stereotype.Component;
8. import javax.annotation.Resource;
9. import java.util.ArrayList;
10. import java.util.List;
11. import java.util.Set;
13. @Component
14. public class CountScheduledTasks {
15.     @Autowired
16.     private ArticleService articleService;
17.     @Resource
18.     private RedisTemplate<String,Object> redisTemplate;
19.     @Scheduled(cron = "0/10 * * * * ?" )
20.     public void syncPostViews(){
21.         Long StartTime = System.nanoTime();
22.         List dtolist = new ArrayList();
23.         Set<String> keySet = redisTemplate.keys("num::*");
24.         System.out.println(keySet);
25.         for (String key : keySet) {
26.             String view = redisTemplate.opsForValue().get(key).toString();
27.             String sid = key.replaceAll("num::", "");
28.             Long lid = Long.valueOf(sid);
29.             Long lviews = Long.valueOf(view);
30.             articleService.updateArticle(lviews,lid);
31.             redisTemplate.delete(key);
32.         }
33.     }
34. }

复制代码

  同时要在启动类中添加注解，开启redis缓存和定时任务：

1. @SpringBootApplication
2. @EnableCaching
3. @EnableScheduling
4. @MapperScan("com.intehel.demo")

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！