模擬併發的 4 種方式，還有誰不會？？

一、Postman Postman 是一個款 HTTP 請求模擬工具首先演示一下 Postman 最基本的使用，創建一個 Spring Boot 項目，測試的代碼如下： import org.springframework.web.bind.annotation.GetMapping; impor ...

一、Postman

Postman 是一個款 HTTP 請求模擬工具

首先演示一下 Postman 最基本的使用，創建一個 Spring Boot 項目，測試的代碼如下：

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("test")
public class TestConrtoller {

    @GetMapping("demo")
    public String testDemo() {
        return "result~";
    }
}

為了便於操作，一般會將

http://127.0.0.1:8080 是經常使用的地址+埠號，可以設置為環境，點擊右上角的設置圖標

選擇 global

輸入信息

以後再進行測試就能這樣搞簡寫了

知道基本使用之後，我們來看一下如何模擬併發測試

填寫基本信息後，創建：

這個時候會創建出Concurrency的文件夾，我們可以把剛纔測試的demo的例子放進這個文件夾下：

這個時候就可以在Concurrency下看到這個介面測試了

選擇併發測試：

這個時候彈出我們想要的框了

點擊 Run Concurrency

你可以立馬感覺到 CPU 在“燃燒”，因為要記錄並列印日誌，顯示的話是一條一條來的，其實測試的速度，要比你看到的列印的日誌的速度快，綠色表示正常

二、Apache Bench（AB）

ApacheBench 是 Apache 伺服器自帶的一個web壓力測試工具，簡稱ab。

ab又是一個命令行工具，對發起負載的本機要求很低，根據ab命令可以創建很多的併發訪問線程，模擬多個訪問者同時對某一URL地址進行訪問，因此可以用來測試目標伺服器的負載壓力。總的來說ab工具小巧簡單，上手學習較快，可以提供需要的基本性能指標，但是沒有圖形化結果，不能監控。

使用的話，首先需要安裝 Apache 伺服器

網站：傳送門 http://httpd.apache.org/download.cgi

因為我的操作系統是 windows10，這裡選擇 File for Microsoft Windows

Linux下的安裝是非常簡單的，這裡不再演示

選擇 ApacheHaus

進入下載頁面選擇適合自己電腦的版本

文件解壓到本地文件夾下，如果不是解壓在c盤，需要設置參數，註意文件路徑最好都是英文，關於需要設置參數，conf->httpd.conf 使用文本編輯器打開，需要修改的有三個地方：

運行根目錄，修改成自己解壓到本地的路徑

監聽埠，預設監聽埠是80，如果已被使用會報錯需要修改，如果80埠未被使用，可不修改；如果修改了監聽埠，則需要把ServerName localhost也相應改成同樣的端口號

DocumentRoot 測試文件存放地，且該目錄必須存在

配置完成後，命令行cmd進入 D:\softUtil\Apache24\bin 目錄下

httpd.exe -k install

啟動：

httpd.exe -k start

測試:

-n :請求數
-c: 併發數

三、併發模擬工具JMeter

JMeter也是一款性能測試工具，是圖形化的。下載地址：傳送門 http://jmeter.apache.org/

需要 Java8+ 的環境

解壓到你覺得合適的目錄下（註意最好是英文路徑），進入它的 bin 目錄下啟動 jmeter.bat 即可。

使用很簡單，首先在測試計劃部分新建一個線程組

設置好基礎信息後添加HTTP請求（基本信息設置好沒有OK哈，直接添加HTTP請求）

填寫HTTP請求相關的內容

之後還要添加監聽器，這裡選擇是圖形結果

再添加一個查看結果樹吧

在運行之前打開log Viewer

下麵開始運行：

執行成功，來感受一下結果：

點進去

查看結果樹

四、代碼模擬

這裡需要用到一個類，就是 CountDownLatch。CountDownLatch 是一個計數器閉鎖，通過它可以完成類似於阻塞當前線程的功能，即：一個線程或多個線程一直等待，直到其他線程執行的操作完成。

更多多線程教程可以參考：https://www.javastack.cn/categories/Java/

CountDownLatch 用一個給定的計數器來初始化，該計數器的操作是原子操作，即同時只能有一個線程去操作該計數器。調用該類await方法的線程會一直處於阻塞狀態，直到其他線程調用 countDown 方法使當前計數器的值變為零，每次調用 countDown 計數器的值減1。

當計數器值減至零時，所有因調用await()方法而處於等待狀態的線程就會繼續往下執行。這種現象只會出現一次，因為計數器不能被重置。下圖和它的方法可以體現出來：

CountDownLatch類只提供了一個構造器：

public CountDownLatch(int count) { };

然後下麵這 3 個方法是 CountDownLatch 類中最重要的方法(上圖能夠反映出來）

public void await() throws InterruptedException { };
public boolean await(long timeout, TimeUnit unit) throws InterruptedException { };
public void countDown() { };

下麵還需要看一個類 Semaphore

Semaphore 與 CountDownLatch 相似，不同的地方在於 Semaphore 的值被獲取到後是可以釋放的，並不像 CountDownLatch 那樣一直減到底。

它也被更多地用來限制流量，類似閥門的功能。如果限定某些資源最多有N個線程可以訪問，那麼超過N個主不允許再有線程來訪問，同時當現有線程結束後，就會釋放，然後允許新的線程進來。有點類似於鎖的lock與 unlock過程。相對來說他也有兩個主要的方法：

用於獲取許可權的acquire(),其底層實現與CountDownLatch.countdown()類似;用於釋放許可權的release()，其底層實現與acquire()是一個互逆的過程。

通過這兩個類可以進行併發的模擬：

測試一下：

import lombok.extern.slf4j.Slf4j;
import java.util.concurrent.*;

@Slf4j
public class CuncurrencyTest {

    public static int clientTotal = 5000;
    public static int threadTotal = 200;
    public static int count = 0;
    public static void main(String[] args) throws InterruptedException {

        ExecutorService executorService = Executors.newCachedThreadPool();

        final Semaphore semaphore = new Semaphore(threadTotal);
        final CountDownLatch countDownLatch = new CountDownLatch(clientTotal);

        for (int i = 0; i < clientTotal; i++) {
            executorService.execute(() -> {
                try {
                    semaphore.acquire();
                    add();
                    semaphore.release();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                    log.error("exception",e);
                }
                countDownLatch.countDown();
            });
        }
        countDownLatch.await();
        executorService.shutdown();
        log.info("count:{}",count);

    }

    private static void  add() {
        count++;
    }
}

因為 count 不是線程安全的，且沒有作防護措施，結果是錯的

上面是對代碼的併發模擬的簡單形式，值得註意的是，這裡提到的兩個類不是專門做併發模擬，它們的用途很廣泛，等之後更新Java網路編程的東西的時候，還會詳細介紹它們。