Introduction
The Akka HTTP modules implement a full server- and client-side HTTP stack on top of akka-actor and akka-stream. It’s not a web-framework but rather a more general toolkit for providing and consuming HTTP-based services. While interaction with a browser is of course also in scope it is not the primary focus of Akka HTTP.
Akka HTTP follows a rather open design and many times offers several different API levels for “doing the same thing”. You get to pick the API level of abstraction that is most suitable for your application. This means that, if you have trouble achieving something using a high-level API, there’s a good chance that you can get it done with a low-level API, which offers more flexibility but might require you to write more application code.
Philosophy
Akka HTTP has been driven with a clear focus on providing tools for building integration layers rather than application cores. As such it regards itself as a suite of libraries rather than a framework.
A framework, as we’d like to think of the term, gives you a “frame”, in which you build your application. It comes with a lot of decisions already pre-made and provides a foundation including support structures that lets you get started and deliver results quickly. In a way a framework is like a skeleton onto which you put the “flesh” of your application in order to have it come alive. As such frameworks work best if you choose them before you start application development and try to stick to the frameworks “way of doing things” as you go along.
For example, if you are building a browser-facing web application it makes sense to choose a web framework and build your application on top of it because the “core” of the application is the interaction of a browser with your code on the web-server. The framework makers have chosen one “proven” way of designing such applications and let you “fill in the blanks” of a more or less flexible “application-template”. Being able to rely on best-practice architecture like this can be a great asset for getting things done quickly.
However, if your application is not primarily a web application because its core is not browser-interaction but some specialized maybe complex business service and you are merely trying to connect it to the world via a REST/HTTP interface a web-framework might not be what you need. In this case the application architecture should be dictated by what makes sense for the core not the interface layer. Also, you probably won’t benefit from the possibly existing browser-specific framework components like view templating, asset management, JavaScript- and CSS generation/manipulation/minification, localization support, AJAX support, etc.
Akka HTTP was designed specifically as “not-a-framework”, not because we don’t like frameworks, but for use cases where a framework is not the right choice. Akka HTTP is made for building integration layers based on HTTP and as such tries to “stay on the sidelines”. Therefore you normally don’t build your application “on top of” Akka HTTP, but you build your application on top of whatever makes sense and use Akka HTTP merely for the HTTP integration needs.
On the other hand, if you prefer to build your applications with the guidance of a framework, you should give Play Framework or Lagom a try, which both use Akka internally.
Using Akka HTTP
Akka HTTP is provided in a separate jar file, to use it make sure to include the following dependency:
"com.typesafe.akka" %% "akka-http" % "10.0.7"
Dependency declarations for other build tools (like Gradle or Maven) can be found here.
Mind that Akka HTTP comes in two modules: akka-http and akka-http-core. Because akka-http depends on akka-http-core you don’t need to bring the latter explicitly. Still you may need to this in case you rely solely on the low-level API; make sure the Scala version is a recent release of version 2.11 or 2.12.
Alternatively, you can bootstrap a new sbt project with Akka HTTP already configured using the Giter8 template:
sbt -Dsbt.version=0.13.15 new https://github.com/akka/akka-http-java-seed.g8
From there on the prepared project can be built using Gradle or Maven. More instructions can be found in the template project. Note, requires sbt version 0.13.13 or newer.
Routing DSL for HTTP servers
The high-level, routing API of Akka HTTP provides a DSL to describe HTTP “routes” and how they should be handled. Each route is composed of one or more level of Directive s that narrows down to handling one specific type of request.
For example one route might start with matching the path of the request, only matching if it is “/hello”, then narrowing it down to only handle HTTP get requests and then complete those with a string literal, which will be sent back as a HTTP OK with the string as response body.
Transforming request and response bodies between over-the-wire formats and objects to be used in your application is done separately from the route declarations, in marshallers, which are pulled in implicitly using the “magnet” pattern. This means that you can complete a request with any kind of object as long as there is an implicit marshaller available in scope.
JSON support is possible in akka-http by the use of Jackson, an external artifact (see JSON Support for details).
The Route created using the Route DSL is then “bound” to a port to start serving HTTP requests:
import akka.NotUsed;
import akka.actor.ActorSystem;
import akka.http.javadsl.ConnectHttp;
import akka.http.javadsl.Http;
import akka.http.javadsl.ServerBinding;
import akka.http.javadsl.model.HttpRequest;
import akka.http.javadsl.model.HttpResponse;
import akka.http.javadsl.server.AllDirectives;
import akka.http.javadsl.server.Route;
import akka.stream.ActorMaterializer;
import akka.stream.javadsl.Flow;
import java.util.concurrent.CompletionStage;
public class HttpServerMinimalExampleTest extends AllDirectives {
public static void main(String[] args) throws Exception {
// boot up server using the route as defined below
ActorSystem system = ActorSystem.create("routes");
final Http http = Http.get(system);
final ActorMaterializer materializer = ActorMaterializer.create(system);
//In order to access all directives we need an instance where the routes are define.
HttpServerMinimalExampleTest app = new HttpServerMinimalExampleTest();
final Flow<HttpRequest, HttpResponse, NotUsed> routeFlow = app.createRoute().flow(system, materializer);
final CompletionStage<ServerBinding> binding = http.bindAndHandle(routeFlow,
ConnectHttp.toHost("localhost", 8080), materializer);
System.out.println("Server online at http://localhost:8080/\nPress RETURN to stop...");
System.in.read(); // let it run until user presses return
binding
.thenCompose(ServerBinding::unbind) // trigger unbinding from the port
.thenAccept(unbound -> system.terminate()); // and shutdown when done
}
private Route createRoute() {
return route(
path("hello", () ->
get(() ->
complete("<h1>Say hello to akka-http</h1>"))));
}
}A common use case is to reply to a request using a model object having the marshaller transform it into JSON. In this case shown by two separate routes. The first route queries an asynchronous database and marshalls the CompletionStage<Optional<Item>> result into a JSON response. The second unmarshalls an Order from the incoming request saves it to the database and replies with an OK when done.
import akka.Done;
import akka.NotUsed;
import akka.actor.ActorSystem;
import akka.http.javadsl.ConnectHttp;
import akka.http.javadsl.Http;
import akka.http.javadsl.ServerBinding;
import akka.http.javadsl.marshallers.jackson.Jackson;
import akka.http.javadsl.model.HttpRequest;
import akka.http.javadsl.model.HttpResponse;
import akka.http.javadsl.model.StatusCodes;
import akka.http.javadsl.server.AllDirectives;
import akka.http.javadsl.server.Route;
import akka.stream.ActorMaterializer;
import akka.stream.javadsl.Flow;
import com.fasterxml.jackson.annotation.JsonCreator;
import com.fasterxml.jackson.annotation.JsonProperty;
import java.util.List;
import java.util.Optional;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.CompletionStage;
import static akka.http.javadsl.server.PathMatchers.longSegment;
public class JacksonExampleTest extends AllDirectives {
public static void main(String[] args) throws Exception {
// boot up server using the route as defined below
ActorSystem system = ActorSystem.create("routes");
final Http http = Http.get(system);
final ActorMaterializer materializer = ActorMaterializer.create(system);
//In order to access all directives we need an instance where the routes are define.
JacksonExampleTest app = new JacksonExampleTest();
final Flow<HttpRequest, HttpResponse, NotUsed> routeFlow = app.createRoute().flow(system, materializer);
final CompletionStage<ServerBinding> binding = http.bindAndHandle(routeFlow,
ConnectHttp.toHost("localhost", 8080), materializer);
System.out.println("Server online at http://localhost:8080/\nPress RETURN to stop...");
System.in.read(); // let it run until user presses return
binding
.thenCompose(ServerBinding::unbind) // trigger unbinding from the port
.thenAccept(unbound -> system.terminate()); // and shutdown when done
}
// (fake) async database query api
private CompletionStage<Optional<Item>> fetchItem(long itemId) {
return CompletableFuture.completedFuture(Optional.of(new Item("foo", itemId)));
}
// (fake) async database query api
private CompletionStage<Done> saveOrder(final Order order) {
return CompletableFuture.completedFuture(Done.getInstance());
}
private Route createRoute() {
return route(
get(() ->
pathPrefix("item", () ->
path(longSegment(), (Long id) -> {
final CompletionStage<Optional<Item>> futureMaybeItem = fetchItem(id);
return onSuccess(() -> futureMaybeItem, maybeItem ->
maybeItem.map(item -> completeOK(item, Jackson.marshaller()))
.orElseGet(() -> complete(StatusCodes.NOT_FOUND, "Not Found"))
);
}))),
post(() ->
path("create-order", () ->
entity(Jackson.unmarshaller(Order.class), order -> {
CompletionStage<Done> futureSaved = saveOrder(order);
return onSuccess(() -> futureSaved, done ->
complete("order created")
);
})))
);
}
private static class Item {
final String name;
final long id;
@JsonCreator
Item(@JsonProperty("name") String name,
@JsonProperty("id") long id) {
this.name = name;
this.id = id;
}
public String getName() {
return name;
}
public long getId() {
return id;
}
}
private static class Order {
final List<Item> items;
@JsonCreator
Order(@JsonProperty("items") List<Item> items) {
this.items = items;
}
public List<Item> getItems() {
return items;
}
}
}The logic for the marshalling and unmarshalling JSON in this example is provided by the “Jackson” library (details on how to use that here: JSON Support).
One of the strengths of Akka HTTP is that streaming data is at its heart meaning that both request and response bodies can be streamed through the server achieving constant memory usage even for very large requests or responses. Streaming responses will be backpressured by the remote client so that the server will not push data faster than the client can handle, streaming requests means that the server decides how fast the remote client can push the data of the request body.
Example that streams random numbers as long as the client accepts them:
import akka.NotUsed;
import akka.actor.ActorSystem;
import akka.http.javadsl.ConnectHttp;
import akka.http.javadsl.Http;
import akka.http.javadsl.ServerBinding;
import akka.http.javadsl.model.*;
import akka.http.javadsl.server.AllDirectives;
import akka.http.javadsl.server.Route;
import akka.stream.ActorMaterializer;
import akka.stream.javadsl.Flow;
import akka.stream.javadsl.Source;
import akka.util.ByteString;
import java.util.Random;
import java.util.concurrent.CompletionStage;
import java.util.stream.Stream;
public class HttpServerStreamRandomNumbersTest extends AllDirectives {
public static void main(String[] args) throws Exception {
// boot up server using the route as defined below
ActorSystem system = ActorSystem.create("routes");
final Http http = Http.get(system);
final ActorMaterializer materializer = ActorMaterializer.create(system);
//In order to access all directives we need an instance where the routes are define.
HttpServerStreamRandomNumbersTest app = new HttpServerStreamRandomNumbersTest();
final Flow<HttpRequest, HttpResponse, NotUsed> routeFlow = app.createRoute().flow(system, materializer);
final CompletionStage<ServerBinding> binding = http.bindAndHandle(routeFlow,
ConnectHttp.toHost("localhost", 8080), materializer);
System.out.println("Server online at http://localhost:8080/\nPress RETURN to stop...");
System.in.read(); // let it run until user presses return
binding
.thenCompose(ServerBinding::unbind) // trigger unbinding from the port
.thenAccept(unbound -> system.terminate()); // and shutdown when done
}
private Route createRoute() {
final Random rnd = new Random();
// streams are re-usable so we can define it here
// and use it for every request
Source<Integer, NotUsed> numbers = Source.fromIterator(() -> Stream.generate(rnd::nextInt).iterator());
return route(
path("random", () ->
get(() ->
complete(HttpEntities.create(ContentTypes.TEXT_PLAIN_UTF8,
// transform each number to a chunk of bytes
numbers.map(x -> ByteString.fromString(x + "\n")))))));
}
}Connecting to this service with a slow HTTP client would backpressure so that the next random number is produced on demand with constant memory usage on the server. This can be seen using curl and limiting the rate curl --limit-rate 50b 127.0.0.1:8080/random
Akka HTTP routes easily interacts with actors. In this example one route allows for placing bids in a fire-and-forget style while the second route contains a request-response interaction with an actor. The resulting response is rendered as json and returned when the response arrives from the actor.
import akka.NotUsed;
import akka.actor.ActorRef;
import akka.actor.ActorSystem;
import akka.actor.Props;
import akka.actor.AbstractActor;
import akka.event.Logging;
import akka.event.LoggingAdapter;
import akka.http.javadsl.ConnectHttp;
import akka.http.javadsl.Http;
import akka.http.javadsl.ServerBinding;
import akka.http.javadsl.marshallers.jackson.Jackson;
import akka.http.javadsl.model.HttpRequest;
import akka.http.javadsl.model.HttpResponse;
import akka.http.javadsl.model.StatusCodes;
import akka.http.javadsl.server.AllDirectives;
import akka.http.javadsl.server.Route;
import akka.http.javadsl.unmarshalling.StringUnmarshallers;
import akka.japi.pf.ReceiveBuilder;
import akka.stream.ActorMaterializer;
import akka.stream.javadsl.Flow;
import akka.util.Timeout;
import scala.concurrent.duration.FiniteDuration;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.CompletionStage;
import java.util.concurrent.TimeUnit;
import static akka.pattern.PatternsCS.ask;
public class HttpServerActorInteractionExample extends AllDirectives {
private final ActorRef auction;
public static void main(String[] args) throws Exception {
// boot up server using the route as defined below
ActorSystem system = ActorSystem.create("routes");
final Http http = Http.get(system);
final ActorMaterializer materializer = ActorMaterializer.create(system);
//In order to access all directives we need an instance where the routes are define.
HttpServerActorInteractionExample app = new HttpServerActorInteractionExample(system);
final Flow<HttpRequest, HttpResponse, NotUsed> routeFlow = app.createRoute().flow(system, materializer);
final CompletionStage<ServerBinding> binding = http.bindAndHandle(routeFlow,
ConnectHttp.toHost("localhost", 8080), materializer);
System.out.println("Server online at http://localhost:8080/\nPress RETURN to stop...");
System.in.read(); // let it run until user presses return
binding
.thenCompose(ServerBinding::unbind) // trigger unbinding from the port
.thenAccept(unbound -> system.terminate()); // and shutdown when done
}
private HttpServerActorInteractionExample(final ActorSystem system) {
auction = system.actorOf(Auction.props(), "auction");
}
private Route createRoute() {
return route(
path("auction", () -> route(
put(() ->
parameter(StringUnmarshallers.INTEGER, "bid", bid ->
parameter("user", user -> {
// place a bid, fire-and-forget
auction.tell(new Bid(user, bid), ActorRef.noSender());
return complete(StatusCodes.ACCEPTED, "bid placed");
})
)),
get(() -> {
final Timeout timeout = Timeout.durationToTimeout(FiniteDuration.apply(5, TimeUnit.SECONDS));
// query the actor for the current auction state
CompletionStage<Bids> bids = ask(auction, new GetBids(), timeout).thenApply((Bids.class::cast));
return completeOKWithFuture(bids, Jackson.marshaller());
}))));
}
static class Bid {
final String userId;
final int offer;
Bid(String userId, int offer) {
this.userId = userId;
this.offer = offer;
}
}
static class GetBids {
}
static class Bids {
public final List<Bid> bids;
Bids(List<Bid> bids) {
this.bids = bids;
}
}
// compiles only against Akka 2.4, see migration guide for how to rewrite for Akka 2.5
static class Auction extends AbstractActor {
private final LoggingAdapter log = Logging.getLogger(context().system(), this);
List<HttpServerActorInteractionExample.Bid> bids = new ArrayList<>();
static Props props() {
return Props.create(Auction.class);
}
public Auction() {
receive(ReceiveBuilder.
match(HttpServerActorInteractionExample.Bid.class, bid -> {
bids.add(bid);
log.info("Bid complete: {}, {}", bid.userId, bid.offer);
}).
match(HttpServerActorInteractionExample.GetBids.class, m -> {
sender().tell(new HttpServerActorInteractionExample.Bids(bids), self());
}).
matchAny(o -> log.info("Invalid message")).
build()
);
}
}
}Again the logic for the marshalling and unmarshalling JSON in this example is provided by the “Jackson” library (details on how to use that here: JSON Support)
Read more about the details of the high level APIs in the section High-level Server-Side API.
Low-level HTTP server APIs
The low-level Akka HTTP server APIs allows for handling connections or individual requests by accepting HttpRequest s and answering them by producing HttpResponse s. This is provided by the akka-http-core module. APIs for handling such request-responses as function calls and as a Flow<HttpRequest, HttpResponse, NotUsed> are available.
import akka.actor.ActorSystem;
import akka.http.javadsl.ConnectHttp;
import akka.http.javadsl.Http;
import akka.http.javadsl.ServerBinding;
import akka.http.javadsl.model.ContentTypes;
import akka.http.javadsl.model.HttpResponse;
import akka.http.javadsl.model.StatusCodes;
import akka.stream.ActorMaterializer;
import akka.stream.Materializer;
import akka.util.ByteString;
import java.util.concurrent.CompletionStage;
public class HttpServerLowLevelExample {
public static void main(String[] args) throws Exception {
ActorSystem system = ActorSystem.create();
try {
final Materializer materializer = ActorMaterializer.create(system);
CompletionStage<ServerBinding> serverBindingFuture =
Http.get(system).bindAndHandleSync(
request -> {
if (request.getUri().path().equals("/"))
return HttpResponse.create().withEntity(ContentTypes.TEXT_HTML_UTF8,
ByteString.fromString("<html><body>Hello world!</body></html>"));
else if (request.getUri().path().equals("/ping"))
return HttpResponse.create().withEntity(ByteString.fromString("PONG!"));
else if (request.getUri().path().equals("/crash"))
throw new RuntimeException("BOOM!");
else {
request.discardEntityBytes(materializer);
return HttpResponse.create().withStatus(StatusCodes.NOT_FOUND).withEntity("Unknown resource!");
}
}, ConnectHttp.toHost("localhost", 8080), materializer);
System.out.println("Server online at http://localhost:8080/\nPress RETURN to stop...");
System.in.read(); // let it run until user presses return
serverBindingFuture
.thenCompose(ServerBinding::unbind) // trigger unbinding from the port
.thenAccept(unbound -> system.terminate()); // and shutdown when done
} catch (RuntimeException e) {
system.terminate();
}
}
}Read more details about the low level APIs in the section Low-Level Server-Side API.
HTTP client API
The client APIs provide methods for calling a HTTP server using the same HttpRequest and HttpResponse abstractions that Akka HTTP server uses but adds the concept of connection pools to allow multiple requests to the same server to be handled more performantly by re-using TCP connections to the server.
Example simple request:
import akka.actor.ActorSystem;
import akka.http.javadsl.Http;
import akka.http.javadsl.model.HttpRequest;
import akka.http.javadsl.model.HttpResponse;
import akka.stream.ActorMaterializer;
import akka.stream.Materializer;
import java.util.concurrent.CompletionStage;
public class ClientSingleRequestExample {
public static void main(String[] args) {
final ActorSystem system = ActorSystem.create();
final Materializer materializer = ActorMaterializer.create(system);
final CompletionStage<HttpResponse> responseFuture =
Http.get(system)
.singleRequest(HttpRequest.create("http://akka.io"), materializer);
}
}Read more about the details of the client APIs in the section Consuming HTTP-based Services (Client-Side).
The modules that make up Akka HTTP
Akka HTTP is structured into several modules:
- akka-http
- Higher-level functionality, like (un)marshalling, (de)compression as well as a powerful DSL for defining HTTP-based APIs on the server-side, this is the recommended way to write HTTP servers with Akka HTTP. Details can be found in the section High-level Server-Side API
- akka-http-core
- A complete, mostly low-level, server- and client-side implementation of HTTP (incl. WebSockets) Details can be found in sections Low-Level Server-Side API and Consuming HTTP-based Services (Client-Side)
- akka-http-testkit
- A test harness and set of utilities for verifying server-side service implementations
- akka-http-jackson
- Predefined glue-code for (de)serializing custom types from/to JSON with jackson