91超碰碰碰碰久久久久久综合_超碰av人澡人澡人澡人澡人掠_国产黄大片在线观看画质优化_txt小说免费全本

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

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

發布時間:2020-10-15 16:43:36 來源:腳本之家 閱讀:220 作者:在遠行的路上 欄目:編程語言

在web應用中,同一時間有大量的客戶端請求同時發送到服務器,例如搶購、秒殺等。這個時候如何避免將大量的請求同時發送到業務系統。

第一種方法:在容器中配置最大請求數,如果大于改請求數,則客戶端阻塞。該方法有效的阻止了大量的請求同時訪問業務系統,但對用戶不友好。

第二種方法:使用過濾器,保證一定數量的請求能夠正常訪問系統,多余的請求先跳轉到排隊頁面,由排隊頁面定時發起請求。過濾器實現如下:

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

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

此種方式的實現就是限流。可以參考RateLimiter的令牌桶限流策略的實現。

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,如不存在則創建新的
	 * @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應用使用限流處理大量的并發請求詳解的全部內容,希望對大家有所幫助。感興趣的朋友可以繼續參閱本站:javaweb設計中filter粗粒度權限控制代碼示例、Javaweb項目session超時解決方案、Javaweb使用cors完成跨域ajax數據交互等,有什么問題可以隨時留言,小編會及時回復大家的。感謝朋友們對本站的支持!

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

望城县| 调兵山市| 谷城县| 札达县| 临泽县| 合水县| 弥渡县| 城口县| 宁津县| 临汾市| 雷山县| 海盐县| 迁西县| 北流市| 亳州市| 镇坪县| 河津市| 梅州市| 迭部县| 彩票| 信阳市| 天水市| 永城市| 渭南市| 嘉义县| 黄陵县| 马龙县| 黑水县| 宁陵县| 阳城县| 清徐县| 北川| 东安县| 云和县| 阿拉尔市| 永善县| 丰城市| 蛟河市| 申扎县| 新巴尔虎左旗| 潢川县|