2015-07-10 19:13:56 +02:00
|
|
|
/*
|
|
|
|
|
* Copyright (C) 2009-2015 Typesafe Inc. <http://www.typesafe.com>
|
|
|
|
|
*/
|
|
|
|
|
|
|
|
|
|
package docs.http.javadsl;
|
|
|
|
|
|
|
|
|
|
import akka.actor.ActorSystem;
|
2015-07-10 19:10:29 +02:00
|
|
|
import akka.http.impl.util.Util;
|
2015-07-10 19:13:56 +02:00
|
|
|
import akka.http.javadsl.Http;
|
|
|
|
|
import akka.http.javadsl.IncomingConnection;
|
|
|
|
|
import akka.http.javadsl.ServerBinding;
|
|
|
|
|
import akka.http.javadsl.model.*;
|
|
|
|
|
import akka.http.javadsl.model.ws.Websocket;
|
|
|
|
|
import akka.japi.function.Function;
|
|
|
|
|
import akka.japi.function.Procedure;
|
|
|
|
|
import akka.stream.ActorMaterializer;
|
|
|
|
|
import akka.stream.Materializer;
|
|
|
|
|
import akka.stream.javadsl.Flow;
|
|
|
|
|
import akka.stream.javadsl.Sink;
|
|
|
|
|
import akka.stream.javadsl.Source;
|
|
|
|
|
import org.junit.Test;
|
|
|
|
|
import scala.Function1;
|
|
|
|
|
import scala.concurrent.Await;
|
|
|
|
|
import scala.concurrent.Future;
|
|
|
|
|
import scala.concurrent.duration.FiniteDuration;
|
|
|
|
|
|
|
|
|
|
import java.io.BufferedReader;
|
|
|
|
|
import java.io.InputStreamReader;
|
|
|
|
|
import java.util.concurrent.TimeUnit;
|
|
|
|
|
|
|
|
|
|
public class HttpServerExampleSpec {
|
2015-07-10 19:10:29 +02:00
|
|
|
public static void bindingExample() {
|
2015-07-10 19:13:56 +02:00
|
|
|
//#binding-example
|
|
|
|
|
ActorSystem system = ActorSystem.create();
|
|
|
|
|
Materializer materializer = ActorMaterializer.create(system);
|
|
|
|
|
|
|
|
|
|
Source<IncomingConnection, Future<ServerBinding>> serverSource =
|
|
|
|
|
Http.get(system).bind("localhost", 8080, materializer);
|
|
|
|
|
|
|
|
|
|
Future<ServerBinding> serverBindingFuture =
|
|
|
|
|
serverSource.to(Sink.foreach(
|
|
|
|
|
new Procedure<IncomingConnection>() {
|
|
|
|
|
@Override
|
|
|
|
|
public void apply(IncomingConnection connection) throws Exception {
|
|
|
|
|
System.out.println("Accepted new connection from " + connection.remoteAddress());
|
|
|
|
|
// ... and then actually handle the connection
|
|
|
|
|
}
|
|
|
|
|
})).run(materializer);
|
|
|
|
|
//#binding-example
|
|
|
|
|
}
|
2015-07-10 19:10:29 +02:00
|
|
|
public static void fullServerExample() throws Exception {
|
2015-07-10 19:13:56 +02:00
|
|
|
//#full-server-example
|
2015-07-10 19:10:29 +02:00
|
|
|
ActorSystem system = ActorSystem.create();
|
|
|
|
|
//#full-server-example
|
|
|
|
|
try {
|
|
|
|
|
//#full-server-example
|
|
|
|
|
final Materializer materializer = ActorMaterializer.create(system);
|
2015-07-10 19:13:56 +02:00
|
|
|
|
2015-07-10 19:10:29 +02:00
|
|
|
Source<IncomingConnection, Future<ServerBinding>> serverSource =
|
|
|
|
|
Http.get(system).bind("localhost", 8080, materializer);
|
2015-07-10 19:13:56 +02:00
|
|
|
|
2015-07-10 19:10:29 +02:00
|
|
|
//#request-handler
|
|
|
|
|
final Function<HttpRequest, HttpResponse> requestHandler =
|
|
|
|
|
new Function<HttpRequest, HttpResponse>() {
|
|
|
|
|
private final HttpResponse NOT_FOUND =
|
|
|
|
|
HttpResponse.create()
|
|
|
|
|
.withStatus(404)
|
|
|
|
|
.withEntity("Unknown resource!");
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
public HttpResponse apply(HttpRequest request) throws Exception {
|
|
|
|
|
Uri uri = request.getUri();
|
|
|
|
|
if (request.method() == HttpMethods.GET) {
|
|
|
|
|
if (uri.path().equals("/"))
|
|
|
|
|
return
|
|
|
|
|
HttpResponse.create()
|
|
|
|
|
.withEntity(MediaTypes.TEXT_HTML.toContentType(),
|
|
|
|
|
"<html><body>Hello world!</body></html>");
|
|
|
|
|
else if (uri.path().equals("/hello")) {
|
|
|
|
|
String name = Util.getOrElse(uri.parameter("name"), "Mister X");
|
2015-07-10 19:13:56 +02:00
|
|
|
|
2015-07-10 19:10:29 +02:00
|
|
|
return
|
|
|
|
|
HttpResponse.create()
|
|
|
|
|
.withEntity("Hello " + name + "!");
|
|
|
|
|
}
|
|
|
|
|
else if (uri.path().equals("/ping"))
|
|
|
|
|
return HttpResponse.create().withEntity("PONG!");
|
|
|
|
|
else
|
|
|
|
|
return NOT_FOUND;
|
|
|
|
|
}
|
|
|
|
|
else return NOT_FOUND;
|
2015-07-10 19:13:56 +02:00
|
|
|
}
|
2015-07-10 19:10:29 +02:00
|
|
|
};
|
|
|
|
|
//#request-handler
|
2015-07-10 19:13:56 +02:00
|
|
|
|
2015-07-10 19:10:29 +02:00
|
|
|
Future<ServerBinding> serverBindingFuture =
|
2015-07-10 19:13:56 +02:00
|
|
|
serverSource.to(Sink.foreach(
|
2015-07-10 19:10:29 +02:00
|
|
|
new Procedure<IncomingConnection>() {
|
|
|
|
|
@Override
|
|
|
|
|
public void apply(IncomingConnection connection) throws Exception {
|
|
|
|
|
System.out.println("Accepted new connection from " + connection.remoteAddress());
|
2015-07-10 19:13:56 +02:00
|
|
|
|
2015-07-10 19:10:29 +02:00
|
|
|
connection.handleWithSyncHandler(requestHandler, materializer);
|
|
|
|
|
// this is equivalent to
|
|
|
|
|
//connection.handleWith(Flow.of(HttpRequest.class).map(requestHandler), materializer);
|
|
|
|
|
}
|
|
|
|
|
})).run(materializer);
|
|
|
|
|
//#full-server-example
|
|
|
|
|
|
|
|
|
|
Await.result(serverBindingFuture, new FiniteDuration(1, TimeUnit.SECONDS)); // will throw if binding fails
|
|
|
|
|
System.out.println("Press ENTER to stop.");
|
|
|
|
|
new BufferedReader(new InputStreamReader(System.in)).readLine();
|
|
|
|
|
} finally {
|
|
|
|
|
system.shutdown();
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
public static void main(String[] args) throws Exception {
|
|
|
|
|
fullServerExample();
|
2015-07-10 19:13:56 +02:00
|
|
|
}
|
|
|
|
|
}
|
