English | 简体中文 | 繁體中文 | Русский язык | Français | Español | Português | Deutsch | 日本語 | 한국어 | Italiano | بالعربية
J2高負荷状況でのリスナーインスタンスの詳細
導言：高並行下最大並行回数を制限し、web.xmlでフィルタを使用してパラメータ（最大並行数）を設定し、他の関連パラメータも設定します。詳細はコードを参照してください。
第1步：web.xmlの設定を行い、不明な点について説明します：パラメータ50は、パラメータ名maxConcurrentを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>
第2步：编写实现类以实现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("2回目の並行数量："+count.get());
}
}
decrement();
log.info("減少した並行量："+count.get());
}
}
/**
* 破棄を終了
*/
public void destroy() {
this.filterConfig = null;
log.info("破棄......");
}
}
コードはここで終わります。
プロジェクトで実際に遭遇した問題について少し話しましょう：
1.response.sendError(int, string);このコードでは、本文の通りに直接使用すると、以下のようなエラーが返されます：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#oldtoolbag.com（メールを送信する際、#を@に変更してください。報告を行い、関連する証拠を提供してください。一旦確認がついたら、このサイトは侵害疑いのコンテンツをすぐに削除します。）