This library implements the provided SPI for the asynchronous and non-blocking http calls in the new AWS Java SDK with Akka HTTP.
This is an alternative implementation to the built-in netty-based async http engine in the aws sdk. Use at your own risk.
Create a dependency to this library by adding the following to your build.sbt:
"com.github.matsluni" %% "aws-spi-akka-http" % "1.0.1"
or for Maven, the following to pom.xml:
<dependency>
<groupId>com.github.matsluni</groupId>
<artifactId>aws-spi-akka-http_3</artifactId>
<version>1.0.1</version>
</dependency>
An example (in scala) from the test shows how to use akka-http as the underlying http provider instead of netty.
val akkaClient = new AkkaHttpAsyncHttpService().createAsyncHttpClientFactory().build()
val client = S3AsyncClient
.builder()
.credentialsProvider(ProfileCredentialsProvider.builder().build())
.region(Region.EU_CENTRAL_1)
.httpClient(akkaClient)
.build()
val eventualResponse = client.listBuckets()If you connect to an AWS service from inside a corporate network, it may be necessary to configure a proxy. This can be achieved in the following way:
val system = ActorSystem("aws-akka-http")
val proxyHost = "localhost"
val proxyPort = 8888
val httpsProxyTransport = ClientTransport.httpsProxy(InetSocketAddress.createUnresolved(proxyHost, proxyPort))
val settings = ConnectionPoolSettings(system)
.withConnectionSettings(ClientConnectionSettings(system)
.withTransport(httpsProxyTransport))
lazy val akkaHttpClient =
AkkaHttpClient
.builder()
.withActorSystem(system)
.withConnectionPoolSettings(settings)
.build()
val client = S3AsyncClient
.builder()
.credentialsProvider(ProfileCredentialsProvider.builder().build())
.region(Region.EU_CENTRAL_1)
.httpClient(akkaHttpClient)
.build()
val eventualResponse = client.listBuckets()When you use this library and a specific AWS service (e.g. S3, SQS, etc...) you may want to exclude the transitive
Netty dependency netty-nio-client like this:
libraryDependencies ++= Seq(
"software.amazon.awssdk" % "s3" % "2.11.4" exclude("software.amazon.awssdk", "netty-nio-client")
)If you not exclude the transitive dependency like shown above you have to explicitly declare which httpClient to use
in the service client instantiation. If no client is explicitly set and multiple implementations for the SdkAsyncHttpClient
are found on the classpath, an exception like the following is thrown at runtime:
software.amazon.awssdk.core.exception.SdkClientException: Multiple HTTP implementations were found on the classpath.
To avoid non-deterministic loading implementations, please explicitly provide an HTTP client via the client builders,
set the software.amazon.awssdk.http.async.service.impl system property with the FQCN of the HTTP service to use as the
default, or remove all but one HTTP implementation from the classpathTo further reduce the classpath it is also optional possible to exclude "software.amazon.awssdk", "apache-client".
This excludes an additional HttpClient, which comes as a transitive dependency with a AWS service.
There also exists an mini example project which shows the usage. This example uses gradle and also shows how to exclude the netty dependency.
In this repository there are unit tests and integration tests. The unit tests run against some local started aws services, which test some basic functionality and do not use real services from aws and cost no money.
But, there are also integration tests which require valid aws credentials to run and running these tests is not for free. If you are not careful it can cost you money on aws. Be warned.
The integration tests look for aws credentials as either an environment variable, a system property or a credential file. See the here and here in the aws documentation for details.
The tests can be run in sbt with:
test
To run the integration tests
it:test
This library is Open Source and available under the Apache 2 License.