J2ee 高并发情况下监听器实例详解

J2ee 高并发情况下监听器实例详解

引言：在高并发下限制最大并发次数，在web.xml中用过滤器设置参数（最大并发数），并设置其他相关参数。详细见代码。
第一步：配置web.xml配置，不懂的地方解释一下：参数50通过参数名maxConcurrent用在filter的实现类中获取，filter-class就是写的实现类，

url-pattern就是限制并发时间的url，结束！

<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> 

第二步：写实现类实现filter，该接口有三个方法，详见代码。

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; 
 
/** 
 * Servlet Filter implementation class ConcurrentCountFilter 
 */ 
public class ConcurrentCountFilter implements Filter { 
  private static Logger log = LoggerFactory.getLogger(ConcurrentCountFilter.class); 
  private FilterConfig filterConfig; 
  private int maxConcurrent = -1; 
  //总计数 
  private static AtomicInteger count = new AtomicInteger(0); 
   
  /** 
   * 获取当前并发数 
   * @return 
   */ 
  public static int get(){  
      return count.get();  
    }  
  /** 
   * 增加并发数量 
   * @return 
   */ 
   public static int increase(){  
      return count.incrementAndGet();  
    } 
   /** 
   * 减少并发数量 
   * @return 
   */ 
   public static int decrement(){ 
     return count.decrementAndGet(); 
   } 
   
    
  /** 
   * 初始化 
   */ 
    public void init(FilterConfig filterConfig) throws ServletException { 
      //获取配置的最大并发数量 
      String maxStr = filterConfig.getInitParameter("maxConcurrent"); 
      int num = -1; 
      if(maxStr != null && !"".equals(maxStr)){ 
        num = Integer.parseInt(maxStr); 
      } 
      if(num >= 1){ 
        this.maxConcurrent = num; 
      }else{ 
        this.maxConcurrent = -1; 
      } 
    } 
    /** 
     * 过滤主方法 
     */ 
    public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException { 
      try{ 
      //增加并发数量 
      int num = increase(); 
      if(maxConcurrent > 0){ 
        if(maxConcurrent >= num){ 
          chain.doFilter(request, response); 
          log.info("第一次并发数量："+count.get()); 
        }else{ 
          HttpServletResponse res = (HttpServletResponse) response; 
          res.sendError(HttpServletResponse.SC_SERVICE_UNAVAILABLE,"达到最大并发数限制"); 
          log.info("达到最大并发数"); 
          log.info("最大并发数量："+count.get()); 
        } 
      }else{ 
        chain.doFilter(request, response); 
        log.info("第二次并发数量："+count.get()); 
      } 
      }finally { 
        decrement(); 
        log.info("减小的并发量："+count.get()); 
      } 
     
    } 
  /** 
   * 退出销毁 
   */ 
  public void destroy() { 
    this.filterConfig = null; 
    log.info("销毁......"); 
  } 
} 

代码到此完。

吐槽一下自己在项目中遇到的坑：

1.response.sendError( int, string);在本文代码中为res.sendError其中若直接如本文代码那样会返回一个503服务器带出来的页面，此页面粗暴及其难看，

在此为了友好通知用户，需做如下步骤，在web.xml中做如下配置代码：

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

如果在web.xml中配置了上面信息，首先会过滤503(HttpServletResponse.SC_SERVICE_UNAVAILABLE)状态码下的此页面而不会抛服务器的页面。

其中503.jsp页面需自己完成在此仅仅贴出来一个示例做参考，代码如下：

<% 
response.setStatus(503); 
 
// 获取异常类 
Throwable ex = Exceptions.getThrowable(request); 
if (ex != null){ 
  LoggerFactory.getLogger("500.jsp").error(ex.getMessage(), ex); 
} 
 
// 编译错误信息 
StringBuilder sb = new StringBuilder("错误信息：\n"); 
if (ex != null) { 
  sb.append(Exceptions.getStackTraceAsString(ex)); 
} else { 
  sb.append("未知错误.\n\n"); 
} 
 
// 如果是异步请求或是手机端，则直接返回信息 
if (Servlets.isAjaxRequest(request)) { 
  out.print(sb); 
} 
 
// 输出异常信息页面 
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 - 服务暂时不可用</title> 
  <%@include file="/WEB-INF/views/include/head.jsp" %> 
