Agrego el EB en el cliente JS y el Veticle Principal

Author: neodevelop

Diff for: webserver/src/main/groovy/com/makingdevs/MainVerticle.groovy

@@ -2,45 +2,53 @@ package com.makingdevs
 
 import io.vertx.core.AbstractVerticle
 import io.vertx.ext.web.Router
+import io.vertx.ext.bridge.PermittedOptions
+import io.vertx.ext.web.handler.sockjs.SockJSBridgeOptions
+import io.vertx.ext.web.handler.sockjs.SockJSHandler
+import io.vertx.reactivex.ext.shell.*
+import io.vertx.ext.shell.term.TelnetTermOptions
+import io.vertx.ext.shell.ShellServiceOptions
+import io.vertx.ext.shell.ShellService
 
 class MainVerticle extends AbstractVerticle {
 
-  private List clients = []
-
   @Override
   void start() {
-    Router router = Router.router(vertx);
-
-    router.route("/ws").handler { ctx ->
-      ctx.request().toWebSocket().onSuccess { ws ->
-        println "Nuevo cliente ${ws.properties}"
-        clients << ws
-
-        ws.textMessageHandler { message ->
-          println "Mensaje recibido: ${message}"
-          // broadcastMessage("Cliente: $message")
-          clients.each { c ->
-            c.writeTextMessage(message)
-          }
-        }
-
-        ws.closeHandler {
-          println "Cliente desconectado"
-          clients.remove(ws)
-        }
-
-        ws.exceptionHandler { error ->
-          println "ERROR en WS: ${error.message}"
-          clients.remove(ws)
-        }
-      }
+    Router router = Router.router(vertx)
+
+    PermittedOptions permittedOptions = new PermittedOptions()
+      .setAddressRegex("chat\\..+");
+
+    SockJSHandler sockJSHandler = SockJSHandler.create(vertx)
+    SockJSBridgeOptions options = new SockJSBridgeOptions()
+      .addInboundPermitted(permittedOptions)
+      .addOutboundPermitted(permittedOptions)
+
+    router.route("/eventbus/*").subRouter(sockJSHandler.bridge(options))
+
+    vertx.eventBus().consumer("chat.publish") { msg ->
+      println "Msg recibido en 'chat.general': ${msg.body()}"
+      vertx.eventBus().publish("chat.general", msg.body())
     }
 
+    // vertx.setPeriodic(10000) { id ->
+    //   vertx.eventBus().publish("chat.general", "Timestamp: ${new Date()}")
+    // }
+
+    ShellService service = ShellService.create(vertx,
+      new ShellServiceOptions().setTelnetOptions(
+        new TelnetTermOptions().
+        setHost("localhost").
+        setPort(4000)
+      )
+    );
+    service.start();
+
     vertx.createHttpServer()
       .requestHandler(router)
       .listen(8082) { http ->
         if(http.succeeded())
-          println "Servidor HTTP en http://localhost:8082"
+          println "Servidor HTTP en http://localhost:8082/eventbus"
         else
           println "Error al iniciar el server: ${http.cause()}"
 

Diff for: webserver/src/main/groovy/com/makingdevs/MainVerticleModulo7.groovy

@@ -0,0 +1,49 @@
+package com.makingdevs
+
+import io.vertx.core.AbstractVerticle
+import io.vertx.ext.web.Router
+
+class MainVerticleModulo7 extends AbstractVerticle {
+
+  private List clients = []
+
+  @Override
+  void start() {
+    Router router = Router.router(vertx);
+
+    router.route("/ws").handler { ctx ->
+      ctx.request().toWebSocket().onSuccess { ws ->
+        println "Nuevo cliente ${ws.properties}"
+        clients << ws
+
+        ws.textMessageHandler { message ->
+          println "Mensaje recibido: ${message}"
+          // broadcastMessage("Cliente: $message")
+          clients.each { c ->
+            c.writeTextMessage(message)
+          }
+        }
+
+        ws.closeHandler {
+          println "Cliente desconectado"
+          clients.remove(ws)
+        }
+
+        ws.exceptionHandler { error ->
+          println "ERROR en WS: ${error.message}"
+          clients.remove(ws)
+        }
+      }
+    }
+
+    vertx.createHttpServer()
+      .requestHandler(router)
+      .listen(8082) { http ->
+        if(http.succeeded())
+          println "Servidor HTTP en http://localhost:8082"
+        else
+          println "Error al iniciar el server: ${http.cause()}"
+
+      }
+  }
+}

Diff for: webserver/src/main/resources/eventbus-client.html

@@ -0,0 +1,51 @@
+<!DOCTYPE html>
+<html lang="en">
+<head>
+  <meta charset="UTF-8">
+  <title>WS Client</title>
+  <script src="https://unpkg.io/[email protected]/dist/sockjs.min.js"></script>
+  <script src='https://unpkg.io/@vertx/[email protected]/vertx-eventbus.js'></script>
+</head>
+<body>
+  <h1>Chat de WS</h1>
+  <div>
+    <label for="messae">Message:</label>
+    <input type="text" id="message" />
+    <button onclick="sendMessage()">Enviar</button>
+  </div>
+  <div id="messages">
+    <h2>Messages</h2>
+  </div>
+
+  <script>
+
+    const eventBus = new EventBus('http://localhost:8082/eventbus');
+    const messages = document.getElementById("messages");
+
+    eventBus.onopen = () => {
+      console.log("Conexión al EB establecida");
+
+      eventBus.registerHandler("chat.general", (err, message) => {
+        if(err){
+          console.error("Error:", err);
+        } else {
+          const p = document.createElement("p");
+          p.textContent = message.body;
+          messages.appendChild(p);
+        }
+      });
+    };
+
+    function sendMessage() {
+      const message = document.getElementById("message");
+      const textMessage = message.value;
+      if(message) {
+        eventBus.publish("chat.publish", textMessage);
+        message.value = "";
+      }
+    }
+
+  </script>
+
+</body>
+</html>