很多人在笔试或者面试中问到:现在要你实现一个统计在线人数的功能,你该怎么设计?
不知道的朋友,这篇文章告诉你。
先说答案:可以利用监听器Listener来实现
目录
1. 监听器的简介
2. Java监听器的类型
(1)ServletContextListener
(2)HttpSessionListener
(3)ServletRequestListener
(4)ServletContextAttributeListener
(5)HttpSessionAttributeListener:
(6)ServletRequestAttributeListener:
(7)HttpSessionActivationListener
3.监听器Listener实现统计人数功能
4.Redis实现统计人数功能
监听器就是一个实现特定接口的普通java程序,这个程序专门用于监听另一个java对象的方法调用或属性改变,当被监听对象发生上述事件后,监听器某个方法将立即被执行。
用于监听WEB,应用启动和销毁的事件
public void contextInitialized(ServletContextEvent sce):在初始化web应用时执行
public void contextDestroyed(ServletContextEvent sce) {}:在销毁web应用时执行
用于监听Session对象的创建和销毁
public void sessionCreated(HttpSessionEvent se) {}:session创建的时候执行
public void sessionDestroyed(HttpSessionEvent se) {}: session被销毁的时候执行
用于监听Requset对象的创建和销毁
public void requsetCreated(HttpSessionEvent se) {}:requset创建的时候执行
public void requestDestroyed(HttpSessionEvent se) {}: requset被销毁的时候执行
用于监听WEB作用域属性的改动,包括:增加属性、删除属性、修改属性
attributeAdded(ServletContextEvent sce):向ServletContext中添加属性时执行
attributeAdded(ServletContextRemoved sce):ServletContext中删除属性时执行
attributeReplaced(ServletContextRemoved sce):ServletContext中修改属性时执行
用于监听Session作用域属性的改动,包括:增加属性、删除属性、修改属性
用于监听Requset作用域属性的改动,包括:增加属性、删除属性、修改属性
用于监听某个对象在Session中的序列化和反序列化
(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(); } }
需求:平均访问时常,平均同时在线人数,最高同时在线人数
(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: