下单延迟10s撤单性能测试

我曾经天真以为，性能测试场景我已经无敌了，可现实又轻轻拍了我一下。

研发提出了一个下单之后延迟10s撤单的压测需求，着实让我迷糊了一会儿，最后参考了Java的延迟队列java.util.concurrent.DelayQueue实现了这个需求。

需求

在某个场景中，我之前的设计是下单，成功的话撤单，原因是为了避免测试用户资产被耗尽。

最近研发对服务功能逻辑进行了优化，在回归测试中，发现这个用例测试结果与之前差异较大。研发判断可能是下单、撤单间隔时间较短导致问题。所以需要进行延迟撤单的压测。

思路
这里使用了java.util.concurrent.DelayQueue这个线程安全队列类，看名字其实也能明白用途。还有一个方案java.util.Timer，但是会创建额外的线程，而且难以控制撤单的速率，所以这次就放弃了。

首先每次下单时候，如果成功会把订单号通过一个java.util.concurrent.Delayed实现类记录到java.util.concurrent.DelayQueue队列中，然后在com.oktest.okex.algo.trade.OrderAndCancelGrid3.FunTester#doing方法中从延迟队列中获取到期的订单号，然后进行撤单操作。

下面是delayQueue功能演示视频截图

实现

订单ID是java.lang.String类型，java.util.concurrent.Delayed实现类如下：

private static class FunDelay implements Delayed {

    int time

    String id

    FunDelay(String id) {
        this.time = getMark() + delay
        this.id = id
    }

    @Override
    public long getDelay(TimeUnit unit) {
        return time - getMark();
    }

    @Override
    public int compareTo(Delayed o) {
        FunDelay item = (FunDelay) o;
        if (this.time < item.time) {
            return -1;
        } else {
            return 1;
        }
    }
}

测试用例

大部分内容复用了之前的设计，重写了after方法，处理用户结束测试之后，延迟队列中尚未处理的订单ID。

private static class FunTester extends FixedThread {

    DelayQueue ids = new DelayQueue<>()


    FunTester(Trade o, int limit) {
        super(o, limit, true)
    }

    @Override
    protected void doing() throws Exception {
        def res = f.order(********)
        if (0 == res.getInteger("code")) {
            def array = res.getJSONArray("data").get(0)
            def id = array.getString("Id")
            ids.add(new FunDelay(id))
        } else {
            output(res.toString())
        }
        int i = 0
        while (true) {
            if (i++ > 10) break
            def poll = ids.poll()
            if (poll == null) break
            f.stop("***", poll.id)
        }
    }

    @Override
    protected void after() {
        super.after()
        sleep(1.0)
        f.clearGrid()
    }

    @Override
    Threadbase clone() {
        return new FunTester(f, limit)
    }


}

执行

执行方法依旧复用之前的内容，添加第4个参数，来参数化延迟的时间。

static int delay;

public static void main(String[] args) {
    ClientManage.init(10, 5, 0, "", 0)
    def util = new ArgsUtil(args)
    def thread = util.getIntOrdefault(0, 1)
    def times = util.getIntOrdefault(1, 1000)
    def runuptime = util.getIntOrdefault(2, 0)
    delay = util.getIntOrdefault(3, 3)
    Constant.RUNUP_TIME = runuptime
    Common.PRINT_RESPonSE = false
    Common.VERIFY = false
    FunLibrary.LOG_KEY = false
    Common.MOCO = true
    Common.setHost()
    def line = DataUtils.getMocoTokens()
    def tasks = []
    thread.times {
        def base = getbase(line.get(getRandomInt(500)))
        def drive = new Trade(base)
        tasks << new FunTester(drive, times)
    }

    new Concurrent(tasks, "下单和延迟10s撤单").start()

    over()
}

测试结果

我使用了默认延迟3s的参数。下面是执行过程中的日志截图：

下单延迟10s撤单测试结果

图中可以看到，17s开始下单，20s开始撤单。需求完美实现！

下面是一份配套资料，对于做【软件测试】的朋友来说应该是最全面最完整的备战仓库，这个仓库也陪伴我走过了最艰难的路程，希望也能帮助到你！

这些都可以以在公众号：伤心的辣条！免费领取，还有一份216页软件测试工程师面试宝典文档资料。以及相对应的视频学习教程免费分享！，其中资料包括了有基础知识、Linux必备、Shell、互联网程序原理、Mysql数据库、抓包工具专题、接口测试工具、测试进阶-Python编程、Web自动化测试、APP自动化测试、接口自动化测试、测试高级持续集成、测试架构开发测试框架、性能测试、安全测试等。

学习不要孤军奋战，最好是能抱团取暖，相互成就一起成长，群众效应的效果是非常强大的，大家一起学习，一起打卡，会更有学习动力，也更能坚持下去。你可以加入我们的测试技术交流扣扣群：914172719（里面有各种软件测试资源和技术讨论）

喜欢软件测试的小伙伴们，如果我的博客对你有帮助、如果你喜欢我的博客内容，请 “点赞” “评论” “收藏” 一键三连哦！

好文推荐

转行面试，跳槽面试，软件测试人员都必须知道的这几种面试技巧！

面试经：一线城市搬砖！又面软件测试岗，5000就知足了…

面试官：工作三年，还来面初级测试？恐怕你的软件测试工程师的头衔要加双引号…

什么样的人适合从事软件测试工作？

那个准点下班的人，比我先升职了…

测试岗反复跳槽，跳着跳着就跳没了…

下单延迟10s撤单性能测试

Java相关栏目本月热门文章