</head> 
<body> 
  <div class="container-fluid"> 
    <div class="page-header"><h1>服务暂时不可用请稍后再试.</h1></div> 
    <div class="errorMessage"> 
      错误信息：<%=ex==null?"未知错误.":StringUtils.toHtml(ex.getMessage())%> <br/> <br/> 
      服务器暂时不可用请稍后再试，谢谢！<br/> <br/> 
      <a href="javascript:" rel="external nofollow" rel="external nofollow" rel="external nofollow" rel="external nofollow" onclick="history.go(-1);" class="btn">返回上一页</a>  
      <a href="javascript:" rel="external nofollow" rel="external nofollow" rel="external nofollow" rel="external nofollow" onclick="$('.errorMessage').toggle();" class="btn">查看详细信息</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">返回上一页</a>  
      <a href="javascript:" rel="external nofollow" rel="external nofollow" rel="external nofollow" rel="external nofollow" onclick="$('.errorMessage').toggle();" class="btn">隐藏详细信息</a> 
      <br/> <br/> 
    </div> 
    <script>try{top.$.jBox.closeTip();}catch(e){}</script> 
  </div> 
</body> 
</html> 
<% 
} out = pageContext.pushBody(); 
%> 

此页面就比服务器抛出的页面友好甚多。

感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！

# J2ee高并发情况下监听器  # J2ee高并发  # J2ee高并发实现监听  # J2EE验证码图片如何生成和点击刷新验证码  # 分享J2EE的13种核心技术  # JDK、J2EE、J2SE、J2ME四个易混淆概念区分  # 图解Eclipse j2ee开发环境的搭建过程  # 经常听朋友说什么J2EE  # 终于知道点什么是J2EE了  # 汗一个  # MyEclipse5.0M1注册码+eclipse3.2[J2EE]  # J2EE 开发购物网站 经验篇 - 建表  # 实战 J2EE 开发购物网站 - 创建数据库  # 错误信息  # 此页面  # 不可用  # 在此  # 上一页  # 再试  # 请稍后  # 不懂  # 希望能  # 谢谢大家  # 到此  # 用在  # 第二步  # 贴出  # 抛出  # 就比  # 查看详细信息  # 中为  # 甚多  # 中做 

相关文章： 内网网站制作软件,内网的网站如何发布到外网？  如何快速启动建站代理加盟业务？  专业型网站制作公司有哪些,我设计专业的，谁给推荐几个设计师兼职类的网站？  详解jQuery中基本的动画方法  建站主机与虚拟主机有何区别？如何选择最优方案？  专业公司网站制作公司,用什么语言做企业网站比较好？  如何选择建站程序？包含哪些必备功能与类型？  已有域名和空间如何快速搭建网站？  如何在景安云服务器上绑定域名并配置虚拟主机？  如何用狗爹虚拟主机快速搭建网站？  专业企业网站设计制作公司,如何理解商贸企业的统一配送和分销网络建设？  黑客如何通过漏洞一步步攻陷网站服务器？  动图在线制作网站有哪些,滑动动图图集怎么做？  定制建站流程步骤详解：一站式方案设计与开发指南  整蛊网站制作软件,手机不停的收到各种网站的验证码短信,是手机病毒还是人为恶搞?有这种手机病毒吗？  简历在线制作网站免费,免费下载个人简历的网站是哪些？  表情包在线制作网站免费,表情包怎么弄？  内部网站制作流程,如何建立公司内部网站？  ppt在线制作免费网站推荐,有什么下载免费的ppt模板网站？  如何在IIS管理器中快速创建并配置网站？  可靠的网站设计制作软件,做网站设计需要什么样的电脑配置？  定制建站策划方案_专业建站与网站建设方案一站式指南  相册网站制作软件,图片上的网址怎么复制？  C#如何在一个XML文件中查找并替换文本内容  建站主机助手选型指南：2025年热门推荐与高效部署技巧  ,怎么用自己头像做动态表情包？  清除minerd进程的简单方法  建站主机默认首页配置指南：核心功能与访问路径优化  建站之星如何实现五合一智能建站与营销推广？  高防网站服务器：DDoS防御与BGP线路的AI智能防护方案  电商网站制作多少钱一个,电子商务公司的网站制作费用计入什么科目？  如何撰写建站申请书？关键要点有哪些？  齐河建站公司：营销型网站建设与SEO优化双核驱动策略  如何用AWS免费套餐快速搭建高效网站？  TestNG的testng.xml配置文件怎么写  网站设计制作书签怎么做,怎样将网页添加到书签/主页书签/桌面？  建站主机数据库如何配置才能提升网站性能？  全景视频制作网站有哪些,全景图怎么做成网页？  宿州网站制作公司兴策,安徽省低保查询网站？  图册素材网站设计制作软件,图册的导出方式有几种？  微信小程序 五星评分(包括半颗星评分)实例代码  建站之星官网登录失败？如何快速解决？  魔方云NAT建站如何实现端口转发？  香港服务器租用费用高吗？如何避免常见误区？  导航网站建站方案与优化指南：一站式高效搭建技巧解析  网站制作免费,什么网站能看正片电影？  北京网站制作网页,网站升级改版需要多久？  制作农业网站的软件,比较好的农业网站推荐一下？  如何高效完成自助建站业务培训？  实例解析Array和String方法