Javaweb應(yīng)用使用限流處理大量的并發(fā)請求詳解

public class ServiceFilter implements Filter {
	
	private static final int MAX_COUNT = 20;
	
	private AtomicInteger filterCount = 0;

	public void doFilter(ServletRequest request, ServletResponse response,
			FilterChain chain) throws IOException, ServletException {
		System.out.println("before"+filterCount);
		if(filterCount > MAX_COUNT) {
			//請求個數(shù)太多，跳轉(zhuǎn)到排隊頁面
			request.getRequestDispatcher("index.jsp").forward(request, response);
		} else {
			//請求個數(shù)加1
			filterCount.incrementAndGet();

			chain.doFilter(request, response);
			//訪問結(jié)束，請求個數(shù)減1
			filterCount.decrementAndGet();
		}
	}

public class RateLimiterUtils {
	private static Logger logger = LoggerFactory.getLogger(RateLimiterUtils.class);
	private static final ConcurrentHashMap<String, RateLimiter> resourceLimitMap = 
			new ConcurrentHashMap<String, RateLimiter>();
	
	/**
	 * 限流
	 * @param resource 需要限流的對象的標(biāo)識
	 * @return true表示得到了許可，沒有達(dá)到限流閥值，false表示得不到許可，達(dá)到了限流閥值。
	 * @author: hejinen
	 * @date:2016年10月19日 上午11:08:49
	 */
	public static boolean rateLimit(String resource) {
		RateLimiter limit = getRateLimit(resource);
		return limit.tryAcquire();
	}
    /**
	 * 獲取某個需限流對象的RateLimiter，如不存在則創(chuàng)建新的
	 * @param resouce 需要限流的對象標(biāo)識
	 */
	public static RateLimiter getRateLimit(String resource) {
		RateLimiter limit = resourceLimitMap.get(resource);	
		if(limit == null) {
			synchronized(RateLimiterUtils.class) {
				limit = resourceLimitMap.get(resource);
				double qps = getQpsByResource(resource);
				if(limit == null) {
					limit = RateLimiter.create(qps);
					resourceLimitMap.put(resource, limit);
					LoggerUtil.info(RateLimiterUtils.class, "create rate limiter for key:{0},QPS:{1}", resource,qps);
				}
			}
		}
		return resourceLimitMap.get(resource);
	}
}