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

在web應用中，同一時間有大量的客戶端請求同時發(fā)送到服務器，例如搶購、秒殺等。這個時候如何避免將大量的請求同時發(fā)送到業(yè)務系統(tǒng)。

成都創(chuàng)新互聯(lián)專注為客戶提供全方位的互聯(lián)網綜合服務，包含不限于網站制作、網站設計、芙蓉網絡推廣、重慶小程序開發(fā)、芙蓉網絡營銷、芙蓉企業(yè)策劃、芙蓉品牌公關、搜索引擎seo、人物專訪、企業(yè)宣傳片、企業(yè)代運營等，從售前售中售后，我們都將竭誠為您服務，您的肯定，是我們最大的嘉獎；成都創(chuàng)新互聯(lián)為所有大學生創(chuàng)業(yè)者提供芙蓉建站搭建服務，24小時服務熱線：18980820575，官方網址：jinyejixie.com

第一種方法：在容器中配置最大請求數(shù)，如果大于改請求數(shù)，則客戶端阻塞。該方法有效的阻止了大量的請求同時訪問業(yè)務系統(tǒng)，但對用戶不友好。

第二種方法：使用過濾器，保證一定數(shù)量的請求能夠正常訪問系統(tǒng)，多余的請求先跳轉到排隊頁面，由排隊頁面定時發(fā)起請求。過濾器實現(xiàn)如下：

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ù)太多，跳轉到排隊頁面
			request.getRequestDispatcher("index.jsp").forward(request, response);
		} else {
			//請求個數(shù)加1
			filterCount.incrementAndGet();

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

此種方式的實現(xiàn)就是限流?？梢詤⒖糝ateLimiter的令牌桶限流策略的實現(xiàn)。

public class RateLimiterUtils {
	private static Logger logger = LoggerFactory.getLogger(RateLimiterUtils.class);
	private static final ConcurrentHashMap<String, RateLimiter> resourceLimitMap = 
			new ConcurrentHashMap<String, RateLimiter>();
	
	/**
	 * 限流
	 * @param resource 需要限流的對象的標識
	 * @return true表示得到了許可，沒有達到限流閥值，false表示得不到許可，達到了限流閥值。
	 * @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 需要限流的對象標識
	 */
	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);
	}
}

總結

以上就是本文關于Javaweb應用使用限流處理大量的并發(fā)請求詳解的全部內容，希望對大家有所幫助。感興趣的朋友可以繼續(xù)參閱本站：javaweb設計中filter粗粒度權限控制代碼示例、Javaweb項目session超時解決方案、Javaweb使用cors完成跨域ajax數(shù)據交互等，有什么問題可以隨時留言，小編會及時回復大家的。感謝朋友們對本站的支持！

網頁題目：Javaweb應用使用限流處理大量的并發(fā)請求詳解
文章分享：http://jinyejixie.com/article28/ijdecp.html

成都網站建設公司_創(chuàng)新互聯(lián)，為您提供外貿建站、動態(tài)網站、靜態(tài)網站、商城網站、域名注冊、

聲明：本網站發(fā)布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經允許不得轉載，或轉載時需注明來源：創(chuàng)新互聯(lián)

猜你還喜歡下面的內容

成人午夜视频全免费观看高清-秋霞福利视频一区二区三区-国产精品久久久久电影小说-亚洲不卡区三一区三区一区

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