扫二维码与项目经理沟通
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流
J2ee 如何实现监听高并发？相信很多没有经验的人对此束手无策，为此本文总结了问题出现的原因和解决方法，通过这篇文章希望你能解决这个问题。
创新互联建站网站建设服务商，为中小企业提供网站建设、成都做网站服务，网站设计，网站托管、服务器租用等一站式综合服务型公司，专业打造企业形象网站，让您在众多竞争对手中脱颖而出创新互联建站。
J2ee 高并发情况下监听器实例详解
引言：在高并发下限制最大并发次数，在web.xml中用过滤器设置参数（最大并发数），并设置其他相关参数。详细见代码。
第一步：配置web.xml配置，不懂的地方解释一下：参数50通过参数名maxConcurrent用在filter的实现类中获取，filter-class就是写的实现类，
url-pattern就是限制并发时间的url，结束！
ConcurrentCountFilter com.procure.pass.ConcurrentCountFilter maxConcurrent 50 ConcurrentCountFilter /a/pass/export
第二步：写实现类实现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中做如下配置代码：
503 /WEB-INF/views/error/503.jsp
如果在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"%>
503 - 服务暂时不可用
<%@include file="/WEB-INF/views/include/head.jsp" %>
<%
} out = pageContext.pushBody();
%>
看完上述内容，你们掌握J2ee 如何实现监听高并发的方法了吗？如果还想学到更多技能或想了解更多相关内容，欢迎关注创新互联行业资讯频道，感谢各位的阅读！
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流
微信二维码
移动版官网