Java如何實現統計線上人數功能

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中刪除屬性時執行

#Serv 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，監聽是過濾，配對到自己需要處理的再進行處理即可。

以上是Java如何實現統計線上人數功能的詳細內容。更多資訊請關注PHP中文網其他相關文章！