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

爱被打了一巴掌 2023-09-28 22:17 128阅读 0赞

很多人在笔试或者面试中问到：现在要你实现一个统计在线人数的功能，你该怎么设计？

不知道的朋友，这篇文章告诉你。

**先说答案：可以利用监听器Listener来实现**

**目录**

1. 监听器的简介

2. Java监听器的类型

(1)ServletContextListener

(2)HttpSessionListener

(3)ServletRequestListener

(4)ServletContextAttributeListener

(5)HttpSessionAttributeListener：

(6)ServletRequestAttributeListener：

(7)HttpSessionActivationListener

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

4.Redis实现统计人数功能

--------------------

## **1. 监听器的简介** ##

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

## **2. Java监听器的类型** ##

### **(1)ServletContextListener** ###

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

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

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

### **(2)HttpSessionListener** ###

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

**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中的序列化和反序列化**

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

## 4.**Redis实现统计人数功能** ##

**需求：平均访问时常，平均同时在线人数，最高同时在线人数**

**（1）先设计数据表：**

开始访问页面时间，离开页面时间表：（id，place，ip，user\_id，user\_name, begin\_time, end\_time, env, info,len\_min）

统计表：平均访问时常，平均同时在线人数，最高同时在线人数（id，day，age\_len\_visit\_min, acu, pcu）

统计记录表：每分钟的同时在线人数。 （id，min\_time, num）

（2）使用redis存储当前在线用户，每次调用可以看作浏览了一分钟(根据业务可以再细化，只需要定时任务记录上次一分钟和当前一分钟的用户，即可算出，某一个用户在某个页面的访问时常。  
（3）同时记录用户开始访问页面时间，离开页面时间，即可分析出后续。  
（4）为方便数据处理，可以记录每个页面每分钟的访问量。

（5）redis, 存储2个hash：

begin，定时器存储到的hash集合，记录详细信息  
now，接口传递过来的用户访问集合，记录刷新时间  
通过定时器来进行更新，刷新操作。  
ps: hash中单独的key不可以自动设置过期，或者使用redis监听，使用String类型的key，监听是过滤，匹配到自己需要处理的再进行处理即可。