目錄一、實(shí)戰(zhàn)說(shuō)明1.1 效果說(shuō)明1.2 核心知識(shí)點(diǎn)二、 環(huán)境搭建三、限流演示3.1 并發(fā)請(qǐng)求工具3.2 效果示例圖一、實(shí)戰(zhàn)說(shuō)明1.1 效果說(shuō)明

本篇主要講如何使用Semaphore對(duì)單接口進(jìn)行限流，例如有如下場(chǎng)景a. A系統(tǒng)的有a接口主要給B系統(tǒng)調(diào)用，現(xiàn)在希望對(duì)B系統(tǒng)進(jìn)行限流，例如處理峰值在100，超過(guò)100的請(qǐng)求快速失敗b. 接口作為總閘入口，希望限制所有外來(lái)訪問(wèn)，例如某個(gè)房間只能同時(shí)100個(gè)玩家在線，只有前面的處理完后面的才能繼續(xù)請(qǐng)求c. 其他類型場(chǎng)景，也就是資源固定的情況下需要輪流使用資源的可以采用Semaphore

不適用場(chǎng)景a. 由于是針對(duì)總?cè)肟谶M(jìn)行限流，所以不能根據(jù)IP或者token等進(jìn)行限流，適用場(chǎng)景比較固定b. 后續(xù)的博客中會(huì)介紹如何使用其他的針對(duì)IP/Token級(jí)別的限流，例如AOP+Redis+Lua進(jìn)行限流

優(yōu)點(diǎn)主要有a. 相比針對(duì)IP級(jí)別的限流，Semaphore實(shí)現(xiàn)相對(duì)簡(jiǎn)單，對(duì)上述場(chǎng)景能快速實(shí)現(xiàn)限流效果

實(shí)現(xiàn)難度：3顆星

1.2 核心知識(shí)點(diǎn)

主要使用以下技術(shù)點(diǎn)a. springbootb. juc包中的Semaphore(tryAcquire、release方法)

Semaphore主要說(shuō)明a. Semaphore中可以通過(guò)tryAcquire和acquire獲取到一個(gè)許可證(默認(rèn))，通過(guò)release釋放許可證b. 兩個(gè)獲取許可證的主要區(qū)別就是前者是非阻塞而后者阻塞，如果我們要實(shí)現(xiàn)快速失敗的效果，就必須使用非阻塞獲取許可證方法注意點(diǎn)a. 一定要確保release方法被調(diào)用，例如放到finally中，否則許可證得不到釋放，將會(huì)導(dǎo)致接口被全部陷死，無(wú)法接收請(qǐng)求

二、 環(huán)境搭建

環(huán)境使用idea+spring initializr創(chuàng)建新建springboot web項(xiàng)目

包目錄說(shuō)明

新建SemaphoreController，請(qǐng)求路徑為limita. 注意點(diǎn)已經(jīng)代碼注釋說(shuō)明

package com.codecoord.semaphore.controller;import org.springframework.web.bind.annotation.RequestMapping;import org.springframework.web.bind.annotation.RestController;import java.util.concurrent.Semaphore;/** * 限流側(cè)測(cè)試 * * @author tianxincode@163.com * @since 2020-08-06 */@RestControllerpublic class SemaphoreController { /** * 最大信號(hào)量，例如此處3，生成環(huán)境可以做成可配置項(xiàng)，通過(guò)注入方式進(jìn)行注入 */ private static final int MAX_SEMAPHORE = 3; /** * Semaphore主限流，全局就行 */ private static final Semaphore SEMAPHORE = new Semaphore(MAX_SEMAPHORE); @RequestMapping('/limit') public String limit() {// 01.使用非阻塞tryAcquire，如果獲取不到就快速返回失敗if (!SEMAPHORE.tryAcquire()) { return '請(qǐng)求頻率超過(guò)限制：' + MAX_SEMAPHORE;}// 02. 如果能進(jìn)入到這里，說(shuō)明一定獲取到了許可證/// todo 可能的參數(shù)校驗(yàn)，注意如果參數(shù)校驗(yàn)不通過(guò)，一定要調(diào)用release方法/*if (valid(xxx)) { SEMAPHORE.release();}*/try { // 03. 模擬業(yè)務(wù)處理，假如需要1s Thread.sleep(1000); return '業(yè)務(wù)處理成功';} catch (InterruptedException e) { // 錯(cuò)誤處理 return '業(yè)務(wù)處理失敗';} finally { // 04. 一定要釋放，否則導(dǎo)致接口假死無(wú)法處理請(qǐng)求 SEMAPHORE.release();} }}三、限流演示3.1 并發(fā)請(qǐng)求工具

并發(fā)請(qǐng)求將基于apache-jmeter-5.2.1進(jìn)行測(cè)試，jmeter的使用相對(duì)簡(jiǎn)單，請(qǐng)讀者自行百度

此處線程組的線程數(shù)量為10個(gè)，真實(shí)環(huán)境中根據(jù)需要調(diào)整配置大小

3.2 效果示例圖

啟動(dòng)測(cè)試，可以看到處理成功的只有三個(gè)，剩下7個(gè)全部失敗a. 請(qǐng)求成功

b. 請(qǐng)求失敗

到此這篇關(guān)于Java使用Semaphore對(duì)單接口進(jìn)行限流的文章就介紹到這了,更多相關(guān)Java 單接口限流內(nèi)容請(qǐng)搜索好吧啦網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持好吧啦網(wǎng)！