并发模拟的四种方式 + 工具，超级实用！

来源：chenxiao.blog.csdn.net/article/details/102736170

一、Postman

Postman是一个款http请求模拟工具

创建一个Springboot项目，测试的代码如下：

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 是经常使用的地址+端口号，可以设置为环境

点击右上角的设置图标

以后再进行测试就能这样搞简写了，搜索公众号互联网架构师回复“2T”，送你一份惊喜礼包。

知道基本使用之后,我们来看一下如何模拟并发测试

填写基本信息后，创建

这个时候会创建出Concurrency的文件夹，我们可以把刚才测试的demo的例子放进这个文件夹下

选择并发测试：

这个时候弹出我们想要的框了

点击Run Concurrency

你可以立马感觉到CPU在“燃烧”，因为要记录并打印日志，显示的话是一条一条来的，其实测试的速度，要比你看到的打印的日志的速度快，绿色表示正常

二、Apache Bench（AB）

Linux下的安装是非常简单的，这里不再演示

选择 ApacheHaus

进入下载页面 选择适合自己电脑的版本

文件解压到本地文件夹下，如果不是解压在c盘，需要设置参数，注意文件路径最好都是英文搜索公众号互联网架构师回复“2T”，送你一份惊喜礼包。

运行根目录，修改成自己解压到本地的路径

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请求相关的内容

之后还要添加监听器，这里选择是图形结果，搜索公众号互联网架构师回复“2T”，送你一份惊喜礼包。

再添加一个查看结果树吧

在运行之前打开log Viewer

下面开始运行：

点进去

查看结果树

四、代码模拟

CountDownLatch类只提供了一个构造器：

public CountDownLatch(int count) {  };  //参数count为计数值

然后下面这3个方法是CountDownLatch类中最重要的方法(上图能够反映出来）

public void await() throws InterruptedException { };   //调用await()方法的线程会被挂起，它会等待直到count值为0才继续执行
public boolean await(long timeout, TimeUnit unit) throws InterruptedException { };  //和await()类似，只不过等待一定的时间后count值还没变为0的话就会继续执行
public void countDown() { };  //将count值减1

它也被更多地用来限制流量，类似阀门的 功能。如果限定某些资源最多有N个线程可以访问，那么超过N个主不允许再有线程来访问，同时当现有线程结束后，就会释放，然后允许新的线程进来。有点类似于锁的lock与 unlock过程。相对来说他也有两个主要的方法：

• 用于获取权限的acquire(),其底层实现与CountDownLatch.countdown()类似;

• 搜索公众号互联网架构师回复“2T”，送你一份惊喜礼包。
  

• 用于释放权限的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不是线程安全的，且没有作防护措施，结果是错的