Отправить запрос через регулярные промежутки времени - PullRequest
Новая
       9

Отправить запрос через регулярные промежутки времени

0 голосов
/ 06 июня 2018

Здравствуйте, я пытаюсь выучить akka-http и сделать простой клиент для API отдыха.Я хотел бы знать, как отправлять запрос на сервер отдыха с регулярными интервалами.

У меня есть простой клиент: 

object RestClientApp extends App {
  // set up ActorSystem and other dependencies here
  //#main-class
  //#server-bootstrapping
  implicit val system: ActorSystem = ActorSystem()
  implicit val materializer: ActorMaterializer = ActorMaterializer()
  //#server-bootstrapping

  // needed for the future flatMap/onComplete in the end
  implicit val executionContext = system.dispatcher

  val responseFuture: Future[HttpResponse] = Http().singleRequest(HttpRequest(uri = "http://akka.io"))

  responseFuture
    .onComplete {
      case Success(res) => println(res)
      case Failure(_) => sys.error("something wrong")
    }
}

Как я могу отправлять запрос и обрабатывать ответ каждыйх единица времени?

Ответы [ 2 ]

0 голосов
/ 06 июня 2018

вы можете определить RestClient как актера и использовать actorSystem.schedule для планирования актера. 

  final def schedule(
    initialDelay: FiniteDuration,
    interval:     FiniteDuration,
    receiver:     ActorRef,
    message:      Any)(implicit
    executor: ExecutionContext,
                       sender: ActorRef = Actor.noSender): Cancellable =

Пример, 

import akka.actor.{Actor, ActorSystem, Props}

class RestClientActor extends Actor {
  import RestClientActor._
  import scala.util.Success
  import scala.util.Failure
  import akka.http.scaladsl.Http
  import akka.http.scaladsl.model.HttpRequest

  implicit val actorSystem: ActorSystem = context.system
  import context.dispatcher

  override def receive: Receive = {
    case InitiateRequest =>
      Http().singleRequest(HttpRequest(uri = "http://jsonplaceholder.typicode.com/posts")).onComplete {
        case Success(s) => println(s._3)
        case Failure(f) => println(f.getMessage)
      }
  }
}

object RestClientActor {
  case object InitiateRequest
}

object RestClientApp {

  def main(args: Array[String]): Unit = {

    import akka.actor.ActorSystem
    import scala.concurrent.duration._
    import RestClientActor._
    import scala.concurrent.ExecutionContextExecutor

    implicit val system: ActorSystem = ActorSystem()
    implicit val executionContext: ExecutionContextExecutor = system.dispatcher

    val actor = system.actorOf(Props[RestClientActor], "RestClientActor")

    system.scheduler.schedule(1 seconds, 3 seconds, actor, InitiateRequest)

  }
}
0 голосов
/ 06 июня 2018

Естественным соответствием будет Akka Streams , на котором построен Akka HTTP.В приведенном ниже примере используется повторяющийся Source для выполнения HTTP-запроса к указанному URI каждые пять секунд.Материализованный поток печатает ответы. 

import akka.actor.ActorSystem
import akka.http.scaladsl.Http
import akka.http.scaladsl.model._
import akka.stream.ActorMaterializer
import akka.stream.scaladsl.Source

import scala.concurrent.duration._

object RestClient {
  def main(args: Array[String]): Unit = {
    implicit val materializer = ActorMaterializer()

    Source
      .repeat(HttpRequest(uri = "http://akka.io"))
      .throttle(1, 5.seconds)
      .mapAsync(1)(Http().singleRequest(_))
      .runForeach(println)
  }
}
...