Merge pull request eugenp#6900 from amit2103/BAEL-9555

[BAEL-9555] - Created a core-java-modules folder

core-java-10/pom.xml → core-java-modules/core-java-10/pom.xml

@@ -12,6 +12,7 @@
         <groupId>com.baeldung</groupId>
         <artifactId>parent-modules</artifactId>
         <version>1.0.0-SNAPSHOT</version>
+        <relativePath>../../</relativePath>
     </parent>
 
     <build>

core-java-11/pom.xml → core-java-modules/core-java-11/pom.xml

@@ -12,6 +12,7 @@
         <groupId>com.baeldung</groupId>
         <artifactId>parent-modules</artifactId>
         <version>1.0.0-SNAPSHOT</version>
+        <relativePath>../../</relativePath>
     </parent>
 
     <dependencies>

core-java-11/src/main/java/com/baeldung/java11/httpclient/HttpClientExample.java → core-java-modules/core-java-11/src/main/java/com/baeldung/java11/httpclient/HttpClientExample.java

@@ -1,132 +1,132 @@
-/*
- * To change this license header, choose License Headers in Project Properties.
- * To change this template file, choose Tools | Templates
- * and open the template in the editor.
- */
-package com.baeldung.java11.httpclient;
-
-import java.io.IOException;
-import java.net.URI;
-import java.net.URISyntaxException;
-import java.net.http.HttpClient;
-import java.net.http.HttpClient.Version;
-import java.net.http.HttpRequest;
-import java.net.http.HttpRequest.BodyPublishers;
-import java.net.http.HttpResponse;
-import java.net.http.HttpResponse.BodyHandlers;
-import java.net.http.HttpResponse.PushPromiseHandler;
-import java.util.Arrays;
-import java.util.List;
-import java.util.concurrent.CompletableFuture;
-import java.util.function.Function;
-import java.util.stream.Collectors;
-
-public class HttpClientExample {
-
-    public static void main(String[] args) throws Exception {
-        httpGetRequest();
-        httpPostRequest();
-        asynchronousGetRequest();
-        asynchronousMultipleRequests();
-        pushRequest();
-    }
-
-    public static void httpGetRequest() throws URISyntaxException, IOException, InterruptedException {
-        HttpClient client = HttpClient.newHttpClient();
-        HttpRequest request = HttpRequest.newBuilder()
-            .version(HttpClient.Version.HTTP_2)
-            .uri(URI.create("http://jsonplaceholder.typicode.com/posts/1"))
-            .headers("Accept-Enconding", "gzip, deflate")
-            .build();
-        HttpResponse<String> response = client.send(request, BodyHandlers.ofString());
-
-        String responseBody = response.body();
-        int responseStatusCode = response.statusCode();
-
-        System.out.println("httpGetRequest: " + responseBody);
-        System.out.println("httpGetRequest status code: " + responseStatusCode);
-    }
-
-    public static void httpPostRequest() throws URISyntaxException, IOException, InterruptedException {
-        HttpClient client = HttpClient.newBuilder()
-            .version(HttpClient.Version.HTTP_2)
-            .build();
-        HttpRequest request = HttpRequest.newBuilder(new URI("http://jsonplaceholder.typicode.com/posts"))
-            .version(HttpClient.Version.HTTP_2)
-            .POST(BodyPublishers.ofString("Sample Post Request"))
-            .build();
-        HttpResponse<String> response = client.send(request, BodyHandlers.ofString());
-        String responseBody = response.body();
-        System.out.println("httpPostRequest : " + responseBody);
-    }
-
-    public static void asynchronousGetRequest() throws URISyntaxException {
-        HttpClient client = HttpClient.newHttpClient();
-        URI httpURI = new URI("http://jsonplaceholder.typicode.com/posts/1");
-        HttpRequest request = HttpRequest.newBuilder(httpURI)
-            .version(HttpClient.Version.HTTP_2)
-            .build();
-        CompletableFuture<Void> futureResponse = client.sendAsync(request, HttpResponse.BodyHandlers.ofString())
-            .thenAccept(resp -> {
-                System.out.println("Got pushed response " + resp.uri());
-                System.out.println("Response statuscode: " + resp.statusCode());
-                System.out.println("Response body: " + resp.body());
-            });
-        System.out.println("futureResponse" + futureResponse);
-
-    }
-
-    public static void asynchronousMultipleRequests() throws URISyntaxException {
-        HttpClient client = HttpClient.newHttpClient();
-        List<URI> uris = Arrays.asList(new URI("http://jsonplaceholder.typicode.com/posts/1"), new URI("http://jsonplaceholder.typicode.com/posts/2"));
-        List<HttpRequest> requests = uris.stream()
-            .map(HttpRequest::newBuilder)
-            .map(reqBuilder -> reqBuilder.build())
-            .collect(Collectors.toList());
-        System.out.println("Got pushed response1 " + requests);
-        CompletableFuture.allOf(requests.stream()
-            .map(request -> client.sendAsync(request, BodyHandlers.ofString()))
-            .toArray(CompletableFuture<?>[]::new))
-            .thenAccept(System.out::println)
-            .join();
-    }
-
-    public static void pushRequest() throws URISyntaxException, InterruptedException {
-        System.out.println("Running HTTP/2 Server Push example...");
-
-        HttpClient httpClient = HttpClient.newBuilder()
-            .version(Version.HTTP_2)
-            .build();
-
-        HttpRequest pageRequest = HttpRequest.newBuilder()
-            .uri(URI.create("https://http2.golang.org/serverpush"))
-            .build();
-
-        // Interface HttpResponse.PushPromiseHandler<T>
-        // void applyPushPromise​(HttpRequest initiatingRequest, HttpRequest pushPromiseRequest, Function<HttpResponse.BodyHandler<T>,​CompletableFuture<HttpResponse<T>>> acceptor)
-        httpClient.sendAsync(pageRequest, BodyHandlers.ofString(), pushPromiseHandler())
-            .thenAccept(pageResponse -> {
-                System.out.println("Page response status code: " + pageResponse.statusCode());
-                System.out.println("Page response headers: " + pageResponse.headers());
-                String responseBody = pageResponse.body();
-                System.out.println(responseBody);
-            }).join();
-
-        Thread.sleep(1000); // waiting for full response
-    }
-
-    private static PushPromiseHandler<String> pushPromiseHandler() {
-        return (HttpRequest initiatingRequest, 
-            HttpRequest pushPromiseRequest, 
-            Function<HttpResponse.BodyHandler<String>, 
-            CompletableFuture<HttpResponse<String>>> acceptor) -> {
-            acceptor.apply(BodyHandlers.ofString())
-                .thenAccept(resp -> {
-                    System.out.println(" Pushed response: " + resp.uri() + ", headers: " + resp.headers());
-                });
-            System.out.println("Promise request: " + pushPromiseRequest.uri());
-            System.out.println("Promise request: " + pushPromiseRequest.headers());
-        };
-    }
-
-}
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package com.baeldung.java11.httpclient;
+
+import java.io.IOException;
+import java.net.URI;
+import java.net.URISyntaxException;
+import java.net.http.HttpClient;
+import java.net.http.HttpClient.Version;
+import java.net.http.HttpRequest;
+import java.net.http.HttpRequest.BodyPublishers;
+import java.net.http.HttpResponse;
+import java.net.http.HttpResponse.BodyHandlers;
+import java.net.http.HttpResponse.PushPromiseHandler;
+import java.util.Arrays;
+import java.util.List;
+import java.util.concurrent.CompletableFuture;
+import java.util.function.Function;
+import java.util.stream.Collectors;
+
+public class HttpClientExample {
+
+    public static void main(String[] args) throws Exception {
+        httpGetRequest();
+        httpPostRequest();
+        asynchronousGetRequest();
+        asynchronousMultipleRequests();
+        pushRequest();
+    }
+
+    public static void httpGetRequest() throws URISyntaxException, IOException, InterruptedException {
+        HttpClient client = HttpClient.newHttpClient();
+        HttpRequest request = HttpRequest.newBuilder()
+            .version(HttpClient.Version.HTTP_2)
+            .uri(URI.create("http://jsonplaceholder.typicode.com/posts/1"))
+            .headers("Accept-Enconding", "gzip, deflate")
+            .build();
+        HttpResponse<String> response = client.send(request, BodyHandlers.ofString());
+
+        String responseBody = response.body();
+        int responseStatusCode = response.statusCode();
+
+        System.out.println("httpGetRequest: " + responseBody);
+        System.out.println("httpGetRequest status code: " + responseStatusCode);
+    }
+
+    public static void httpPostRequest() throws URISyntaxException, IOException, InterruptedException {
+        HttpClient client = HttpClient.newBuilder()
+            .version(HttpClient.Version.HTTP_2)
+            .build();
+        HttpRequest request = HttpRequest.newBuilder(new URI("http://jsonplaceholder.typicode.com/posts"))
+            .version(HttpClient.Version.HTTP_2)
+            .POST(BodyPublishers.ofString("Sample Post Request"))
+            .build();
+        HttpResponse<String> response = client.send(request, BodyHandlers.ofString());
+        String responseBody = response.body();
+        System.out.println("httpPostRequest : " + responseBody);
+    }
+
+    public static void asynchronousGetRequest() throws URISyntaxException {
+        HttpClient client = HttpClient.newHttpClient();
+        URI httpURI = new URI("http://jsonplaceholder.typicode.com/posts/1");
+        HttpRequest request = HttpRequest.newBuilder(httpURI)
+            .version(HttpClient.Version.HTTP_2)
+            .build();
+        CompletableFuture<Void> futureResponse = client.sendAsync(request, HttpResponse.BodyHandlers.ofString())
+            .thenAccept(resp -> {
+                System.out.println("Got pushed response " + resp.uri());
+                System.out.println("Response statuscode: " + resp.statusCode());
+                System.out.println("Response body: " + resp.body());
+            });
+        System.out.println("futureResponse" + futureResponse);
+
+    }
+
+    public static void asynchronousMultipleRequests() throws URISyntaxException {
+        HttpClient client = HttpClient.newHttpClient();
+        List<URI> uris = Arrays.asList(new URI("http://jsonplaceholder.typicode.com/posts/1"), new URI("http://jsonplaceholder.typicode.com/posts/2"));
+        List<HttpRequest> requests = uris.stream()
+            .map(HttpRequest::newBuilder)
+            .map(reqBuilder -> reqBuilder.build())
+            .collect(Collectors.toList());
+        System.out.println("Got pushed response1 " + requests);
+        CompletableFuture.allOf(requests.stream()
+            .map(request -> client.sendAsync(request, BodyHandlers.ofString()))
+            .toArray(CompletableFuture<?>[]::new))
+            .thenAccept(System.out::println)
+            .join();
+    }
+
+    public static void pushRequest() throws URISyntaxException, InterruptedException {
+        System.out.println("Running HTTP/2 Server Push example...");
+
+        HttpClient httpClient = HttpClient.newBuilder()
+            .version(Version.HTTP_2)
+            .build();
+
+        HttpRequest pageRequest = HttpRequest.newBuilder()
+            .uri(URI.create("https://http2.golang.org/serverpush"))
+            .build();
+
+        // Interface HttpResponse.PushPromiseHandler<T>
+        // void applyPushPromise​(HttpRequest initiatingRequest, HttpRequest pushPromiseRequest, Function<HttpResponse.BodyHandler<T>,​CompletableFuture<HttpResponse<T>>> acceptor)
+        httpClient.sendAsync(pageRequest, BodyHandlers.ofString(), pushPromiseHandler())
+            .thenAccept(pageResponse -> {
+                System.out.println("Page response status code: " + pageResponse.statusCode());
+                System.out.println("Page response headers: " + pageResponse.headers());
+                String responseBody = pageResponse.body();
+                System.out.println(responseBody);
+            }).join();
+
+        Thread.sleep(1000); // waiting for full response
+    }
+
+    private static PushPromiseHandler<String> pushPromiseHandler() {
+        return (HttpRequest initiatingRequest, 
+            HttpRequest pushPromiseRequest, 
+            Function<HttpResponse.BodyHandler<String>, 
+            CompletableFuture<HttpResponse<String>>> acceptor) -> {
+            acceptor.apply(BodyHandlers.ofString())
+                .thenAccept(resp -> {
+                    System.out.println(" Pushed response: " + resp.uri() + ", headers: " + resp.headers());
+                });
+            System.out.println("Promise request: " + pushPromiseRequest.uri());
+            System.out.println("Promise request: " + pushPromiseRequest.headers());
+        };
+    }
+
+}