在web應(yīng)用中,同一時(shí)間有大量的客戶端請求同時(shí)發(fā)送到服務(wù)器,例如搶購、秒殺等。這個(gè)時(shí)候如何避免將大量的請求同時(shí)發(fā)送到業(yè)務(wù)系統(tǒng)。
成都創(chuàng)新互聯(lián)專注為客戶提供全方位的互聯(lián)網(wǎng)綜合服務(wù),包含不限于網(wǎng)站制作、網(wǎng)站設(shè)計(jì)、芙蓉網(wǎng)絡(luò)推廣、重慶小程序開發(fā)、芙蓉網(wǎng)絡(luò)營銷、芙蓉企業(yè)策劃、芙蓉品牌公關(guān)、搜索引擎seo、人物專訪、企業(yè)宣傳片、企業(yè)代運(yùn)營等,從售前售中售后,我們都將竭誠為您服務(wù),您的肯定,是我們最大的嘉獎;成都創(chuàng)新互聯(lián)為所有大學(xué)生創(chuàng)業(yè)者提供芙蓉建站搭建服務(wù),24小時(shí)服務(wù)熱線:18980820575,官方網(wǎng)址:muchs.cn
第一種方法:在容器中配置最大請求數(shù),如果大于改請求數(shù),則客戶端阻塞。該方法有效的阻止了大量的請求同時(shí)訪問業(yè)務(wù)系統(tǒng),但對用戶不友好。
第二種方法:使用過濾器,保證一定數(shù)量的請求能夠正常訪問系統(tǒng),多余的請求先跳轉(zhuǎn)到排隊(duì)頁面,由排隊(duì)頁面定時(shí)發(fā)起請求。過濾器實(shí)現(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) { //請求個(gè)數(shù)太多,跳轉(zhuǎn)到排隊(duì)頁面 request.getRequestDispatcher("index.jsp").forward(request, response); } else { //請求個(gè)數(shù)加1 filterCount.incrementAndGet(); chain.doFilter(request, response); //訪問結(jié)束,請求個(gè)數(shù)減1 filterCount.decrementAndGet(); } }
此種方式的實(shí)現(xiàn)就是限流。可以參考RateLimiter的令牌桶限流策略的實(shí)現(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 需要限流的對象的標(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(); } /** * 獲取某個(gè)需限流對象的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); } }
總結(jié)
以上就是本文關(guān)于Javaweb應(yīng)用使用限流處理大量的并發(fā)請求詳解的全部內(nèi)容,希望對大家有所幫助。感興趣的朋友可以繼續(xù)參閱本站:javaweb設(shè)計(jì)中filter粗粒度權(quán)限控制代碼示例、Javaweb項(xiàng)目session超時(shí)解決方案、Javaweb使用cors完成跨域ajax數(shù)據(jù)交互等,有什么問題可以隨時(shí)留言,小編會及時(shí)回復(fù)大家的。感謝朋友們對本站的支持!
網(wǎng)頁題目:Javaweb應(yīng)用使用限流處理大量的并發(fā)請求詳解
文章分享:http://muchs.cn/article28/ijdecp.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供外貿(mào)建站、動態(tài)網(wǎng)站、靜態(tài)網(wǎng)站、商城網(wǎng)站、域名注冊、
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來源: 創(chuàng)新互聯(lián)