结合redis实现后台统计(今日访客/总访客)

2023-11-20 05:42| 来源: 网络整理| 查看: 265

一、实现今日访客

1、本项目redis的配置

#redis相关的信息 redis: host: 127.0.0.1 port: 6381

2、controller实现数据的记录

//获取访客数量 @RequestMapping("selectIp") public String test(HttpServletRequest request){ 　　　　//获取ip String ip = request.getHeader("x-forwarded-for"); if(ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) { ip = request.getHeader("Proxy-Client-IP"); } if(ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) { ip = request.getHeader("WL-Proxy-Client-IP"); } if(ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) { ip = request.getRemoteAddr(); } System.out.println("-----"+ip); /*获取当前日期*/ Calendar calendar = new GregorianCalendar(); String day = (calendar.get(Calendar.HOUR_OF_DAY)*60+ calendar.get(Calendar.MINUTE))+""; /*获取总访问次数*/ String num = redisTemplate.opsForValue().get("ipAdress"); //如果ip不为空 if(ip != null){ //redis中没有这个值或者今日访问时间小于当前时间说明已访问 if(!redisTemplate.hasKey("iptime_" + ip) || Integer.parseInt(day) < Integer.parseInt(redisTemplate.opsForValue().get("iptime_"+ip))) { //添加一个iptime_本机ip，值为当前分钟时间,设置生命周期为一天 redisTemplate.opsForValue().set("iptime_" + ip, day, 1,TimeUnit.DAYS); //重新赋值访问次数 num = redisTemplate.opsForValue().increment("ipAdress")+""; } } //返回总访客 return num; }

3、前端页面加载事件调用接口（在不同的服务需要通过feignCilent来调用方法）

$(function(){ /*获取访问网页ip*/ $.post("/admin/selectIp",function(rs){ $("#num").html(rs); },"json"); });

用户访问：访问量加1，记录ip和访问时间

二、实现总访客

1、创建一张记录总访客的表

2、service接口的方法

public interface ICountvisitorsService extends IService { //更新网站访客数量 boolean updateVisitors(T_countvisitors countvisitors) throws Exception; //查询网站的访问量 T_countvisitors findCount(T_countvisitors countvisitors) throws Exception; }

3、serviceimpl实现类的代码

@Service public class CountvisitorsServiceImpl extends ServiceImpl implements ICountvisitorsService { //更新网站访客数量 @Override public boolean updateVisitors(T_countvisitors countvisitors) throws Exception { //添加修改时间 countvisitors.setUpdatetime(new Date()); return getBaseMapper().updateById(countvisitors) > 0 ? true : false; } //查询网站的访问量 @Override public T_countvisitors findCount(T_countvisitors countvisitors) throws Exception { return getBaseMapper().selectById(countvisitors.getCid()); }

4、编写一个定时任务，在每天凌晨一点的时候执行（将redis中的今日访客加上总访客）

@Configuration @EnableScheduling public class MyCountTask { @Autowired private ICountvisitorsService countvisitorsService; @Autowired private RedisTemplate redisTemplate; //设置每天凌晨1点执行 @Scheduled(cron="0 0 1 * * ?") public void CountVisitors() throws Exception { //清空当天数据 if(redisTemplate.hasKey("ipAdress")){ T_countvisitors countvisitors = new T_countvisitors(); //修改更新时间 countvisitors.setUpdatetime(new Date()); //获取数据库中的对象 T_countvisitors countvisitors2 = countvisitorsService.findCount(countvisitors); //从redis中获取数据，存放在数据库 countvisitors.setNum(Integer.parseInt(redisTemplate.opsForValue().get("ipAdress"))+countvisitors2.getNum()); //删除redis中的今日访客 redisTemplate.delete("ipAdress"); //执行修改数据，保存总访客 countvisitorsService.updateVisitors(countvisitors); } }

5、返回今日访客与总访客的controller

//显示今日访问页面的人数、总访问页面的人数 @RequestMapping("pageCount") public JSONResult pageCount() throws Exception { JSONResult jsonResult = new JSONResult(); T_countvisitors countvisitors = countvisitorsService.findCount(new T_countvisitors()); List listNum = new ArrayList(); listNum.add(redisTemplate.opsForValue().get("ipAdress")); listNum.add(countvisitors.getNum() + ""); jsonResult.setRecords(listNum); jsonResult.setCode(20000); return jsonResult; }

实现每周、每月、访客地区数据--需要创建多一些表

【本文地址】

公司简介

联系我们