Servlet监听器统计网站在线人数
本节我们利用 Servlet 监听器接口，完成一个统计网站在线人数的案例。当一个用户登录后，显示欢迎信息，同时显示出当前在线人数和用户名单。当用户退出登录或 Session 过期时，从在线用户名单中删除该用户，同时将在线人数减 1。
本案例可以通过如下 2 种方案实现：
- 使用 HttpSessionListener 和 HttpSessionAttributeListener 实现；
- 使用 HttpSessionBindingListener 实现。
使用 HttpSessionListener 和 HttpSessionAttributeListener 实现
1. 创建一个名称为 listennerDemo 的工程，并分别创建 net.biancheng.www.listener 和 net.biancheng.www.servlet 两个包。
2. 在 WebContent 中，创建 login.html，代码如下。
Insert title here
3. 在 net.biancheng.www.servlet 包中，创建名称为 LoginServlet 的 Servlet 类，代码如下。
package net.biancheng.www.servlet;
import java.io.IOException;
import java.io.PrintWriter;
import java.util.ArrayList;
import java.util.List;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.Cookie;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
/**
* 登录校验
* @author 编程帮 www.biancheng.net
*/
@WebServlet("/LoginServlet")
public class LoginServlet extends HttpServlet {
private static final long serialVersionUID = 1L;
@SuppressWarnings("unchecked")
protected void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
// 设置页面输出格式
response.setContentType("text/html;charset=UTF-8");
//修改request缓冲区的字符集为UTF-8
request.setCharacterEncoding("utf-8");
PrintWriter writer = response.getWriter();
// 获取表单数据
String username = request.getParameter("username");
// 查看当前会话是否已有账号登录
String logined = (String) request.getSession().getAttribute("username");
// 当前会话已有账号登录
if ("".equals(username) || username == null) {
System.out.println("非法操作，您没有输入用户名");
response.sendRedirect("/listennerDemo/login.html");
} else {
if (!"".equals(logined) && logined != null) {
System.out.println("您已经登录，重复登录无效，请先退出当前账号重新登录！");
writer.write("编程帮 www.biancheng.net
"
+ "您好，您已经登录了账户：" + logined + "
"
+ "如要登录其他账号，请先退出当前账号重新登录！");
// 登陆页面为填写内容
} else {// 将当前账号加入会话中
request.getSession().setAttribute("username", username);
writer.write("编程帮 www.biancheng.net
"
+ "" + username + "： 欢迎您的到来
");
}
// 从上下文中获取已经登录账号的集合
List onLineUserList = (List) request.getServletContext().getAttribute("onLineUserList");
if (onLineUserList != null) {
// 向页面输出结果
writer.write(
" 当前在线人数为：" + onLineUserList.size() + "
" + "");
for (int i = 0; i < onLineUserList.size(); i++) {
writer.write("\r\n" + "" + onLineUserList.get(i) + " \r\n" + " ");
}
}
writer.write("
" + "退出登录");
}
}
protected void doPost(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
doGet(request, response);
}
}
4. 在 net.biancheng.www. listener 包中，创建名称为 MySessionListener 的监听器类，代码如下。
package net.biancheng.www.listener;
import java.util.ArrayList;
import java.util.List;
import javax.servlet.ServletContext;
import javax.servlet.annotation.WebListener;
import javax.servlet.http.HttpSession;
import javax.servlet.http.HttpSessionAttributeListener;
import javax.servlet.http.HttpSessionBindingEvent;
import javax.servlet.http.HttpSessionEvent;
import javax.servlet.http.HttpSessionListener;
/**
* 监听器
* @author 编程帮 www.bianchengbang.net
*
*/
@WebListener
public class MySessionListener implements HttpSessionListener,HttpSessionAttributeListener{
@SuppressWarnings("unchecked")
@Override
public void attributeAdded(HttpSessionBindingEvent se) {
System.out.println("HttpSessionAttributeListener****attributeAdded()方法开始工作*******************");
//从上下文中获取已经登录账号的集合
List onLineUserList = (List) se.getSession().getServletContext().getAttribute("onLineUserList");
//在上下文中没有登陆用户
if(onLineUserList==null || onLineUserList.size()==0) {
onLineUserList = new ArrayList();
}
String username =(String) se.getSession().getAttribute("username");
//向已登录集合中添加当前账号
onLineUserList.add(username);
System.out.println("用户："+username+" 成功加入在线用户列表");
for(int i= 0;i onlineUserList = (List) application.getAttribute("onLineUserList");
// 取得登录的用户名
String username = (String) session.getAttribute("username");
if(!"".equals(username) && username!=null && onlineUserList!=null && onlineUserList.size()>0 ) {
// 从在线列表中删除用户名
onlineUserList.remove(username);
System.out.println(username+"已经退出！");
System.out.println("当前在线人数为"+onlineUserList.size());
}else {
System.out.println("会话已经销毁！");
}
}
} 5. 在 net.biancheng.www.servlet 包中，创建名称为 LogoutServlet 的 Servlet 类，代码如下。
package net.biancheng.www.servlet;
import java.io.IOException;
import java.util.List;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
/**
* 退出登录
* @author 编程帮 www.bianchengbang.net
*
*/
@WebServlet("/LogoutServlet")
public class LogoutServlet extends HttpServlet {
private static final long serialVersionUID = 1L;
protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
//退出登录操作，将此次session进行销毁
//触发HttpSessionListener监听器的sessionDestroyed方法
request.getSession().invalidate();
//跳转回登录页面
response.sendRedirect("/listennerDemo/login.html");
}
protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
doGet(request, response);
}
}启动 Tomcat，在谷歌浏览器地址栏输入“http://localhost:8080/listennerDemo/login.html”