在開發J2EE的過程往往需要限制併發請求量從而減少伺服器異常的可能性。而這些通常都是通過叢集手段或外部代理來實現的。本文主要介紹單個應用如何不依賴其他程式來解決這個問題。

J2EE的每個請求都是經由過濾器（責任鏈模式），Servlet來執行的，每個請求的進入都需要過濾器的准許才能執行到Servlet，那麼只需要在過濾器上計算當前的併發數並與最大允許數量對比即可實現併發限制。

原始碼：

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;

/**
 * 併發量計數與限制過濾器
 * @author ZYB
 * @date Dec 2, 2014 3:21:36 PM<BR/>
 */
public class ConcurrentCountFilter implements Filter{
	// 如果不是用來限制全域性併發(配置路徑為/*的)的那麼把static關鍵字去掉即可.
	private static AtomicInteger count = new AtomicInteger(0);
	
	/**
	 * 獲取當前併發數
	 * @author ZYB
	 * @date Dec 3, 2014 9:51:37 AM<BR/>
	 * @return
	 */
	public static int get(){
		return count.get();
	}
	
	/**
	 * 增加併發數量
	 * @author ZYB
	 * @date Dec 3, 2014 9:51:32 AM<BR/>
	 * @return
	 */
	public static int increase(){
		return count.incrementAndGet();
	}
	
	/**
	 * 減少併發數量
	 * @author ZYB
	 * @date Dec 3, 2014 9:51:22 AM<BR/>
	 * @return
	 */
	public static int decrement(){
		return count.decrementAndGet();
	}
	
	/**
	 * 最大併發允許數量, 負數表示不限制
	 */
	private int maxConcurrent = -1;
	
	/* (non-Javadoc)
	 * @see javax.servlet.Filter#init(javax.servlet.FilterConfig)
	 */
	@Override
	public void init(FilterConfig filterConfig) throws ServletException {
		String maxStr = filterConfig.getInitParameter("maxConcurrent");
		int num = -1;
		if(maxStr != null && !"".equals(maxStr)){
			try{
				num = Integer.parseInt(maxStr);
			}catch(NumberFormatException e){}
		}
		if(num >= 1){
			this.maxConcurrent = num;
		}else{
			this.maxConcurrent = -1;
		}
	}

	/* (non-Javadoc)
	 * @see javax.servlet.Filter#doFilter(javax.servlet.ServletRequest, javax.servlet.ServletResponse, javax.servlet.FilterChain)
	 */
	@Override
	public void doFilter(ServletRequest request, ServletResponse response,
			FilterChain chain) throws IOException, ServletException {
		try{
			int num = increase();//增加併發數量,並取得當前數量
			if(maxConcurrent > 0){//檢查是否限制最大併發數量, <=0表示不限制
				if(maxConcurrent >= num){//檢查是否超過最大併發限制, 沒超過則允許執行
					chain.doFilter(request, response);
				}else{
					//超過最大併發限制
					HttpServletResponse res = (HttpServletResponse) response;
					res.sendError(HttpServletResponse.SC_SERVICE_UNAVAILABLE, "達到最大併發數限制:" + this.maxConcurrent);
				}
			}else{//未限制最大併發數
				chain.doFilter(request, response);
			}
		}finally{//由於Servlet執行時可能會丟擲異常,所以使用try-finally塊來減少併發數非常必要.
			decrement();
		}
	}

	/* (non-Javadoc)
	 * @see javax.servlet.Filter#destroy()
	 */
	@Override
	public void destroy() {
	}

}