Merge pull request vert-x#20 from vert-x3/http-server-sharing-example

cescoffier · cescoffier · commit 36dcd5385882 · 2015-06-04T12:00:02.000+02:00
Add an example illustrating the HTTP Server sharing
diff --git a/core-examples/src/main/groovy/io/vertx/example/core/http/sharing/client.groovy b/core-examples/src/main/groovy/io/vertx/example/core/http/sharing/client.groovy
@@ -0,0 +1,9 @@
+
+vertx.setPeriodic(100, { l ->
+  vertx.createHttpClient().getNow(8080, "localhost", "/", { resp ->
+    resp.bodyHandler({ body ->
+      println(body.toString("ISO-8859-1"))
+    })
+  })
+})
+
diff --git a/core-examples/src/main/java/io/vertx/example/core/http/sharing/Client.java b/core-examples/src/main/java/io/vertx/example/core/http/sharing/Client.java
@@ -0,0 +1,30 @@
+package io.vertx.example.core.http.sharing;
+
+import io.vertx.core.AbstractVerticle;
+import io.vertx.example.util.Runner;
+
+/**
+ * A client illustrating the round robin made by vert.x. The client send a request to the server periodically and
+ * print the received messages.
+ */
+public class Client extends AbstractVerticle {
+
+  // Convenience method so you can run it in your IDE
+  public static void main(String[] args) {
+    Runner.runExample(Client.class);
+  }
+
+  @Override
+  public void start() throws Exception {
+
+    vertx.setPeriodic(100, (l) -> {
+          vertx.createHttpClient().getNow(8080, "localhost", "/", resp -> {
+            resp.bodyHandler(body -> {
+              System.out.println(body.toString("ISO-8859-1"));
+            });
+          });
+        }
+    );
+
+  }
+}
diff --git a/core-examples/src/main/java/io/vertx/example/core/http/sharing/Server.java b/core-examples/src/main/java/io/vertx/example/core/http/sharing/Server.java
@@ -0,0 +1,40 @@
+package io.vertx.example.core.http.sharing;
+
+import io.vertx.core.AbstractVerticle;
+import io.vertx.example.util.Runner;
+
+/**
+ * An example illustrating the server sharing and round robin. The servers are identified using an id.
+ */
+public class Server extends AbstractVerticle {
+
+  // Convenience method so you can run it in your IDE
+  public static void main(String[] args) {
+    Runner.runExample(Server.class);
+  }
+
+  @Override
+  public void start() throws Exception {
+    getVertx().deployVerticle(new HttpVerticle("server-1"));
+    getVertx().deployVerticle(new HttpVerticle("server-2"));
+  }
+
+
+  private class HttpVerticle extends AbstractVerticle {
+
+    private final String id;
+
+    private HttpVerticle(String id) {
+      this.id = id;
+    }
+
+
+    @Override
+    public void start() throws Exception {
+      vertx.createHttpServer().requestHandler(req -> {
+        req.response().putHeader("content-type", "text/html").end("<html><body><h1>Hello from " +
+            id + "</h1></body></html>");
+      }).listen(8080);
+    }
+  }
+}
diff --git a/core-examples/src/main/js/io/vertx/example/core/http/sharing/client.js b/core-examples/src/main/js/io/vertx/example/core/http/sharing/client.js
@@ -0,0 +1,9 @@
+
+vertx.setPeriodic(100, function (l) {
+  vertx.createHttpClient().getNow(8080, "localhost", "/", function (resp) {
+    resp.bodyHandler(function (body) {
+      console.log(body.toString("ISO-8859-1"));
+    });
+  });
+});
+
diff --git a/core-examples/src/main/rb/io/vertx/example/core/http/sharing/client.rb b/core-examples/src/main/rb/io/vertx/example/core/http/sharing/client.rb
@@ -0,0 +1,9 @@
+
+$vertx.set_periodic(100) { |l|
+  $vertx.create_http_client().get_now(8080, "localhost", "/") { |resp|
+    resp.body_handler() { |body|
+      puts body.to_string("ISO-8859-1")
+    }
+  }
+}
+
