gatling updates - two simulations, run all simulations from mvn, separate scenario class

Author: Ganesh Tiwari

load-tester/pom.xml

@@ -46,6 +46,13 @@
                 <groupId>io.gatling</groupId>
                 <artifactId>gatling-maven-plugin</artifactId>
                 <version>${gatling-maven-plugin.version}</version>
+                <configuration>
+                    <runMultipleSimulations>true</runMultipleSimulations>
+                    <includes>
+                        <include>gt.simulations.*</include>
+                    </includes>
+                </configuration>
+
             </plugin>
 
             <plugin>

load-tester/readme.md

@@ -0,0 +1,7 @@
+# Run single simulation:
+- Use Engine class to run individual simulation
+- Use `mvn gatling:test -Dgatling.simulationClass=gt.simulations.THE_SIMULATION_CLASS` to run specified simulation
+
+# Run all simulations
+- Use `mvn gatling:test` 
+

load-tester/src/test/resources/gatling.conf

@@ -92,7 +92,7 @@ gatling {
     #warmUpUrl = "https://gatling.io"          # The URL to use to warm-up the HTTP stack (blank means disabled)
     #enableGA = true                           # Very light Google Analytics (Gatling and Java version), please support
     #pooledConnectionIdleTimeout = 60000       # Timeout in millis for a connection to stay idle in the pool
-    #requestTimeout = 60000                    # Timeout in millis for performing an HTTP request
+    requestTimeout = 1500                      # Timeout in millis for performing an HTTP request
     #enableHostnameVerification = false        # When set to true, enable hostname verification: SSLEngine.setHttpsEndpointIdentificationAlgorithm("HTTPS")
     dns {
       #queryTimeout = 5000                     # Timeout in millis of each DNS query in millis

load-tester/src/test/scala/Engine.scala

@@ -1,4 +1,5 @@
-import gt.simulations.PublicUserSimulation
+//import gt.simulations.PublicUserSimulation
+
 import io.gatling.app.Gatling
 import io.gatling.core.config.GatlingPropertiesBuilder
 
@@ -8,7 +9,15 @@ object Engine extends App {
         .resourcesDirectory(IDEPathHelper.mavenResourcesDirectory.toString)
         .resultsDirectory(IDEPathHelper.resultsDirectory.toString)
         .binariesDirectory(IDEPathHelper.mavenBinariesDirectory.toString)
-        .simulationClass(classOf[PublicUserSimulation].getName)//
+
+    /*
+    uncomment and put the simulation that you want to run
+
+    Or run mvn gatling:test to run all tests
+        runMultipleSimulations is true
+     */
+
+    //.simulationClass(classOf[PublicUserSimulation].getName)//
 
     Gatling.fromMap(props.build)
 }

load-tester/src/test/scala/gt/scenarios/ArticleScenario.scala

@@ -0,0 +1,15 @@
+package gt.scenarios
+
+import io.gatling.core.Predef._
+import io.gatling.http.Predef._
+import io.gatling.http.request.builder.HttpRequestBuilder
+
+object ArticleScenario {
+
+    def readArticle(id: Int): HttpRequestBuilder = {
+        http("read article #" + id)
+            .get("/article/read/" + id)
+    }
+
+    //other methods
+}

load-tester/src/test/scala/gt/scenarios/HomePageScenario.scala

@@ -0,0 +1,22 @@
+package gt.scenarios
+
+import gt.Environment
+import io.gatling.core.Predef._
+import io.gatling.http.Predef._
+import io.gatling.http.request.builder.HttpRequestBuilder
+
+object HomePageScenario {
+
+    def homePage(): HttpRequestBuilder = {
+        http("public home page")
+            .get(Environment.publicHomePage)
+    }
+
+    def openPage(page: Int): HttpRequestBuilder = {
+        http("open page " + page)
+            .get("/?size=5&page=" + (page - 1))
+    }
+
+    //other methods
+
+}

load-tester/src/test/scala/gt/simulations/BaseSimulation.scala

@@ -1,33 +1,25 @@
 package gt.simulations
 
 import gt.Environment
+import gt.scenarios.{ArticleScenario, HomePageScenario}
 import io.gatling.core.Predef._
 import io.gatling.http.Predef._
-import io.gatling.http.request.builder.HttpRequestBuilder
+import io.gatling.http.protocol.HttpProtocolBuilder
 
 import scala.concurrent.duration.DurationInt
 
-class PublicUserSimulation extends BaseSimulation {
+class PublicUserSimulation extends Simulation {
 
-    def openPage(page: Int): HttpRequestBuilder = {
-        http("open page " + page)
-            .get("/?size=5&page=" + (page - 1))
-    }
-
-    def readArticle(id: Int): HttpRequestBuilder = {
-        http("read article #" + id)
-            .get("/article/read/" + id)
-    }
+    val httpConfig: HttpProtocolBuilder = http.baseUrl(Environment.baseUrl)
 
     //scenario
-    val scn = scenario("Open Public Home Page")
-        .exec(http("public home page")
-            .get(Environment.publicHomePage))
-        .exec(readArticle(68))
-        .exec(readArticle(67))
-        .exec(readArticle(66))
-        .exec(openPage(2))
-        .exec(openPage(3))
+    val scn = scenario("open public home page read article and navigate to other pages")
+        .exec(HomePageScenario.homePage())
+        .exec(ArticleScenario.readArticle(68))
+        .exec(ArticleScenario.readArticle(67))
+        .exec(ArticleScenario.readArticle(66))
+        .exec(HomePageScenario.openPage(2))
+        .exec(HomePageScenario.openPage(3))
 
     before {
         //data prep
@@ -38,7 +30,7 @@ class PublicUserSimulation extends BaseSimulation {
             //load scenario
             nothingFor(1 seconds),
             atOnceUsers(5),
-            rampUsers(Environment.maxUsers) during (Environment.rampUpTime)
+            rampUsers(Environment.maxUsers) during Environment.rampUpTime
         ).protocols(httpConfig.inferHtmlResources()) // inferHtmlResources will fetch everything on the page (JS, CSS, images etc.)
     )
 

load-tester/src/test/scala/gt/simulations/PublicUserSimulation.scala

@@ -0,0 +1,23 @@
+package gt.simulations
+
+import io.gatling.core.Predef._
+import io.gatling.http.Predef._
+
+import scala.concurrent.duration.DurationInt
+
+class TestSimulation extends Simulation {
+
+    val httpProtocol = http
+        .baseUrl("http://computer-database.gatling.io") // Here is the root for all relative URLs
+
+    val scn = scenario("Scenario Name")
+        .exec(http("get req").get("/"))
+
+    setUp(
+        scn.inject(
+            nothingFor(1.seconds),
+            atOnceUsers(2),
+        ).protocols(httpProtocol)
+    )
+
+}