The MicroMonolith!!

billoneil · billoneil · commit 73e655ea2616 · 2017-08-15T23:48:31.000-04:00
diff --git a/stubbornjava-examples/src/main/java/com/stubbornjava/examples/undertow/MicroMonolith.java b/stubbornjava-examples/src/main/java/com/stubbornjava/examples/undertow/MicroMonolith.java
@@ -0,0 +1,74 @@
+package com.stubbornjava.examples.undertow;
+
+import com.stubbornjava.common.undertow.Exchange;
+import com.stubbornjava.examples.undertow.contenttypes.ContentTypesServer;
+import com.stubbornjava.examples.undertow.rest.RestServer;
+import com.stubbornjava.examples.undertow.routing.ConstantStringHandler;
+
+import io.undertow.Undertow;
+import io.undertow.server.HttpHandler;
+import io.undertow.server.RoutingHandler;
+
+public class MicroMonolith {
+
+    public static void main(String[] args) {
+
+        // {{start:restServer}}
+        Undertow.builder()
+                .addHttpListener(8080, "0.0.0.0", RestServer.ROOT)
+                .build()
+                .start();
+        // {{end:restServer}}
+
+        // {{start:contentTypesServer}}
+        Undertow.builder()
+                .addHttpListener(8081, "0.0.0.0", ContentTypesServer.ROUTES)
+                .build()
+                .start();
+        // {{end:contentTypesServer}}
+
+        // {{start:multiPortServer}}
+        Undertow.builder()
+                .addHttpListener(8082, "0.0.0.0", RestServer.ROOT)
+                .addHttpListener(8083, "0.0.0.0", ContentTypesServer.ROUTES)
+                .build()
+                .start();
+        // {{end:multiPortServer}}
+
+        // {{start:combinedServer}}
+        RoutingHandler combinedHanlder = new RoutingHandler().addAll(RestServer.ROUTES)
+                                                             .addAll(ContentTypesServer.ROUTES);
+        Undertow.builder()
+                .addHttpListener(8084, "0.0.0.0", combinedHanlder)
+                .build()
+                .start();
+        // {{end:combinedServer}}
+
+        // {{start:microserviceService}}
+        Undertow.builder()
+                .addHttpListener(8085, "0.0.0.0", exchange -> {
+            Integer port = Exchange.queryParams()
+                                   .queryParamAsInteger(exchange, "port")
+                                   .orElse(null);
+            if (null != port) {
+                try {
+                    HttpHandler handler = new ConstantStringHandler("web server with port " + port);
+                    Undertow.builder()
+                            .addHttpListener(port, "0.0.0.0", handler)
+                            .build()
+                            .start();
+                } catch (Exception e) {
+                    String message = "error trying to create web sertver with port " + port;
+                    Exchange.body().sendText(exchange, message);
+                    return;
+                }
+                Exchange.body().sendText(exchange, "server with port " + port + " created");
+                return;
+            }
+            Exchange.body().sendText(exchange, "port cannot be null");
+        })
+        .build()
+        .start();
+        // {{end:microserviceService}}
+    }
+}
diff --git a/stubbornjava-examples/src/main/java/com/stubbornjava/examples/undertow/contenttypes/ContentTypesServer.java b/stubbornjava-examples/src/main/java/com/stubbornjava/examples/undertow/contenttypes/ContentTypesServer.java
@@ -2,7 +2,6 @@
 
 import com.stubbornjava.common.undertow.SimpleServer;
 
-import io.undertow.server.HttpHandler;
 import io.undertow.server.RoutingHandler;
 
 public class ContentTypesServer {
@@ -17,7 +16,7 @@ public class ContentTypesServer {
      * to be a CSI cyber crimes specialist ripping apart some code for a clue to
      * whatever it does.
      */
-    private static final HttpHandler ROUTES = new RoutingHandler()
+    public static final RoutingHandler ROUTES = new RoutingHandler()
         .get("/helloWorldText", ContentTypeHandlers::helloWorldText)
         .get("/helloWorldHtml", ContentTypeHandlers::helloWorldHtml)
         .get("/helloWorldFileDownload", ContentTypeHandlers::helloWorldFileDownload)
diff --git a/stubbornjava-examples/src/main/java/com/stubbornjava/examples/undertow/rest/RestServer.java b/stubbornjava-examples/src/main/java/com/stubbornjava/examples/undertow/rest/RestServer.java
@@ -16,7 +16,7 @@
 public class RestServer {
 
     // {{start:routes}}
-    private static final HttpHandler ROUTES = new RoutingHandler()
+    public static final RoutingHandler ROUTES = new RoutingHandler()
         .get("/users", timed("listUsers", UserRoutes::listUsers))
         .get("/users/{email}", timed("getUser", UserRoutes::getUser))
         .get("/users/{email}/exception", timed("getUser", UserRoutes::getUserThrowNotFound))
@@ -38,7 +38,7 @@ public class RestServer {
         ROUTES.handleRequest(exchange);
     };
 
-    private static final HttpHandler ROOT = CustomHandlers.exception(EXCEPTION_THROWER)
+    public static final HttpHandler ROOT = CustomHandlers.exception(EXCEPTION_THROWER)
         .addExceptionHandler(ApiException.class, ApiHandlers::handleApiException)
         .addExceptionHandler(Throwable.class, ApiHandlers::serverError)
     ;
