import org.vertx.java.core.sockjs.SockJSServer; //导入依赖的package包/类
private void startSockJSServer() {
    HttpServer httpServer = vertx.createHttpServer();

    SockJSServer sockJSServer = vertx.createSockJSServer(httpServer);

    JsonObject config = new JsonObject().putString("prefix", "/chat");
    sockJSServer.installApp(config, new Handler<SockJSSocket>() {
        public void handle(final SockJSSocket sock) {
            vertx.sharedData().getSet(SHARED_DATA_SOCKET_IDS).add(sock.writeHandlerID());
            sock.endHandler(new Handler<Void>() {
                @Override
                public void handle(Void aVoid) {
                    vertx.sharedData().getSet(SHARED_DATA_SOCKET_IDS).remove(sock.writeHandlerID());
                }
            });
        }
    });
    httpServer.listen(8083);
}
 

import org.vertx.java.core.sockjs.SockJSServer; //导入依赖的package包/类
public void bridge(final CountingCompletionHandler<Void> countDownLatch) {
  HttpServer server = vertx.createHttpServer();
  SockJSServer sjsServer = vertx.createSockJSServer(server).setHook(hook);
  JsonObject empty = new JsonObject();
  JsonArray all = new JsonArray().add(empty);
  JsonArray inboundPermitted = config.getArray("inbound_permitted", all);
  JsonArray outboundPermitted = config.getArray("outbound_permitted", all);

  sjsServer.bridge(config.getObject("sjs_config", new JsonObject()
      .putString("prefix", "/channel")), inboundPermitted, outboundPermitted, config.getObject(
      "bridge_config", empty));

  countDownLatch.incRequired();
  server.listen(config.getInteger("port", 1986), config.getString("host", "0.0.0.0"),
      new AsyncResultHandler<HttpServer>() {
        @Override
        public void handle(AsyncResult<HttpServer> ar) {
          if (!ar.succeeded()) {
            countDownLatch.failed(ar.cause());
          } else {
            countDownLatch.complete();
          }
        }
      });
}
 

import org.vertx.java.core.sockjs.SockJSServer; //导入依赖的package包/类
public void start() {

        RouteMatcher routeMatcher = new RouteMatcher();

        // HTTP server
        HttpServer httpServer = vertx.createHttpServer();
        httpServer.requestHandler(routeMatcher);

        // SockJS server
        JsonArray permitted = new JsonArray();
        permitted.add(new JsonObject()); // Let everything through
        SockJSServer sockJSServer = vertx.createSockJSServer(httpServer);
        sockJSServer.bridge(new JsonObject().putString("prefix", "/eventbus"), permitted, permitted);

        httpServer.listen(7777);

        System.out.println("Vert.X Core UP");
    }
 

import org.vertx.java.core.sockjs.SockJSServer; //导入依赖的package包/类
@Override
public void start() {
    final HttpServer httpServer = vertx.createHttpServer();
    final SockJSServer sockJSServer = vertx.createSockJSServer(httpServer);
    final JsonObject config = new JsonObject().putString("prefix", "/echo");
    sockJSServer.installApp(config, new Handler<SockJSSocket>() {
        public void handle(final SockJSSocket sock) {

        }
    });
    httpServer.listen(8080);
}
 

import org.vertx.java.core.sockjs.SockJSServer; //导入依赖的package包/类
@Override
public SockJSServer createSockJSServer(HttpServer httpServer) {
  return null;
}
 

import org.vertx.java.core.sockjs.SockJSServer; //导入依赖的package包/类
@Override
public SockJSServer createSockJSServer(HttpServer httpServer) {
    return null;
}
 

import org.vertx.java.core.sockjs.SockJSServer; //导入依赖的package包/类
@Override
void start(final JsonObject appConfig, HttpServer server) {

    eb              = vertx.eventBus();
    channel         = appConfig.getString("channel");
    sessionStore    = vertx.sharedData().getMap("_REFER_STORAGE");

    List<Module> deployments = new ArrayList<Module>();
    deployments.add(new Module(SubscribeManager.class.getName() , appConfig, 1, false   ));
    deployments.add(new Module(NodeWatchManager.class.getName() , appConfig, 1, false   ));
    deployments.add(new Module(PublishManager.class.getName()                           ));
    deployments.add(new Module(SessionManager.class.getName()   , appConfig             ));

    deployWorkerVerticles(deployments, new Handler<Void>() {
        public void handle(Void event) {
            INFO(" *** modules are deployed. *** ");

            JsonObject createNodeAction = new JsonObject();
            createNodeAction.putString("action", "create");
            createNodeAction.putString("channel", channel);
            createNodeAction.putObject("data",
                    new JsonObject()
                            .putObject("server"	, new JsonObject()
                                    .putString("host", appConfig.getString("host"))
                                    .putNumber("port", appConfig.getNumber("port")))
                            .putObject("redis", appConfig.getObject("redis-address"))
            );

            eb.send(NodeWatchManager.class.getName(), createNodeAction, new Handler<Message<JsonObject>>() {
                public void handle(Message<JsonObject> message) {
                    if("ok".equals(message.body().getString("status"))){
                        eb.send(NodeWatchManager.class.getName(), new JsonObject().putString("action", "watch"));
                    }
                }
            });

        }
    });





    SockJSServer sockServer = vertx.createSockJSServer(server);
    sockServer.installApp(
            new JsonObject().putString("prefix", "/message"),
            new SocketMessageHandler(vertx, channel)
    );

}