J2ee 高并 * 况下 * 实例详解
作者:Smy_0114 时间:2022-12-26 05:47:43
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();
%>
此页面就比服务器抛出的页面友好甚多。
感谢阅读,希望能帮助到大家,谢谢大家对本站的支持!
来源:http://blog.csdn.net/smy_0114/article/details/55270707
标签:J2ee,高并发, ,
0
投稿
猜你喜欢
Java8 用Lambda表达式给List集合排序的实现
2023-02-05 17:27:09
详解SpringBoot注入数据的方式
2022-05-09 06:34:24
Android Fragment的用法实例详解
2022-01-21 03:39:40
c# 生成二维码的示例
2021-09-17 14:03:26
Android使用android-wheel实现省市县三级联动
2022-10-07 21:01:00
Android进阶Hook拦截系统实例化View过程实现App换肤功能
2023-12-01 21:22:12
Java环境配置图文教程(推荐)
2023-09-17 11:27:42
Android 显示和隐藏输入法实现代码
2023-03-29 06:42:39
Java中synchronized的几种使用方法
2023-06-19 16:33:28
C#中的自动类型转换和强制类型转换
2023-08-10 07:11:14
Java读取Properties文件的七种方法的总结
2022-08-12 13:27:18
C# 设计模式系列教程-状态模式
2022-11-07 13:31:55
Android动画之3D翻转效果实现函数分析
2022-08-07 12:37:42
Java连接redis及基本操作示例
2023-12-07 03:27:03
Spring Boot中操作使用Redis实现详解
2023-11-24 02:39:29
Spring Boot+Shiro实现一个Http请求的Basic认证
2022-06-01 22:22:31
C#实现Datatable排序的方法
2022-12-30 11:31:52
实例分析Java中public static void main(String args[])是什么意思
2023-10-18 16:34:01
C#获取程序文件相关信息的方法
2021-12-12 05:34:51
C#入门教程之集合ArrayList用法详解
2022-04-30 06:32:13