加特林可变加速

Question

我试着用各种“Rest”和“atOnceUser”进行注射。我在留档上没有找到一个好的解决方案。

我的方法是使用本地计数器创建一个名为“getNextNumber（）”的函数，以增加“atOnceUser”的数量，但该函数一开始只调用一次。

有什么想法吗？

我的代码：

class TestCombinationGetFiles extends Simulation {
    var counter: Int =1 

    def getNextNumber():Int = {
      counter+= 1
      return counter
    }     

  val Get20Files = scenario("get20Files")
   .feed(UuidFeeder.feeder)
   .exec(WebAuth.AuthenticateUser)
   .pause(30)
   .exec(WebCloudContent.GoToTestFolder20)

 val Get10Files = scenario("get10Files").feed(UuidFeeder.feeder)
  .exec(WebAuth.AuthenticateUser)
  .pause(15)
  .exec(WebCloudContent.GoToTestFolder10)

 val loadFolder20TestRamp =            
  scenario("loadFolder20TestRamp").exec(WebAuthSwisscom.AuthenticateUser,             
   WebCloudContentSwisscom.GoToTestFolder20)    

 setUp(Get20Files.inject(
    splitUsers(36) into( 
        atOnceUsers(getNextNumber())) 
        separatedBy(30 seconds)) 

        /* messy Code with correct functionality
        atOnceUsers(1),
        nothingFor(30 seconds),
        atOnceUsers(2),
        nothingFor(30 seconds),
        atOnceUsers(3),
        nothingFor(30 seconds),
        atOnceUsers(4),
        nothingFor(30 seconds),
        atOnceUsers(5),
        nothingFor(30 seconds),
        atOnceUsers(6),
        nothingFor(30 seconds),
        atOnceUsers(7),
        nothingFor(30 seconds),
        atOnceUsers(8),
        nothingFor(30 seconds))
        */
    ,
    Get10Files.inject(
        splitUsers(16) into( 
           atOnceUsers(1)) 
           separatedBy(15 seconds)) 
   ).protocols(WebSetUp.httpProtocol)
}

Answer 1

我想你发现了加特林身上缺失的一个特征！我将进一步开发此功能，并向Gatling团队提交一个pull请求（希望）将其加入到项目中，但与此同时，您可以通过提供自己的自定义InjectionStep实现来获得所需的功能——只需将此粘贴到模拟文件的顶部即可：

import io.gatling.core.controller.inject._
import scala.concurrent.duration._

case class AtOnceIncrementalInjection(users: Int) extends InjectionStep {
  require(users > 0, "The number of users must be a strictly positive value")
  var count = users

  override def chain(chained: Iterator[FiniteDuration]): Iterator[FiniteDuration] = {
    val currentUsers = count
    count += 1
    Iterator.continually(0 milliseconds).take(currentUsers) ++ chained 
  }
}

def atOnceIncrementalUsers(initialUsers:Int) = AtOnceIncrementalInjection(initialUsers)

这基本上就是你试图用atoceusers做的，但关键的区别是计数在chain方法中，这将得到你想要的递增行为，因为每次Gatling决定发送一些请求时，chain都会被调用。

现在，您可以像在ceusers上使用的那样使用helper函数：

splitUsers(36) into( 
    atOnceIncrementalUsers(1)) 
    separatedBy(30 seconds))