Lokhu okuthunyelwe kuchaza ukuthi ungakwenza kanjani ubuqiniso be-Oauth2 ngeGatling.
Kulesi sibonelo, sithumela isicelo sokwakha umsebenzisi. Noma kunjalo, indawo yokugcina yomsebenzisi ivikelwe futhi idinga i-access_token.
Okokuqala, sizothola i- bearer_token noma i- access_token bese siyithumela njengekhanda esicelweni esilandelayo se-API sokwenza umsebenzisi.
Ukucacisa lokhu, sizosebenzisa isakhiwo sephrojekthi efanayo seGatling esakhe ngaphambili:
Uhlaka Lokuhlola Ukusebenza ngeGatling neMaven
Lapho silandela izinyathelo kokuthunyelwe okungenhla, sizoba nokwakheka kwephrojekthi yethu ngokulandelayo:
Okokuqala sichaza imingcele yethu ye-OAuth 2.0 | Configuration.scala
object ngaphansi kwe- i-config ifolda:
object Configuration { val environment: String = System.getProperty('environment') val clientId: String = System.getProperty('CLIENT_ID') val clientSecret: String = System.getProperty('CLIENT_SECRET') val apiURL: String = 'https://some-sub-domain.' + environment + 'some-domain.com/api' var tokenPath: String = 'https://some-sub-domain' + environment + '.eu.auth0.com/oauth/token' val userPath = '/identity/iaa/v1/users' }
Qaphela:Imvamisa, imvelo, i-client_id kanye ne-client_secrets zithunyelwa emshinini izivivinyo ezizobe zisebenza, ngakho-ke singasebenzisa Uhlelo.getProperty () ukufunda amanani.Manje sidinga ukubhala ikhodi ethumela isicelo kuseva yokugunyazwa ukuthola ithokheni.
Leli fayela AuthRequest.scala
igcinwa ngaphansi kwe- izicelo ifolda esakhiweni sephrojekthi yethu.
import java.io.{BufferedWriter, FileWriter} import config.Configuration import io.gatling.core.Predef._ import io.gatling.http.Predef._ object AuthRequest { val getAccessToken = exec(http('Get access token')
.post(Configuration.tokenPath)
.body(StringBody(
s'''{
'client_id': '${Configuration.clientId}',
'client_secret': '${Configuration.clientSecret}',
'audience': 'https://some-domain-name.com/user',
'grant_type': 'client_credentials',
'scope': 'user:admin'
}'''
))
.asJson
.headers(Map('Content-Type' -> 'application/json'))
.check(status.is(200))
.check(jsonPath('$.access_token').saveAs('access_token')))
.exec {
session =>
val fw = new BufferedWriter(new FileWriter('access_token.txt', true))
try {
fw.write(session('access_token').as[String] + '
')
}
finally fw.close()
session
} }
Kumazwibela ekhodi engenhla, futhi sigcina i-access_token kufayela.
Ucingo olungenhla, luthola nje ithokheni yokungena.
Sidinga esinye isicelo sokwenza umsebenzisi ngokuthumela ithokheni lokungena njengesihloko.
Isicelo sethu somsebenzisi sisefayeleni elibizwa UserRequests.scala
futhi igcinwa ngaphansi kwe- izicelo ifolda.
import config.Configuration.{apiURL, userPath} import io.gatling.core.Predef._ import io.gatling.http.Predef._ object UserRequests { private val auth0Headers = Map(
'Accept' -> 'application/json, text/javascript, */*; q=0.01',
'Content-Type' -> 'application/json',
'Authorization' -> 'Bearer ${access_token}') val createUser = exec(http('Create user')
.post(apiURL + userPath)
.headers(auth0Headers)
.body(ElFileBody('createUser.json'))
.check(status.is(201))) }
Manje sibhala into yesimo. Kulesi sibonelo into yethu ibizwa UserScenarios.scala
futhi igcinwa ngaphansi kwe- isimo ifolda.
import requests.{AuthRequest, UserRequests} import io.gatling.core.Predef._ object UserScenarios { var userIds:Array[Map[String,String]] =
(100 to 900).toArray map ( x => { Map( 'userId' -> x.toString) }) val getAccessToken = scenario('Get token')
.exec(AuthRequest.getAccessToken) val createUserScenario = scenario('Create user')
.feed(userIds.circular)
.exec(UserAuthZRequest.getAccessToken)
.exec(UserRequests.createUser) }
Isicelo esingenhla, sithumela isicelo se-POST sokwakha umsebenzisi nge-access_token njengomthwali kunhlokweni.
Ekugcineni ifayela lethu lokulingisa libizwe UserSimulation.scala
igcinwa ngaphansi kwe- ukulingisa ifolda.
import scenario.UserScenarios import io.gatling.core.Predef._ import scala.concurrent.duration._ class UserSimulation extends Simulation { setUp(
UserScenarios.createUserScenario.inject(rampUsers(250) during (15 minutes)), ) }
Ukwenza izivivinyo esizisebenzisayo
mvn clean gatling:test