Cila është praktika më e mirë për të dërguar një kërkesë të thjeshtë HTTP dhe për të marrë përgjigjen e saj me Akka?

Në përgjithësi është një formë e dobët të përdorësh Await në një Future. Zakonisht është e panevojshme, por "ndihet" si metoda e saktë nëse nuk jeni të njohur me të ardhmen.

Pasi një rezultat të vijë si një e ardhme, ju mund ta lini llogaritjen "brenda" të së ardhmes dhe të shtoni më shumë funksionalitet mbi vlerën origjinale.

Duke adresuar drejtpërdrejt pyetjen tuaj, ju mund të përdorni operatorët e së ardhmes në vend të Await për të "marrë përmbajtjen e përgjigjes" (shih përgjigjen e Frederic A. se pse duhet të merrni parasysh transmetimet përpara se të shkoni me zgjidhjen e mëposhtme):

import scala.concurrent.duration._

val responseFuture : Future[HttpResponse] = ??? //same as in question

val responseBody : Future[ByteString] = 
  responseFuture
    .map(_.entity) 
    .flatMap(_.toStrict(10 seconds))
    .map(_.data)

Kjo seri operacionesh mund të kryhet gjithashtu duke përdorur për të kuptuar:

val responseBody : Future[ByteString] = 
  for {
    entity <- responseFuture.entity
    strict <- entity.toStrict(10 seconds)
    body   <- strict.data
  } yield body

Nëse dëshironi të printoni rezultatin kur të jetë gati, atëherë mund të bëni diçka si:

responseBody foreach { body =>
  println s"body: ${body.utf8String}"
}

Edhe një herë, vini re se ne ishim në gjendje të transformonim një HttpResponse në një ByteString dhe të printonim rezultatin pa përdorur Await. Në vend të kësaj, ne përdorëm map, flatMap dhe foreach për të përmbushur detyrën.

Një truk mendor që përdora kur përdora për herë të parë Futures ishte të imagjinoja një të ardhme si një lloj të veçantë Array. Ju nuk mund të zgjidhni elementin nga Array, gjë që bën Await, por mund të përdorni hartën dhe flatMap në grupin special kur dëshironi të operoni me elementin.

Akka http bazohet në transmetimet akka për shumë arsye, njëra që mund t'ju ndihmojë të kuptoni se çfarë po ndodh këtu është kjo: çka nëse kompjuteri në të cilin po ekzekutohet kodi juaj ka vetëm 64 Gb RAM dhe madhësia e përgjigjes HTTP është 784 Tb d.m.th., shumë më tepër se çfarë mund të përshtatet në ram + shkëmbim? Një zgjidhje transmetimi është e vetmja mënyrë për ta kapërcyer këtë, dhe kjo është ajo në të cilën akka http është e shkëlqyer!

Pra, në rastin tuaj, kur responseFuture përfundon, në thelb kjo do të thotë që vetëm titujt e përgjigjes http janë në dispozicion, jo përmbajtja. Mbani mend, përmbajtja mund të jetë e madhe, duhen orë të tëra për t'u shkarkuar, por ju ende mund të prisni që responseFuture të përfundojë në më pak se një sekondë.

Ajo që ju e quani përmbajtje të përgjigjes quhet entitet http. Akka http e ofron atë si një transmetim, por për raste si tuajat, mund të telefononi .toStrict në entitet për ta marrë atë si një grup (të ardhmen e) bajtash dhe jo si një transmetim.

Më në fund nuk është pothuajse kurrë e drejtë të përdoret Await. Më mirë duhet të veproni kur të përfundojë e ardhmja, ose duke përdorur .onComplete/.onSuccess/.onFailure ose duke e krahasuar rezultatin me diçka, mundësisht duke u kombinuar me të ardhme të tjera duke përdorur .map dhe/ose .flatMap.