Comment implémenter la fonction de comptage des personnes en ligne en Java

1. Introduction à l'écouteur

Un écouteur est un programme Java ordinaire qui implémente une interface spécifique. Ce programme est spécialement utilisé pour surveiller les appels de méthode ou les modifications de propriétés d'un autre objet Java lorsque les événements ci-dessus se produisent. objet surveillé, une méthode de l'écouteur sera exécutée immédiatement.

2. Types d'écouteurs Java

(1) ServletContextListener

Utilisé pour écouter les événements WEB, de démarrage et de destruction d'applications

public void contextInitialized(ServletContextEvent sce) : exécuté lors de l'initialisation de l'application Web

public void contextDestroyed( ServletContextEvent sce) sce) {} : Exécuté lorsque l'application Web est détruite

(2)HttpSessionListener

est utilisé pour surveiller la création et la destruction des objets Session

public void sessionCreated(HttpSessionEvent se) {} : Exécuté lorsque la session est créée

public void sessionDestroyed(HttpSessionEvent se) {} : exécuté lorsque la session est détruite

(3)ServletRequestListener

est utilisé pour surveiller la création et la destruction des objets Requset

public void requsetCreated(HttpSessionEvent se) {} : exécuté lorsque le requset est créé

public void requestDestroyed(HttpSessionEvent se) {} : exécuté lorsque le requset est détruit

(4)ServletContextAttributeListener

est utilisé pour surveiller les modifications dans les attributs de portée WEB, notamment : l'ajout d'attributs, la suppression d'attributs, la modification d'attributs

attributeAdded(ServletContextEvent sce ): Exécuté lors de l'ajout d'attributs à ServletContext

attributeAdded(ServletContextRemoved sce): Exécuté lors de la suppression d'attributs dans ServletContext

attributReplaced(ServletContextRemoved sce): Exécuté lors de la modification d'attributs dans ServletContext

(5) HttpSessionAttributeListener

est utilisé pour surveiller les modifications de la fonction de session dans les attributs de domaine, notamment : l'ajout d'attributs, la suppression d'attributs, la modification d'attributs

(6) ServletRequestAttributeListener

est utilisé pour surveiller les modifications dans les attributs de portée Requset, notamment : l'ajout d'attributs, la suppression d'attributs, la modification d'attributs

(7)HttpSessionActivationListener

Utilisé pour surveiller la sérialisation et la désérialisation d'un objet dans la session

3 Listener implémente la fonction de comptage de personnes

(1) Créez d'abord le package d'écoute, puis créez une nouvelle classe 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) Créer L'interface du servlet d'écoute

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 implémente la fonction de comptage de personnes

Exigences : temps d'accès moyen, nombre moyen de personnes en ligne en même temps, nombre maximum de personnes en ligne en même temps. time

(1) Concevez d'abord le tableau de données :

Commencez à visiter l'heure de la page, quittez le calendrier de la page : (id, place, ip, user_id, user_name, start_time, end_time, env, info, len_min)

Tableau de statistiques : temps de visite moyen, nombre moyen de personnes en ligne en même temps, nombre maximum de personnes en ligne en même temps (id, jour, age_len_visit_min, acu, pcu)

Tableau d'enregistrement statistique : nombre de personnes en ligne en même temps par minute . (id, min_time, num)

(2) Utilisez redis pour stocker les utilisateurs en ligne actuels. Chaque appel peut être considéré comme une navigation pendant une minute (il peut être affiné davantage en fonction de l'entreprise, seule la tâche planifiée doit enregistrer la tâche planifiée. dernière minute et la minute en cours), vous pouvez calculer la fréquence à laquelle un utilisateur visite une certaine page

(3) En même temps, enregistrez l'heure à laquelle l'utilisateur commence à visiter la page et l'heure à laquelle il quitte la page, et vous pouvez analyser le suivi.

(4) Pour faciliter le traitement des données, peut enregistrer le nombre de visites par page et par minute

(5) redis, stocke 2 hachages :

begin, l'ensemble de hachage stocké. par la minuterie, enregistre des informations détaillées

maintenant, l'ensemble d'accès utilisateur transmis par l'interface, enregistre l'heure de rafraîchissement

Utilisez la minuterie pour effectuer des opérations de mise à jour et d'actualisation

ps : les clés individuelles du hachage ne peuvent pas être automatiquement configurées pour expirer , ou utilisez la surveillance Redis, utilisez des clés de type String, la surveillance filtre et correspond à ce dont vous avez besoin. Traitez-le à nouveau

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!