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();
}
}