本文整理了Java中org.vertx.java.core.http.HttpServer.websocketHandler()方法的一些代码示例，展示了HttpServer.websocketHandler()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。HttpServer.websocketHandler()方法的具体详情如下：
包路径：org.vertx.java.core.http.HttpServer
类名称：HttpServer
方法名：websocketHandler

HttpServer.websocketHandler介绍

[英]Get the websocket handler
[中]获取websocket处理程序

代码示例

代码示例来源：origin: io.vertx/mod-rxvertx

@Override public void execute() {
 core.websocketHandler(this);
}
@Override public void onUnsubscribed() {

代码示例来源：origin: com.github.flowersinthesand/portal-vertx

private Handler<ServerWebSocket> ws() {
  return new Handler<ServerWebSocket>() {
    Handler<ServerWebSocket> old = httpServer.websocketHandler();
    @Override
    public void handle(ServerWebSocket webSocket) {
      if (webSocket.path().startsWith(url)) {
        socketFactory.openWs(webSocket);
      }
      if (old != null) {
        old.handle(webSocket);
      }
    }
  };
}

代码示例来源：origin: io.vertx/mod-rxvertx

@Override public void onUnsubscribed() {
 core.websocketHandler(null);
}
@Override public RxServerWebSocket wrap(ServerWebSocket s) {

代码示例来源：origin: jboss-fuse/fabric8

public void init() {
  server = vertx.createHttpServer();
  server.requestHandler(handler);
  if (websocketHandler != null) {
    server.setWebSocketSubProtocols("v10.stomp", "v11.stomp", "v12.stomp", "mqttv3.1", "mqttv3.1.1");
    server.websocketHandler(websocketHandler);
  }
  if (host != null) {
    server = server.listen(port, host);
    LOG.info("Attempt listening on port " + port + " and host " + host);
  } else {
    server = server.listen(port);
    LOG.info("Attempt listening on port " + port);
  }
}

代码示例来源：origin: io.fabric8/gateway-core

public void init() {
  server = vertx.createHttpServer();
  server.requestHandler(handler);
  if( websocketHandler!=null ) {
    server.setWebSocketSubProtocols("v10.stomp", "v11.stomp", "v12.stomp", "mqttv3.1", "mqttv3.1.1");
    server.websocketHandler(websocketHandler);
  }
  if (host != null) {
    LOG.info("Listening on port " + port + " and host " + host);
    server = server.listen(port, host);
  } else {
    LOG.info("Listening on port " + port);
    server = server.listen(port);
  }
}

代码示例来源：origin: org.vert-x/vertx-core

public DefaultSockJSServer(final VertxInternal vertx, final HttpServer httpServer) {
 this.vertx = vertx;
 this.sessions = vertx.sharedData().getMap("_vertx.sockjssessions");
 // Any previous request and websocket handlers will become default handlers
 // if nothing else matches
 rm.noMatch(httpServer.requestHandler());
 wsMatcher.noMatch(new Handler<WebSocketMatcher.Match>() {
  Handler<ServerWebSocket> wsHandler = httpServer.websocketHandler();
  public void handle(WebSocketMatcher.Match match) {
   if (wsHandler != null) {
    wsHandler.handle(match.ws);
   }
  }
 });
 httpServer.requestHandler(new Handler<HttpServerRequest>() {
  @Override
  public void handle(HttpServerRequest req) {
   if (log.isTraceEnabled()) {
    log.trace("Got request in sockjs server: " + req.uri);
   }
   rm.handle(req);
  }
 });
 httpServer.websocketHandler(wsMatcher);
}

代码示例来源：origin: vert-x/mod-lang-php

/**
 * Creates or gets the server websocket handler.
 */
public Value websocketHandler(Env env, @Optional Value handler) {
 if (PhpTypes.notNull(handler)) {
  PhpTypes.assertCallable(env, handler,
    "Handler argument to Vertx\\Http\\HttpServer::websocketHandler() must be callable.");
 }
 if (PhpTypes.isCallable(env, handler)) {
  server.websocketHandler(new Handler<org.vertx.java.core.http.ServerWebSocket>(env, PhpTypes.toCallable(handler),
    new ResultModifier<org.vertx.java.core.http.ServerWebSocket, ServerWebSocket>() {
     @Override
     public ServerWebSocket modify(org.vertx.java.core.http.ServerWebSocket socket) {
      return new ServerWebSocket(socket);
     }
    }));
  return env.wrapJava(this);
 }
 else {
  return env.wrapJava(server.websocketHandler());
 }
}

代码示例来源：origin: com.github.flowersinthesand/portal-vertx

@Init
public void init() {
  RouteMatcher routeMatcher = new RouteMatcher();
  routeMatcher.get("/portal/:file.js", resource());
  routeMatcher.get(url, httpIn());
  routeMatcher.post(url, httpOut());
  routeMatcher.noMatch(httpServer.requestHandler());
  
  httpServer.requestHandler(routeMatcher);
  httpServer.websocketHandler(ws());
}

代码示例来源：origin: RichardHightower/slumberdb

private void configureAndStartHttpServer(Map<String, ClassMeta<?>> servicesDefinition) {
  HttpServer server = vertx.createHttpServer();
  server.setTCPKeepAlive(true);
  server.setTCPNoDelay(true);
  server.setSoLinger(0);
  server.setCompressionSupported(config.httpCompression());
  if (config.maxFrameSize() == -1) {
    server.setMaxWebSocketFrameSize(MAX_MESSAGE_SIZE);
    maxMessageSize = MAX_MESSAGE_SIZE;
  } else {
    server.setMaxWebSocketFrameSize(config.maxFrameSize());
    maxMessageSize = config.maxFrameSize();
  }
  if (debug) {
    logger.info("DataStoreServer::configureAndStartHttpServer()", config);
  }
  server.websocketHandler(websocketHandler())
      .requestHandler(clientRequestHandler())
      .listen(config.port());
  HttpServer admin = vertx.createHttpServer();
  admin.setTCPKeepAlive(true);
  admin.setTCPNoDelay(true);
  admin.setSoLinger(0);
  admin.setCompressionSupported(config.httpCompression());
  admin.requestHandler(adminRouteMatchers(servicesDefinition));
  admin.listen(config.adminPort());
  puts("Admin port on", config.adminPort());
}