Comment faire fonctionner un serveur Akka-HTTP à l'intérieur d'un cluster Akka?

Question

Je construis un cluster Akka et je veux utiliser le serveur Akka-HTTP comme serveur API à l'intérieur. Comment fait-on cela?

J'imagine que ce sera un singleton de cluster, car c'est un point d'accès au cluster, mais en faire un acteur semble bizarre, car il devra avoir une méthode receive(), qui ne fera rien (i deviner).

Answer 1

exemple le plus simple:

implicit val system = ... // your ActorSystem goes here 
implicit val materializer = ActorMaterializer() 
implicit val executionContext = system.dispatcher 

val route = 
    path("hello") { 
    get { 
     complete(HttpEntity(ContentTypes.`text/plain(UTF-8)`, "Hello World !")) 
    } 
    } 

val bindingFuture = Http().bindAndHandle(route, "localhost", 8080) 

Pour arrêter:

bindingFuture 
    .flatMap(_.unbind()) // trigger unbinding from the port 
    .onComplete(_ => system.terminate()) // and shutdown when done