English | 简体中文 | 繁體中文 | Русский язык | Français | Español | Português | Deutsch | 日本語 | 한국어 | Italiano | بالعربية
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;
}
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());
}
HttpServletResponse res = (HttpServletResponse) response;
res.sendError(HttpServletResponse.SC_SERVICE_UNAVAILABLE,"达到最大并发数限制");
log.info("达到最大并发数");
log.info("最大并发数量：")+count.get());
}
}
chain.doFilter(request, response);
log.info("第二次并发数量：")+count.get());
}
}
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>/script>
</div>
</body>
</html>
<%
} out = pageContext.pushBody();
%>
이 페이지는 서버가 투입한 페이지보다 훨씬 더 친절합니다.
읽어주셔서 감사합니다. 많은 도움이 되길 바랍니다. 많은 사이트 지원에 감사합니다!
선언: 이 문서의 내용은 인터넷에서 가져왔으며, 원작자의 소유입니다. 이 내용은 인터넷 사용자가 자발적으로 기여하고 업로드한 것이며, 이 사이트는 소유권을 가지지 않으며, 인공적으로 편집된 것이 아니며, 관련 법적 책임을 부담하지 않습니다. 저작권 문제가 있는 내용을 발견하면 notice#w로 이메일을 보내 주세요.3codebox.com에 이메일을 보내면, #을 @으로 변경하여 신고하시고 관련 증거를 제공하시면, 사실이 확인되면 이 사이트는 즉시 위반된 내용을 삭제합니다.