J2Explicación detallada del ejemplo de instancia del listener en condiciones de alta concurrencia ee

J2Explicación detallada del ejemplo de instancia del listener en condiciones de alta concurrencia ee

Introducción: Limitar el número máximo de conexiones concurrentes bajo alta concurrencia, configurar los parámetros (número máximo de conexiones concurrentes) en el archivo web.xml y establecer otros parámetros relacionados. Ver detalles en el código.
Primer paso: configurar el archivo web.xml, explique aquí los puntos que no comprende: parámetros50 se utiliza mediante el nombre de parámetro maxConcurrent en la clase de implementación del filtro, filtro-La clase es la clase que escribimos,

url-El patrón es la URL que limita el tiempo de conexión concurrente, ¡termina aquí!

<filter> 
  <filter-name>ConcurrentCountFilter</filter-name> 
  <filter-class>com.procure.pass.ConcurrentCountFilter</filter-class> 
  <init-param> 
    <param-name>maxConcurrent</param-name> 
    <param-value>50</param-value> 
  </init-param> 
 </filter> 
 <filter-mapping> 
  <filter-name>ConcurrentCountFilter</filter-name> 
  <url-pattern>/a/pass/export</url-pattern> 
 </filter-mapping> 

Segundo paso: escribir la clase de implementación del filtro y los métodos del interfaz, consulte el código para más detalles.

import java.io.IOException; 
import java.util.concurrent.atomic.AtomicInteger; 
import javax.servlet.Filter; 
import javax.servlet.FilterChain; 
import javax.servlet.FilterConfig; 
import javax.servlet.ServletException; 
import javax.servlet.ServletRequest; 
import javax.servlet.ServletResponse; 
import javax.servlet.http.HttpServletResponse; 
import org.slf4j.Logger; 
import org.slf4j.LoggerFactory; 
/** 
 * Clase de implementación del Filtro Servlet ConcurrentCountFilter 
 */ 
public class ConcurrentCountFilter implements Filter { 
  private static Logger log = LoggerFactory.getLogger(ConcurrentCountFilter.class); 
  private FilterConfig filterConfig; 
  private int maxConcurrent = -1; 
  //Cuenta total 
  private static AtomicInteger count = new AtomicInteger(0); 
  /** 
   * Obtener cantidad concurrente actual 
   * @return 
   */ 
  public static int get(){  
      return count.get();  
    }  
  /** 
   * Aumentar cantidad concurrente 
   * @return 
   */ 
   public static int increase(){  
      return count.incrementAndGet();  
    } 
   /** 
   * Reducir cantidad concurrente 
   * @return 
   */ 
   public static int decrement(){ 
     return count.decrementAndGet(); 
   } 
  /** 
   * Inicialización 
   */ 
    public void init(FilterConfig filterConfig) throws ServletException { 
      //Obtener cantidad máxima concurrente de configuración 
      String maxStr = filterConfig.getInitParameter("maxConcurrent"); 
      int num = -1; 
      if(maxStr != null && !"".equals(maxStr)){ 
        num = Integer.parseInt(maxStr); 
      } 
      if(num >= 1){ 
        this.maxConcurrent = num; 
      } 
        this.maxConcurrent = -1; 
      } 
    } 
    /** 
     * Método principal de filtrado 
     */ 
    public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException { 
      try{ 
      //Aumentar cantidad concurrente 
      int num = increase(); 
      if(maxConcurrent > 0){ 
        if(maxConcurrent >= num){ 
          chain.doFilter(request, response); 
          log.info("Primera cantidad concurrente:")+count.get()); 
        } 
          HttpServletResponse res = (HttpServletResponse) response; 
          res.sendError(HttpServletResponse.SC_SERVICE_UNAVAILABLE,"Se ha alcanzado el límite de la cantidad máxima de concurrencia"); 
          log.info("Se ha alcanzado el número máximo de concurrencia"); 
          log.info("Cantidad máxima de concurrencia:")+count.get()); 
        } 
      } 
        chain.doFilter(request, response); 
        log.info("Segunda cantidad de concurrencia:")+count.get()); 
      } 
      } 
        decrement(); 
        log.info("Disminución de la cantidad de concurrencia:")+count.get()); 
      } 
    } 
  /** 
   * Salida destrucción 
   */ 
  public void destroy() { 
    this.filterConfig = null; 
    log.info("Destrucción......"); 
  } 
} 

El código termina aquí.

Quejarse de los problemas encontrados en el proyecto:

