Java如何实现统计在线人数功能

WBOY

发布时间：2023-04-19 09:13:02

2212人浏览过

来源于亿速云

转载

1. 监听器的简介

监听器就是一个实现特定接口的普通java程序，这个程序专门用于监听另一个java对象的方法调用或属性改变，当被监听对象发生上述事件后，监听器某个方法将立即被执行。

2. Java监听器的类型

(1)ServletContextListener

用于监听WEB，应用启动和销毁的事件

public void contextInitialized(ServletContextEvent sce):在初始化web应用时执行

public void contextDestroyed(ServletContextEvent sce) {}:在销毁web应用时执行

(2)HttpSessionListener

用于监听Session对象的创建和销毁

立即学习“Java免费学习笔记（深入）”；

public void sessionCreated(HttpSessionEvent se) {}:session创建的时候执行

public void sessionDestroyed(HttpSessionEvent se) {}: session被销毁的时候执行

(3)ServletRequestListener

用于监听Requset对象的创建和销毁

public void requsetCreated(HttpSessionEvent se) {}:requset创建的时候执行

public void requestDestroyed(HttpSessionEvent se) {}: requset被销毁的时候执行

(4)ServletContextAttributeListener

用于监听WEB作用域属性的改动，包括：增加属性、删除属性、修改属性

attributeAdded(ServletContextEvent sce):向ServletContext中添加属性时执行

attributeAdded(ServletContextRemoved sce):ServletContext中删除属性时执行

attributeReplaced(ServletContextRemoved sce):ServletContext中修改属性时执行

(5)HttpSessionAttributeListener

用于监听Session作用域属性的改动，包括：增加属性、删除属性、修改属性

(6)ServletRequestAttributeListener

用于监听Requset作用域属性的改动，包括：增加属性、删除属性、修改属性

(7)HttpSessionActivationListener

用于监听某个对象在Session中的序列化和反序列化

I-Shop购物系统

部分功能简介：商品收藏夹功能热门商品最新商品分级价格功能自选风格打印结算页面内部短信箱商品评论增加上一商品，下一商品功能增强商家提示功能友情链接用户在线统计用户来访统计用户来访信息用户积分功能广告设置用户组分类邮件系统后台实现更新用户数据系统图片设置模板管理CSS风格管理申诉内容过滤功能用户注册过滤特征字符IP库管理及来访限制及管理压缩，恢复，备份数据库功能上传文件管理商品类别管理商品添加/修改/

下载

3.监听器Listener实现统计人数功能

(1)先创建监听器包listener在新建OnlineListener类

package listener;
import javax.servlet.ServletContext;
import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;
import javax.servlet.annotation.WebListener;
import javax.servlet.http.HttpSessionAttributeListener;
import javax.servlet.http.HttpSessionEvent;
import javax.servlet.http.HttpSessionListener;
import javax.servlet.http.HttpSessionBindingEvent;
 
@WebListener()
public class OnlineListener implements ServletContextListener,HttpSessionListener, HttpSessionAttributeListener {

    private static int count=0;
 
    public OnlineListener() {//构造函数
    }
 
    // ServletContextListener的实现方法，在初始化web应用时执行，你可以在此处初始化server上下文相关数据
    public void contextInitialized(ServletContextEvent sce) {//应用初始化完成
   
    }
   
    // ServletContextListener的实现方法，在web应用关闭时执行
    public void contextDestroyed(ServletContextEvent sce) {
     
    }
 
    // HttpSessionListener的实现方法，session被创建的时候执行
    public void sessionCreated(HttpSessionEvent se) {//创建
        count++;
        ServletContext app = se.getSession().getServletContext();
        app.setAttribute("count",count);
    }


   // HttpSessionListener的实现方法，session被销毁的时候执行
    public void sessionDestroyed(HttpSessionEvent se) {
        count--;
        ServletContext app = se.getSession().getServletContext();
        app.setAttribute("count",count);
    }
}

(2)创建监听器servlet的接口

import javax.servlet.ServletContext;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.io.PrintWriter;
 
@WebServlet(name = "OnlineServlet",urlPatterns = "/online")
public class OnlineServlet extends HttpServlet {
    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
     this.doGet(request, response);
    }
 
    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
      String op=request.getParameter("op");
      String result="";
      switch (op){
          case "login":
              //request.getSession()触发监听器的sessionCreated
              ServletContext app=request.getSession().getServletContext();
              int count= (int) app.getAttribute("count");
              result=String.format("当前%d人在线",count);
              break;
          case "logout":
              //销毁session，触发监听器的sessionDestroy
              request.getSession().invalidate();//销毁session
              result="您已经退出了！";
      }
        response.setContentType("text/html;charset=utf-8");
        PrintWriter out=response.getWriter();
        out.write(result);
        out.close();
    }
}