接口并发测试

2023年2月18日 61次阅读 来源: ghc_2018

        这段时间一直在走流程测试，今天大哥过来，让他看了下我的代码还有点问题，回头还要修改下以前购买商品的帖子，今天先说下接口的并发测试吧，以前都是用Jmeter来做并发测试，今天本来也打算用来着，大哥说那个太麻烦了直接用JUnit提供的ContiPerf，就有了今天的帖子嘿嘿！

需要先导入一个pom文件

<dependency>
            <groupId>org.databene</groupId>
            <artifactId>contiperf</artifactId>
            <version>2.3.4</version>
        </dependency>

然后直接在springboot的Test类里 contextLoads 方法上添加 @PerfTest 注解，想这样

《接口并发测试》

    @Test
    @PerfTest(threads = 50, duration = 30000)
    void contextLoads() {
        
    }

@PerfTest后面的参数是50个线程，30秒执行完，更多参数如下

@Documented
@Target({ElementType.METHOD, ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
public @interface PerfTest {
    int invocations() default 1;

    int duration() default -1;

    int threads() default 1;

    int rampUp() default 0;

    int warmUp() default 0;

    boolean cancelOnViolation() default false;

    Class<? extends WaitTimer> timer() default None.class;

    double[] timerParams() default {};

    Class<? extends Clock>[] clocks() default {};
}

完整代码

    private static String url = "http://localhost:8080/order/";

    @Rule
    public ContiPerfRule i = new ContiPerfRule();
    static int succss = 0;
    static int fail = 0;

    /**
     * 并发测试
     */
    @Test
    @PerfTest(threads = 50, duration = 30000)
    void contextLoads() {
        try {
            Snowflake sf = new Snowflake(2, 5, true);
            String userId = sf.nextIdStr().substring(11, 19);
            String planNo = "954410189564411904";
            JSONObject msg = new JSONObject();
            msg.put("userId", userId);
            msg.put("planNo", planNo);
            sendParam(msg, "接口地址");

            succss++;
            System.out.println("================================");
        } catch (Exception e) {
            fail++;
        } finally {
            System.err.println(Thread.currentThread().getId() + "===success=" + succss + "   fail=" + fail);
        }

    }

    protected void sendParam(JSONObject msg, String addr) {
        String request = JSON.toJSONString(msg);
        log.info("request=={}", request);

        String response = HttpUtil.post(url + addr, request);
        log.info("response=={}", response);
    }

HttpUtil.post()，用的是hutool的，可以自己去导入。

这里需要注意下，我用的spring-boot-starter-test是2.3.6.RELEASE 版本的，版本太高了可以能不能使用@Rule注解。

    原文作者：ghc_2018
    原文地址: https://blog.csdn.net/gaohechao/article/details/123593252
    本文转自网络文章，转载此文章仅为分享知识，如有侵权，请联系博主进行删除。
点赞