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

HttpServer.requestHandler介绍

[英]Get the request handler
[中]获取请求处理程序

代码示例

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

@Override public void onUnsubscribed() {
 core.requestHandler(null);
}
@Override public RxHttpServerRequest wrap(HttpServerRequest r) {

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

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

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

/**
 * Creates or gets the server route handler.
 */
public Value requestHandler(final Env env, @Optional final RouteMatcher matcher) {
 if (matcher != null) {
  server.requestHandler(new org.vertx.java.core.Handler<org.vertx.java.core.http.HttpServerRequest>() {
   @Override
   public void handle(org.vertx.java.core.http.HttpServerRequest request) {
    matcher.handle(env, request);
   }
  });
  return env.wrapJava(this);
 }
 else {
  return env.wrapJava(server.requestHandler());
 }
}

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

@Override
public void init(Map<String,Object> config) {
  LOG.info("Initializing the ApiMan Engine..");
  vertx = (Vertx) config.get(ApiManagerService.VERTX);
  httpGateway = (HttpGateway) config.get(ApiManagerService.HTTP_GATEWAY);
  String port = (String) config.get(ApiManagerService.PORT);
  engine = new Engine().create(vertx, httpGateway, port);
  engineRestServer = vertx.createHttpServer();
  int portRest = Integer.valueOf(port) - 1;
  if (config.containsKey(ApiManagerService.PORT_REST)) portRest = (Integer) config.get(ApiManagerService.PORT_REST);
  engineRestServer.requestHandler(new ApiManRestRequestHandler(engine));
  engineRestServer.listen(portRest, "0.0.0.0");
  LOG.info("The ApiMan REST Service is listening at '0.0.0.0' on port " + portRest);
  System.out.println("Apiman Admin at 0.0.0.0:8999");
}

代码示例来源：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: etsy/statsd-jvm-profiler

/**
   * Start an embedded HTTP server
   *
   * @param activeProfilers The active profilers
   * @param port The port on which to bind the server
   */
  public static void startServer(final Map<String, ScheduledFuture<?>> runningProfilers, final Map<String, Profiler> activeProfilers, final int port, final AtomicReference<Boolean> isRunning, final List<String> errors) {
    final HttpServer server = VERTX.createHttpServer();
    server.requestHandler(RequestHandler.getMatcher(runningProfilers, activeProfilers, isRunning, errors));
    server.listen(port, new Handler<AsyncResult<HttpServer>>() {
      @Override
      public void handle(AsyncResult<HttpServer> event) {
        if (event.failed()) {
          server.close();
          startServer(runningProfilers, activeProfilers, port + 1, isRunning, errors);
        } else if (event.succeeded()) {
          LOGGER.info("Profiler server started on port " + 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: 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: vert-x/mod-lang-php

/**
 * Creates or gets the server request handler.
 * 
 * @param handler
 *          An optional handler. If no handler is provided then the current
 *          request handler will be returned.
 */
public Value requestHandler(Env env, @Optional Value handler) {
 if (PhpTypes.notNull(handler)) {
  PhpTypes.assertCallable(env, handler,
    "Handler argument to Vertx\\Http\\HttpServer::requestHandler() must be callable.");
 }
 if (PhpTypes.isCallable(env, handler)) {
  server.requestHandler(new Handler<org.vertx.java.core.http.HttpServerRequest>(env, PhpTypes.toCallable(handler),
    new ResultModifier<org.vertx.java.core.http.HttpServerRequest, HttpServerRequest>() {
     @Override
     public HttpServerRequest modify(org.vertx.java.core.http.HttpServerRequest request) {
      return new HttpServerRequest(request);
     }
    }));
  return env.wrapJava(this);
 }
 else {
  return env.wrapJava(server.requestHandler());
 }
}

代码示例来源：origin: OlivierCroisier/LP4J

/**
 * Constructor.
 *
 * @param httpPort The HTTP port on which the emulator should run.
 */
public EmulatorLaunchpad(int httpPort) {
  vertx = VertxFactory.newVertx();
  // Static files
  HttpServer httpServer = vertx.createHttpServer();
  httpServer.requestHandler(new WebResourceHandler());
  // Eventbus bridge
  JsonObject bridgeConfig = new JsonObject().putString("prefix", EVENTBUS_ADDRESS);
  JsonArray credentialsPermitAll = new JsonArray().add(new JsonObject());
  vertx.createSockJSServer(httpServer).bridge(bridgeConfig, credentialsPermitAll, credentialsPermitAll);
  vertx.eventBus().registerLocalHandler(EVENTBUS_SERVER_HANDLER_ID, eventBusHandler);
  System.out.println("Launchpad emulator is ready on http://localhost:" + httpPort + "/");
  httpServer.listen(httpPort);
}

代码示例来源：origin: com.englishtown/vertx-mod-jersey

server.requestHandler(rm);

代码示例来源：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());
}

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

server.requestHandler(routeMatcher());
server.requestHandler(staticHandler());