监听器应用一般统计在线人数,闲着没事，写个笔记，我们项目中是这样做的
首先定义一个servlet 这个servelt 在服务器启动时，就会调用，初始化：
这个是 web.xml的配置
<!-- added by li'n for 登陆页面自动读取访问数 on 2013-04-15 the beginning -->
<servlet>
<servlet-name>VisitCounts</servlet-name>
<servlet-class>com.sysware.framework.login.VisitCounts</servlet-class>
<load-on-startup>0</load-on-startup>
</servlet>
<!-- added by li'n for 登陆页面自动读取访问数 on 2013-04-15 the end -->
２、项目登录页面可以获取访问本项目的总人数（init方法）
package com.sysware.framework.login;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.io.IOException;
import javax.servlet.http.HttpServlet;
/**
* @version 1.0
* @author li'n on 系统工程部
* @since 2013-04-15 17:00
*
*/
public class VisitCounts extends HttpServlet{
/**
*
*/
private static final long serialVersionUID = -6737156348721467846L;
//累计访问量
public static int counts = 0;
public static void setCounts(int counts) {
VisitCounts.counts = counts;
}
/**
*
* @return 历史访问量
*/
public int getCounts() {
return counts;
}
/**
* 服务器启动时读取文件中的历史访问量
*/
public void init()
{
//获取visitCount.txt的文件路径
String p = this.getClass().getClassLoader().getResource("").getPath();
File file = new File(p+File.separator +"visitCount.txt");
//读取文件中的数字，即系统的历史访问量
if (file.exists()) {
readFile(file);
} else {
try {
file.createNewFile();
readFile(file);
} catch (IOException e) {
e.printStackTrace();
}
}
}
/**
* 读取文件file中的访问量数据
*/
@SuppressWarnings("static-access")
public void readFile(File file){
BufferedReader reader = null;
String tempString = null;
try {
reader = new BufferedReader(new FileReader(file));
while((tempString = reader.readLine()) != null)
{
VisitCounts.counts = Integer.parseInt(tempString);
System.out.println();
this.setCounts(counts);
}
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
３、在用户登录时，数量加１并用流写到文件里面（doLogin方法里面处理）
if(loginInfo.isSuccess())
{
//added by li'n for 访问量统计 on 2013-04-19 the beginning
//登录成功，访问量加1
VisitCounts.setCounts(VisitCounts.counts + 1);
//将访问量更新到文件visitCount.txt
writeFile();
//added by li'n for 访问量统计 on 2013-04-19 the end
}
/**
* 将访问量更新到文件visitCount.txt
* @return 历史访问量
* @author li'n on 系统工程部
* @since 2013-04-19
*/
public void writeFile(){
FileWriter filewrite = null;
try {
//获得文件路径
filewrite = new FileWriter(this.getClass().getClassLoader().getResource("").getPath()+File.separator +"visitCount.txt");
//将访问量写入文件
int o = VisitCounts.counts;
filewrite.write(o + "
");
filewrite.flush();
filewrite.close();
} catch (Exception e) {
e.printStackTrace();
}
}
以上，是实现累计访问量的一个方法；
下面说说实现在线人数，这个就要用到监听器的方式
首先还是在 web.xml中配置你所写的监听器
<!-- 在线用户session监听器 --> <listener> <listener-class>com.sysware.framework.login.OnlineSessionListener</listener-class> </listener>
２、监听器类
package com.sysware.framework.login;
import javax.servlet.http.HttpSessionAttributeListener;
import javax.servlet.http.HttpSessionBindingEvent;
import com.sysware.framework.commons.SystemConstants;
/**
*
*
* 在线session监听器
*
* @version : 1.0
* @since : 2012-5-21下午08:46:02
* @team : 系统管理
* @author : liuxj
*/
public class OnlineSessionListener implements HttpSessionAttributeListener {
@Override
public void attributeAdded(HttpSessionBindingEvent event) {
if (SystemConstants.SESSION_KEY.equals(event.getName())) {
OnlineUserContext.getInstance().addSession(event.getSession());
}
}
@Override
public void attributeRemoved(HttpSessionBindingEvent event) {
if (SystemConstants.SESSION_KEY.equals(event.getName())) {
OnlineUserContext.getInstance().removeSession(event.getSession());
}
}
@Override
public void attributeReplaced(HttpSessionBindingEvent event) {
if (SystemConstants.SESSION_KEY.equals(event.getName())) {
OnlineUserContext.getInstance().replaceSession(event.getSession());
}
}
}
package com.sysware.framework.login; import java.util.ArrayList; import java.util.HashMap; import java.util.Iterator; import java.util.List; import java.util.Map; import java.util.Map.Entry; import javax.servlet.http.HttpSession; import com.sysware.framework.commons.SystemConstants; import com.sysware.framework.eobs.commons.ObjectCloneUtils; import com.sysware.utils.SyswareUtil; /** * copyright : Sysware Technology Co., Ltd * * 在线用户信息上下文 * * @version : 1.0 * @since : 2012-5-21下午08:31:07 * @team : 系统管理 * @author : liuxj */ public class OnlineUserContext { private static OnlineUserContext onlineUserContext; // 用户在线信息 private Map<String, HttpSession> onlineUserMap; private OnlineUserContext() { onlineUserMap = new HashMap<String, HttpSession>(); } /** * 获取在线用户上下文实例 * * @since : 2012-5-23:下午05:47:55 * @return 在线用户上下文实例 */ public static OnlineUserContext getInstance() { return onlineUserContext == null ? onlineUserContext = new OnlineUserContext() : onlineUserContext; } /** * 加入session触发 * * @since : 2012-5-21:下午09:02:26 * @param session * session对象 */ synchronized void addSession(HttpSession session) { onlineUserMap.put(session.getId(), session); } /** * 移除Session * * @since : 2012-5-21:下午09:02:56 * @param session * session对象 */ synchronized void removeSession(HttpSession session) { if (onlineUserMap.containsKey(session.getId())) { onlineUserMap.remove(session.getId()); } } /** * 替换Session * * @since : 2012-5-21:下午09:03:18 * @param session * session对象 */ synchronized void replaceSession(HttpSession session) { addSession(session); } /** * 根据用户ID判断是否登录 * * @since : 2013-1-28:下午02:01:31 * @param userId * 用户ID * @return true已经登录|false未登录 */ public boolean isLogged(String userId) { List<OnlineUserInfo> list = getOnlineUserInfoList(); for (OnlineUserInfo info : list) { if (info.isLogged() && info.getUserId().equals(userId)) { return true; } } return false; } /** * 根据sessionId获取session * @since : 2012-12-17:下午01:06:11 * @param sessionId sessionId * @return session */ public HttpSession getSession(String sessionId) { return onlineUserMap.containsKey(sessionId) ? onlineUserMap.get(sessionId) : null; } /** * 根据sessionId移除session * @since : 2012-12-17:下午01:05:39 * @param sessionId sessionId */ public void removeSession(String sessionId) { HttpSession session = getSession(sessionId); if(!SyswareUtil.isEmpty(session)) { session.invalidate(); session = null; } } /** * 获取当前登录操作用户数量 * * @since : 2012-5-21:下午09:20:54 * @return 登录操作用户数量 */ public int getLoginUserCount() { int num = 0; List<OnlineUserInfo> list = getOnlineUserInfoList(); for(OnlineUserInfo info : list) { if(info.isLogged()) { num ++; } } return num; } /** * 获取当前未登录的操作用户数量 * * @since : 2012-5-21:下午09:21:14 * @return 未登录的操作用户数量 */ public int getNoLoginUserCount() { int num = 0; List<OnlineUserInfo> list = getOnlineUserInfoList(); for(OnlineUserInfo info : list) { if(!info.isLogged()) { num ++; } } return num; } /** * 获取当前操作用户总数 * * @since : 2012-5-21:下午09:22:16 * @return 操作用户总数 */ public int getOperatorCount() { return getOnlineUserInfoList().size(); } /** * 获取当前操作用户列表 * * @since : 2012-5-22:上午10:11:39 * @return 操作用户列表 */ public synchronized List<OnlineUserInfo> getOnlineUserInfoList() { List<OnlineUserInfo> list = new ArrayList<OnlineUserInfo>(); Iterator<Entry<String, HttpSession>> iterator = onlineUserMap .entrySet().iterator(); while (iterator.hasNext()) { Entry<String, HttpSession> entry = iterator.next(); OnlineUserInfo info = ObjectCloneUtils.clone(getOnlineUserInfo(entry.getKey())); info.setSessionId(entry.getKey()); list.add(info); } return list; } /** * 获取在线用户信息 * * @since : 2012-5-21:下午09:14:01 * @param sessionId * session的ID * @return 在线用户信息 */ private OnlineUserInfo getOnlineUserInfo(String sessionId) { HttpSession session = getSession(sessionId); return SyswareUtil.isEmpty(session) ? null : (Operator) session.getAttribute(SystemConstants.SESSION_KEY); } }
上面的方法，一个是在线统计人数，一个是实现总访问量，自己项目中运用的，做个笔记。
<div class="visit">当前访问数：<span id="nowVisitCount" style="color:#5374B1;"><%=OnlineUserContext.getInstance().getLoginUserCount() %></span></div> <div class="count">累计访问数：<span id="historyVisitCount" style="color:#5374B1;"><%=new LoginServiceImpl().getCounts()%></span></div>