SpringBoot+Quartz+Redis+Mysql定时从Redis存入Mysql

朴灿烈づ我的快乐病毒、 2023-06-09 03:52 5阅读 0赞

先说明一下场景  
以博客为例，对每个用户的粉丝，和该用户下面的博客的赞数之和，放入redis  
这里以1小时更新一次  
代码实现  
以  
https://blog.csdn.net/baxxdwyp/article/details/102622981  
https://blog.csdn.net/baxxdwyp/article/details/102620035  
为基础，一个quartz单任务，一个redis set 点赞  
我们更改一下Job的任务

/**
     * 定时更新用户的总量
     */
    public class UserSumJob implements Job
    {
        @Autowired
        private UserDao userDao;
        @Autowired
        private RedisTemplate redisTemplate;
        public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
    
            System.out.println("用户总量统计中");
    
            List<String> info = userDao.userId();
            for (int i=0;i<info.size();i++)
            {
                UserSum userSum = new UserSum();
                String userid = info.get(i);
                //总粉丝
                int fansSum = redisTemplate.opsForSet().size("star_"+userid).intValue();
                userSum.setUserId(userid);
                userSum.setFans(fansSum);
                List<String> blogIdInfo = userDao.blogId(userid);
                //总赞
                int sum = 0;
                for (int j=0;j<blogIdInfo.size();j++)
                {
                    String blogId = blogIdInfo.get(i);
                    int a = redisTemplate.opsForSet().size("fabulous_"+blogId).intValue();
                    sum = sum + a;
                }
                userSum.setFabulous(sum);
                userDao.updateUserSum(userSum);
            }
        }
    }

redis用的是set类型，key = star\_userId 放的是粉丝，统计粉丝量  
key = fabulous\_blogId，统计一篇博客的点赞量，然后一个用户的所有博客相加，即为该用户的总赞量  
然后存放到实体类中，在到dao实现，即可存取到mysql中