为什么这个加特林作业不能顺序运行？

Question

我所试图做的是：

1. 进行GET调用来获得id
2. 对于所有这些ID的列表进行一系列的另一GET来电

这里是我的代码为此：

/** *创建者：pbane3于11/10/16。 */

import io.gatling.core.Predef._ 
import io.gatling.http.Predef._ 
import scala.concurrent.duration._ 
import scala.concurrent.forkjoin.ThreadLocalRandom 
import scala.collection.mutable 
import scala.collection.Map 


class RunWithMePerfTest extends Simulation { 

    var idList = List[String]() 

    var count = 0; 

    def idFeeder(idString:String):Unit = { 
    idList = idString.split(",").map(_.trim).toList; 
    println(idList) 
    } 

    def getRunId() : String = { 
    println(count) 
    var id = idList(count); 
    count = count+1; 
    return id; 
    } 

    object GetAllRunDetails { 

    val getAllRunDetails = exec(http("Get Run Ids") 
     .get("**/**") 
     .check(status in (200 to 209)) 
     // .check(bodyString.saveAs("GetResponse")) 
     .check(jsonPath("$..id").ofType[String].findAll.transform(_.mkString(",")).saveAs("runId"))) 
     .exec(
     session => { 
      var getJson = session.get("GetResponse").asOption[String]; 
      var runId = session.get("runId").asOption[String] 
     // println("Run ID === ") 
     // println(runId.get) 
      idFeeder(runId.get) 
      session 
     } 
    ) 
    } 

    object GetRunIdDetails{ 

    println("Length=" + idList.length) 
    val getRunIdDetails = repeat(idList.length) { 

     exec(http("Getting Run Details") 
     .get(s"****/***" + getRunId()) 
     .check(status in (200 to 209)) 
     .check(bodyString.saveAs("GetRunIdResponse")) 
    ) 
     .exec(
      session => { 
      var getResponse = session.get("GetRunIdResponse").asOption[String]; 
      println("Response from Get" + getResponse.get) 
      session 
      } 
     ) 

    } 
    } 

    val scn = scenario("All run details") 
    .exec(GetAllRunDetails.getAllRunDetails, GetRunIdDetails.getRunIdDetails) 

    setUp(scn.inject(atOnceUsers(1))); 

} 

但这里为什么GetAllRunDetails.getAllRunDetails不GetRunIdDetails.getRunIdDetails之前运行？这是我的idList永远不会被定义。

，我得到的错误是这样的：

Length=0 
0 
Exception in thread "main" java.lang.IndexOutOfBoundsException: 0 
    at scala.collection.LinearSeqOptimized$class.apply(LinearSeqOptimized.scala:65) 
    at scala.collection.immutable.List.apply(List.scala:84) 
    at nike.runwithme.performance.RunWithMePerfTest.getRunId(RunWithMePerfTest.scala:27) 
    at nike.runwithme.performance.RunWithMePerfTest$GetRunIdDetails$.<init>(RunWithMePerfTest.scala:57) 
    at nike.runwithme.performance.RunWithMePerfTest.GetRunIdDetails$lzycompute(RunWithMePerfTest.scala:51) 
    at nike.runwithme.performance.RunWithMePerfTest.GetRunIdDetails(RunWithMePerfTest.scala:51) 
    at nike.runwithme.performance.RunWithMePerfTest.<init>(RunWithMePerfTest.scala:73) 
    at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) 
    at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) 
    at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) 
    at java.lang.reflect.Constructor.newInstance(Constructor.java:423) 
    at java.lang.Class.newInstance(Class.java:442) 
    at io.gatling.app.Gatling$.io$gatling$app$Gatling$$$anonfun$1(Gatling.scala:41) 
    at io.gatling.app.Gatling$lambda$1.apply(Gatling.scala:41) 
    at io.gatling.app.Gatling$lambda$1.apply(Gatling.scala:41) 
    at io.gatling.app.Gatling.run(Gatling.scala:92) 
    at io.gatling.app.Gatling.runIfNecessary(Gatling.scala:75) 
    at io.gatling.app.Gatling.start(Gatling.scala:65) 
    at io.gatling.app.Gatling$.start(Gatling.scala:57) 
    at io.gatling.app.Gatling$.fromArgs(Gatling.scala:49) 
    at io.gatling.app.Gatling$.main(Gatling.scala:43) 
    at io.gatling.app.Gatling.main(Gatling.scala) 

