import static akka.http.javadsl.server.Directives.*; final Route route = path("hello", () -> get(() -> complete("Hello, Akka HTTP!") ) ); import akka.http.javadsl.model.StatusCodes; import akka.http.javadsl.server.Handler; final Handler helloHandler = ctx -> ctx.complete(StatusCodes.OK, "Hello, Akka HTTP!"); import akka.actor.ActorSystem; import akka.http.javadsl.Http; import akka.http.javadsl.ServerBinding; import akka.http.javadsl.settings.ServerSettings; import akka.stream.ActorMaterializer; import akka.stream.Materializer; import scala.concurrent.Future; final ActorSystem system = ActorSystem.create(); final Materializer materializer = ActorMaterializer.create(system); final Http http = Http.get(system); final ServerSettings serverSettings = ServerSettings.create(system); final routes = concat(route, path("ping", () -> complete("Pong!"))); final Future<ServerBinding> binding = http.bindAndHandle(routes, ConnectHttp.toHost("localhost", 8080), serverSettings, materializer);


上一篇:
下一篇:
切换中文