import akka.actor.ActorSystem; import akka.http.javadsl.Http; import akka.http.javadsl.model.HttpRequest; import akka.http.javadsl.model.HttpResponse; import akka.http.javadsl.server.AllDirectives; import akka.http.javadsl.server.Route; public class SimpleWebService extends AllDirectives { private final ActorSystem system; private final Http http; public SimpleWebService() { system = ActorSystem.create(); http = Http.get(system); } public void startServer(String host, int port) { final Route route = route( path("hello", () -> get(() -> complete(HttpResponse.create().withEntity("Hello, World!")) ) ) ); http.bindAndHandle(route.flow(system, materializer()), host, port); } public static void main(String[] args) { SimpleWebService service = new SimpleWebService(); service.startServer("localhost", 8080); } }


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