统计网站的用户访问量的实现

待我称王封你为后i 2022-05-28 07:42 342阅读 0赞

1、项目需求：一个IP一天内访问算是一次访问，统计该网站的用户访问量。

2、实现思想：服务器启动的时候把数据库中的访问量进行缓存，用户访问的时候进行访问量的刷新，把访问信息存到集合中进行缓存，达到一定数量的时候要存入数据库中，服务器关闭的时候把未存入数据库中的访问量存入数据库中

3、代码实现：

//用来统计不同的URL对应的访问情况  
    private static List<Map<String, Integer>> accessNumMapList = new ArrayList<Map<String, Integer>>();  
    //访问总量  
    public static int accessSum = 0;  
    //用来缓存当天的访问ip，vector是同步的，线程安全的  
    public static Vector<String> ipVector = new Vector<String>();  
    //用来缓存访问量的信息  
    private static List<AccessStatistics> asList = new ArrayList<AccessStatistics>();  
      
    //定时任务,每天凌晨的时候把当天的访问量归0  
    public void accessTodayJob() \{  
        ipVector = new Vector<String>();  
    \}  
      
    //服务器启动的时候调用该方法，用到了注解开发的方式，进行缓存url分类对应的条数，总条数，当天的条数  
    @PostConstruct  
    public void getAccessNum() \{  
        accessNumMapList = dao.getAccessUrlNum();  
        accessSum = dao.getAccessSum();  
        ipVector = dao.getIpListToday();  
    \}      
      
    //处理请求，并刷新数据  
    public synchronized void accessMethod(HttpServletRequest request) \{  
        boolean flag = false;  
        for (String str : ipVector) \{  
            if(request.getRemoteAddr().equals(str)) \{  
                flag = true;  
                break;  
            \}  
        \}  
        if(!flag) \{  
            ipVector.addElement(request.getRemoteAddr());  
            accessSum ++;  
              
            boolean containUrl = false;  
            //表示的是url：数量  
            for (Map<String, Integer> accessNumMap : accessNumMapList) \{  
                //如果存在该url,进行count++  
                if(accessNumMap.containsKey(request.getRequestURI())) \{  
                    int count = accessNumMap.get(request.getRequestURI());  
                    count = count + 1;  
                    accessNumMap.put(request.getRequestURI(), count);  
                    containUrl = true;  
                    //跳出循环  
                    break;  
                \}  
            \}  
              
            if(!containUrl) \{  
                Map<String, Integer> accessNumMap = new HashMap<String, Integer>();  
                accessNumMap.put(request.getRequestURI(), 1);  
                accessNumMapList.add(accessNumMap);  
            \}  
                      
            AccessStatistics as = new AccessStatistics();  
            as.setRemoteAddr(request.getRemoteAddr());  
            as.setRequestUrl(request.getRequestURI());  
            as.setMethod(request.getMethod());  
            as.setRequestTime(new Date());  
            asList.add(as);  
            //这里在配置文件配置缓存的大小，重启服务器就行，不用进行编译  
            if(asList.size() >= Integer.valueOf(Global.getConfig("accessCacheSize"))) \{  
                new SaveThread().start();  
            \}  
        \}  
    \}  
      
    //开一个线程进行处理保存操作，提高性能  
    private class SaveThread extends Thread\{  
        private boolean flag = false;//这里通过用标识符的方式来保证线程的安全，并且提高性能。  
        // 如果开启了这个线程下次进方法的时候，就直接走run方法  
        public  void run() \{  
            if(flag) \{  
                return;  
            \}  
            flag = true;  
            for (AccessStatistics accessStatistics : asList) \{  
                save(accessStatistics);  
            \}  
            //清空内存  
            asList = new ArrayList<AccessStatistics>();  
            flag = false;  
        \}  
    \}  
      
    //关闭服务器,把未存入数据库中的数据存入数据库中  
    @PreDestroy  
    public void serverStop() \{  
        if(asList.size() > 0) \{  
            new SaveThread().start();  
        \}  
    \}