1.response.sendError(int, string); en el código de este artículo, es res.sendError si se devuelve directamente como el código de este artículo, se devolverá un503La página del servidor presentada, esta página es bruta y difícil de ver,

Para notificar amigablemente al usuario, se deben seguir los siguientes pasos, realizar la configuración de código siguiente en web.xml:

<error-page> 
  <error-code>503</error-code> 
  <location>/WEB-INF/views/error/503.jsp</location> 
 </error-page> 

Si se configuró la información anterior en web.xml, primero se filtrará503con código de estado (HttpServletResponse.SC_SERVICE_UNAVAILABLE) de esta página no lanzará la página del servidor.

Donde503.jsp página debe ser completada aquí solo se muestra un ejemplo como referencia, el código es el siguiente:

<% 
response.setStatus(503); 
// Obtener la clase de excepción 
Throwable ex = Exceptions.getThrowable(request); 
if (ex != null){ 
  LoggerFactory.getLogger("500.jsp").error(ex.getMessage(), ex); 
} 
// Mensaje de error de compilación 
StringBuilder sb = new StringBuilder("Mensaje de error: \n"); 
if (ex != null) { 
  sb.append(Exceptions.getStackTraceAsString(ex)); 
} 
  sb.append("Error desconocido.\n\n"); 
} 
// Si es una solicitud asíncrona o desde un dispositivo móvil, devolver la información directamente}} 
if (Servlets.isAjaxRequest(request)) { 
  out.print(sb); 
} 
// Mostrar página de información de excepción 
else { 
%> 
<%@page import="org.slf4j.Logger,org.slf4j.LoggerFactory"%> 
<%@page import="com.xahl_oa.internal.common.web.Servlets"%> 
<%@page import="com.xahl_oa.internal.common.utils.Exceptions"%> 
<%@page import="com.xahl_oa.internal.common.utils.StringUtils"%> 
<%@page contentType="text/html;charset=UTF-8"isErrorPage="true"%> 
<%@include file="/WEB-INF/views/include/taglib.jsp"%> 
<!DOCTYPE html> 
<html> 
<head> 
  <title>503 - El servicio está temporalmente inaccesible</title> 
  <%@include file="/WEB-INF/views/include/head.jsp" %> 
</head> 
<body> 
  <div class="container-fluid"> 
    <div class="page-header"><h1>El servicio está temporalmente inaccesible, por favor inténtelo de nuevo más tarde.</h1></div> 
    <div class="errorMessage"> 
      Información de error：<%=ex==null&63;"Error desconocido.":StringUtils.toHtml(ex.getMessage())%> <br/> <br/> 
      El servidor está temporalmente inaccesible, por favor inténtelo de nuevo más tarde. ¡Gracias! <br/> <br/> 
      <a href="javascript:" rel="external nofollow" rel="external nofollow" rel="external nofollow" rel="external nofollow" onclick="history.go(-1);" class="btn">Volver a la página anterior</a>  
      <a href="javascript:" rel="external nofollow" rel="external nofollow" rel="external nofollow" rel="external nofollow" onclick="$('.errorMessage').toggle();" class="btn">Ver detalles</a> 
    </div> 
    <div class="errorMessage hide"> 
      <%=StringUtils.toHtml(sb.toString())%> <br}}/> 
      <a href="javascript:" rel="external nofollow" rel="external nofollow" rel="external nofollow" rel="external nofollow" onclick="history.go(-1);" class="btn">Volver a la página anterior</a>  
      <a href="javascript:" rel="external nofollow" rel="external nofollow" rel="external nofollow" rel="external nofollow" onclick="$('.errorMessage').toggle();" class="btn">Ocultar detalles</a> 
      <br/> <br/> 
    </div> 
    <script>try{top.$.jBox.closeTip();}catch(e){}</script>/script> 
  </div> 
</body> 
</html> 
<% 
} out = pageContext.pushBody(); 
%> 

Esta página es mucho más amigable que la página lanzada por el servidor.

Gracias por leer, espero que pueda ayudar a todos, gracias por el apoyo de este sitio!

Declaración: el contenido de este artículo se obtiene de la red, el copyright pertenece al propietario original, el contenido se contribuye y carga espontáneamente por los usuarios de Internet, este sitio no posee los derechos de propiedad, no se ha realizado una edición humana y no asume la responsabilidad legal relevante. Si encuentra contenido sospechoso de copyright, le invitamos a enviar un correo electrónico a: notice#oldtoolbag.com (al enviar un correo electrónico, por favor reemplace # con @) para denunciar, y proporcione la evidencia relevante. Una vez verificada, este sitio eliminará inmediatamente el contenido sospechoso de infracción.