AWS CRT HTTP Client Sample GET Request

[grandamp]

Apologies for creating a thread on something very basic, but; is there a simple code example of performing an HTTP GET request via the AWS CRT HTTP Client?

There are many blog posts that cover how to initialize the client, but I'm having a challenge in finding any complete example that demonstrates performing a GET request and consuming the response.

Below is a Coretto17 example using using the native java.net.http.HttpClient, where I would like an example using software.amazon.awssdk.http.crt.AwsCrtAsyncHttpClient:

	public static void jdkAsyncGet(URI httpURI) {
		HttpClient client = HttpClient.newHttpClient();
		HttpRequest request = HttpRequest.newBuilder(httpURI)
				.timeout(Duration.ofSeconds(30))
				.version(HttpClient.Version.HTTP_2)
				.build();
		CompletableFuture<Void> futureResponse = client.sendAsync(request, HttpResponse.BodyHandlers.ofString())
				.thenAccept(resp -> {
					acceptResponseCallback(resp);
				});
		while (!futureResponse.isDone()) {
			//Wait
		}
		System.out.println("futureResponse: " + futureResponse);
	}

[zoewangg]

Hi @grandamp, we have some sample code of using AwsCrtAsyncHttpClient as a generic HTTP client in our test code

aws-sdk-java-v2/http-clients/aws-crt-client/src/test/java/software/amazon/awssdk/http/crt/AwsCrtHttpClientSpiVerificationTest.java

Lines 191 to 231 in b57d499

	public void testGetRequest() throws Exception {
	String path = "/testGetRequest";
	byte[] body = generateRandomBody(TEST_BODY_LEN);
	String expectedBodyHash = sha256Hex(body).toUpperCase();
	stubFor(any(urlEqualTo(path)).willReturn(aResponse().withStatus(200)
	.withHeader("Content-Length", Integer.toString(TEST_BODY_LEN))
	.withHeader("foo", "bar")
	.withBody(body)));
	CompletableFuture<Boolean> streamReceived = new CompletableFuture<>();
	AtomicReference<SdkHttpResponse> response = new AtomicReference<>(null);
	Sha256BodySubscriber bodySha256Subscriber = new Sha256BodySubscriber();
	AtomicReference<Throwable> error = new AtomicReference<>(null);
	SdkAsyncHttpResponseHandler handler = new SdkAsyncHttpResponseHandler() {
	@Override
	public void onHeaders(SdkHttpResponse headers) {
	response.compareAndSet(null, headers);
	}
	@Override
	public void onStream(Publisher<ByteBuffer> stream) {
	stream.subscribe(bodySha256Subscriber);
	streamReceived.complete(true);
	}
	@Override
	public void onError(Throwable t) {
	error.compareAndSet(null, t);
	}
	};
	URI uri = URI.create("http://localhost:" + mockServer.port());
	SdkHttpRequest request = CrtHttpClientTestUtils.createRequest(uri, path, null, SdkHttpMethod.GET, emptyMap());
	CompletableFuture future = client.execute(AsyncExecuteRequest.builder()
	.request(request)
	.responseHandler(handler)
	.requestContentPublisher(new EmptyPublisher())
	.build());
	future.get(60, TimeUnit.SECONDS);

Note that HTTP/2 is not supported in the AWS CRT HTTP client at the moment though.

[grandamp]

Thank you @zoewangg !

[github-actions[bot]]

Hello! Reopening this discussion to make it searchable.