Merge branch 'galderz-t_sockjs_java'

Author: cescoffier

web-examples/README.adoc

@@ -134,6 +134,10 @@ Before running the example you need to download the dependencies, the easiest fo
 
 Run the server either in your IDE or on the command line, then run the node client `npm start`.
 
+== EventBus Bridge - Java client
+
+The link:src/main/java/io/vertx/example/web/vertxbus/java contains an example of communication between a client and a service using the SockJS event bus. This example is written in java, and the client interacts using SockJS (in Java, using the web socket protocol).
+
 == Real-time - client side event bus
 
 This example demonstrates a full duplex connection between the browser and the server side.
@@ -167,18 +171,18 @@ When you get the index page in your browser you should see it update every secon
 == Real-time - chat service
 
 This example demonstrates 2-way communication between the client and the server using the event bus bridge
-and web sockets. 
+and web sockets.
 
 The link:src/main/java/io/vertx/example/web/chat/Server.java[Java real-time chat example]
 
 The link:src/main/java/io/vertx/example/web/chat/webroot/index.html[index.html] file
 bootstraps the vertxbus.js bridge from the client and uses jQuery to handle manipulating
 the DOM and registering event handlers.
 
-When you load the index page in a browser, you should see a div for chat messages and 
-an input field where you can enter your own messages. Typing in the input field and 
+When you load the index page in a browser, you should see a div for chat messages and
+an input field where you can enter your own messages. Typing in the input field and
 pressing ENTER will cause the input to be sent via the event bus to the server. The server
-will accept the message, prepend it with a timestamp and publish back to all registered 
+will accept the message, prepend it with a timestamp and publish back to all registered
 listeners (e.g. All connected clients). Take note of the addInboundPermitted and addOutboundPermitted
 settings on the BridgeOptions object to be sure that you authorize the correct messages
 to traverse the event bus bridge in the appropriate direction.

web-examples/src/main/java/io/vertx/example/web/vertxbus/java/Client.java

@@ -0,0 +1,33 @@
+package io.vertx.example.web.vertxbus.java;
+
+import io.vertx.core.Vertx;
+import io.vertx.core.http.HttpClient;
+import io.vertx.core.http.WebSocket;
+import io.vertx.core.json.JsonObject;
+
+public class Client {
+
+  public static void main(String[] args) {
+    Vertx vertx = Vertx.vertx();
+    HttpClient client = vertx.createHttpClient();
+
+    client.websocket(8080, "localhost", "/eventbus/websocket", ws -> {
+      System.out.println("Connected");
+      sendPing(ws);
+
+      vertx.setPeriodic(5000, id -> sendPing(ws));
+
+      // Register
+      JsonObject msg = new JsonObject().put("type", "register").put("address", "feed");
+      ws.writeFrame(io.vertx.core.http.WebSocketFrame.textFrame(msg.encode(), true));
+
+      ws.handler(System.out::println);
+    }, fail -> System.out.println("Failed: " + fail));
+  }
+
+  private static void sendPing(WebSocket ws) {
+    JsonObject msg = new JsonObject().put("type", "ping");
+    ws.writeFrame(io.vertx.core.http.WebSocketFrame.textFrame(msg.encode(), true));
+  }
+
+}

web-examples/src/main/java/io/vertx/example/web/vertxbus/java/Server.java

@@ -0,0 +1,58 @@
+package io.vertx.example.web.vertxbus.java;
+
+import java.text.DateFormat;
+import java.time.Instant;
+import java.util.Date;
+
+import io.vertx.core.AbstractVerticle;
+import io.vertx.core.eventbus.EventBus;
+import io.vertx.core.json.JsonObject;
+import io.vertx.example.util.Runner;
+import io.vertx.ext.web.Router;
+import io.vertx.ext.web.handler.sockjs.BridgeOptions;
+import io.vertx.ext.web.handler.sockjs.PermittedOptions;
+import io.vertx.ext.web.handler.sockjs.SockJSHandler;
+
+/**
+ * A {@link io.vertx.core.Verticle} which bridges Java to the @{link EventBus}.
+ */
+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 {
+
+    Router router = Router.router(vertx);
+
+    // Allow events for the designated addresses in/out of the event bus bridge
+    BridgeOptions opts = new BridgeOptions()
+        .addOutboundPermitted(new PermittedOptions().setAddress("feed"));
+
+    // Create the event bus bridge and add it to the router.
+    SockJSHandler ebHandler = SockJSHandler.create(vertx).bridge(opts);
+    router.route("/eventbus/*").handler(ebHandler);
+
+    // Start the web server and tell it to use the router to handle requests.
+    vertx.createHttpServer().requestHandler(router::accept)
+      .listen(8080, "localhost", ar -> {
+        if (ar.succeeded()) {
+          System.out.printf("Server started on localhost:%s", ar.result().actualPort());
+        } else if (ar.failed()) {
+          System.out.printf("Failed: %s", ar.cause());
+        }
+      });
+
+    EventBus eb = vertx.eventBus();
+
+    vertx.setPeriodic(1000L, t -> {
+      // Create a timestamp string
+      String timestamp = DateFormat.getDateTimeInstance(DateFormat.SHORT, DateFormat.MEDIUM).format(Date.from(Instant.now()));
+
+      eb.send("feed", new JsonObject().put("now", timestamp));
+    });
+  }
+}