Answer 1

所以这里是适合我的答案。几乎相同的代码，但在第二种情况下添加了session。有道理，因为一切都加入到session：

/** 
    * Created by pbane3 on 11/10/16. 
    * 
    * The First test gets the Run Id's 
    * 
    * Then it creates a a List of all the RunIDs 
    * 
    * After that loops through each of the RunIDs 
    * and makes a GET call for each of them 
    */ 

import io.gatling.core.Predef._ 
import io.gatling.http.Predef._ 
import scala.concurrent.duration._ 
import scala.concurrent.forkjoin.ThreadLocalRandom 
import scala.collection.mutable 
import scala.collection.Map 
import java.io.File 
import java.io.PrintWriter 



class RunWithMePerfTest extends Simulation { 

    //this is used to store the list of the runIds 
    var idList = List[String]() 

    var count = 0; 

    //used to build the list and feed to the session 
    def idFeeder(idString:String):Unit = { 
    idList = idString.split(",").map(_.trim).toList; 
    println(idList) 
    } 

    //used to access the list and feed to the session 
    def getRunId() : String = { 
    println(count) 
    var id = idList(count); 
    count = count+1; 
    return id; 
    } 

    //makes the initial call to get all the run IDs 
    object GetAllRunDetails { 
    println("I come in scn1") 
    val getAllRunDetails = exec(http("Get Run Ids") 
     .get("https://someUrl") 
     .check(status in (200 to 209)) 
     // .check(bodyString.saveAs("GetResponse")) 
     .check(jsonPath("$..id").ofType[String].findAll.transform(_.mkString(",")).saveAs("runId"))) 
     .exec(
     session => { 
      var getJson = session.get("GetResponse").asOption[String]; 
      var runId = session.get("runId").asOption[String] 

      idFeeder(runId.get) 
      session 
     } 
    ) 
    } 

    //makes one get call for each of the run ids obtained from the last get call 
    object GetRunIdDetails{ 
    val getRunIdDetails = repeat(session=>idList.length) { 
     exec(http("Getting Run Details") 
     .get(session => (s"https://someUrl" + getRunId())) 
     .check(status in (200 to 209)) 
     .check(bodyString.saveAs("GetRunIdResponse")) 
    ) 
     .exec(
      session => { 
      var getResponse = session.get("GetRunIdResponse").asOption[String]; 
      println("Response from Get:") 
      println(getResponse.get) 
      session 
      } 
     ) 
    } 
    } 

    val scn1 = scenario("All run details") 
    .exec(GetAllRunDetails.getAllRunDetails) 

    val scn2 = scenario("All run ID Details") 
    .exec(GetRunIdDetails.getRunIdDetails) 


    setUp(scn1.inject(atOnceUsers(1)),scn2.inject(nothingFor(10 seconds),atOnceUsers(1))); 

} 

Answer 2

您可以链的情况下按顺序运行。尝试创建两个场景，然后将它们链接起来。

scn1 = scenario("Get All run details") 
    .exec(GetAllRunDetails.getAllRunDetails) 

scn2 = scenario("bla").exec(GetRunIdDetails.getRunIdDetails) 

seqScenario = scn1.exec(scn2) 

添加到答案： exec在运行之前被初始化。当你调用.get（s“****/***”+ getRunId（））方法时，idList中没有数据，所以你的运行在它开始之前就会失败。您可以添加另一个将数据放入会话中的exec，然后才能在您的获取调用中使用它。