From c47fd6985914864cf05df8ec42eb6934617e0957 Mon Sep 17 00:00:00 2001 From: tjq Date: Sun, 15 Jan 2023 22:58:44 +0800 Subject: [PATCH] test: use gatling to test remote framework performance --- .../remote/benchmark/HttpSimulation.java | 21 ++++++++++++++----- 1 file changed, 16 insertions(+), 5 deletions(-) diff --git a/powerjob-remote/powerjob-remote-benchmark/src/test/java/tech/powerjob/remote/benchmark/HttpSimulation.java b/powerjob-remote/powerjob-remote-benchmark/src/test/java/tech/powerjob/remote/benchmark/HttpSimulation.java index cdc1bf7f..00b1a8b4 100644 --- a/powerjob-remote/powerjob-remote-benchmark/src/test/java/tech/powerjob/remote/benchmark/HttpSimulation.java +++ b/powerjob-remote/powerjob-remote-benchmark/src/test/java/tech/powerjob/remote/benchmark/HttpSimulation.java @@ -22,15 +22,22 @@ public class HttpSimulation extends Simulation { .acceptEncodingHeader("gzip, deflate") .userAgentHeader("Mozilla/5.0 (Windows NT 5.1; rv:31.0) Gecko/20100101 Firefox/31.0"); + ScenarioBuilder warmup = scenario("WarmupSimulation") + .exec(http("PowerJob-Warmup-HTTP") + .get("/pressure/ask?protocol=HTTP&debug=false&responseSize=1024")) + .exec(http("PowerJob-Warmup-AKKA") + .get("/pressure/ask?protocol=AKKA&debug=false&responseSize=1024")) + ; + ScenarioBuilder httpAsk = scenario("HttpSimulation") // 7 .exec(http("PowerJob-Remote-Http") // 请求名称，用于压测报表展示 .get("/pressure/ask?protocol=HTTP&debug=false&responseSize=1024")) // 9 - .pause(5); // 10 + ; ScenarioBuilder akkaAsk = scenario("AkkaSimulation") // 7 .exec(http("PowerJob-Remote-AKKA") // 请求名称，用于压测报表展示 .get("/pressure/ask?protocol=AKKA&debug=false&responseSize=1024")) // 9 - .pause(5); // 10 + ; /* @@ -43,9 +50,13 @@ public class HttpSimulation extends Simulation { { setUp( // 11 - httpAsk.injectOpen(incrementUsersPerSec(10.0).times(2).eachLevelLasting(10)).andThen( - akkaAsk.injectOpen(incrementUsersPerSec(10.0).times(2).eachLevelLasting(10)) - ) // 12 + warmup.injectOpen(constantUsersPerSec(50).during(10)) + .andThen( + httpAsk.injectOpen(incrementUsersPerSec(100).times(10).eachLevelLasting(10)) + ) + .andThen( + akkaAsk.injectOpen(incrementUsersPerSec(100).times(10).eachLevelLasting(10)) + ) ).protocols(httpProtocol); // 13 } }