Как запустить сервер Akka-HTTP внутри кластера Akka?

Question

Я создаю кластер Akka и хочу использовать сервер Akka-HTTP в качестве сервера API внутри. Как это сделать?

Я бы предположил, что это будет кластер singleton, поскольку он является точкой доступа к кластеру, но сделать его актером кажется странным, поскольку он должен будет иметь метод receive(), который ничего не сделает (i Угадай).

Answer 1

Простейший пример:

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) 

Для остановки:

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