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

HttpServer.requestHandler介绍

暂无

代码示例

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

@Override
 public void start(Future<Void> startFuture) throws Exception {
  HttpServer server = vertx.createHttpServer(new HttpServerOptions().setPort(8080));
  server.requestHandler(req -> req.response().end());
  server.listen(res -> {
   if (res.succeeded()) {
    startFuture.complete();
   } else {
    startFuture.fail(res.cause());
   }
  });
 }
}

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

@Test
public void testListenTwice2() throws Exception {
 server.requestHandler(noOpHandler());
 server.listen(ar -> {
  assertTrue(ar.succeeded());
  assertIllegalStateException(() -> server.listen());
  testComplete();
 });
 await();
}

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

@Test
public void testRequestBodyBufferAtEnd() {
 Buffer body = TestUtils.randomBuffer(1000);
 server.requestHandler(req -> req.bodyHandler(buffer -> {
  assertEquals(body, buffer);
  req.response().end();
 }));
 server.listen(onSuccess(server -> {
  client.request(HttpMethod.POST, DEFAULT_HTTP_PORT, DEFAULT_HTTP_HOST, DEFAULT_TEST_URI, resp -> testComplete()).end(body);
 }));
 await();
}

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

@Test
public void testSharedServersRoundRobinWithOtherServerRunningOnDifferentPort() throws Exception {
 // Have a server running on a different port to make sure it doesn't interact
 CountDownLatch latch = new CountDownLatch(1);
 HttpServer theServer = vertx.createHttpServer(new HttpServerOptions().setPort(8081));
 theServer.requestHandler(req -> {
  fail("Should not process request");
 }).listen(onSuccess(s -> latch.countDown()));
 awaitLatch(latch);
 testSharedServersRoundRobin();
}

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

@Test
public void testHostHeaderOverridePossible() {
 server.requestHandler(req -> {
  assertEquals("localhost:4444", req.host());
  req.response().end();
 });
 server.listen(onSuccess(s -> {
  HttpClientRequest req = client.request(HttpMethod.GET, DEFAULT_HTTP_PORT, DEFAULT_HTTP_HOST, DEFAULT_TEST_URI, resp -> testComplete());
  req.setHost("localhost:4444");
  req.end();
 }));
 await();
}

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

@Test
public void testListenTwice() throws Exception {
 server.requestHandler(noOpHandler());
 server.listen(onSuccess(v -> testComplete()));
 assertIllegalStateException(() -> server.listen());
 await();
}

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

@Test
public void testDefaultHttpVersion() {
 server.requestHandler(req -> {
  assertEquals(HttpVersion.HTTP_1_1, req.version());
  req.response().end();
 });
 server.listen(onSuccess(s -> {
  client.request(HttpMethod.GET, DEFAULT_HTTP_PORT, DEFAULT_HTTP_HOST, DEFAULT_TEST_URI, onSuccess(resp -> resp.endHandler(v -> testComplete()))).end();
 }));
 await();
}

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

@Test
public void testListenInvalidPort() throws Exception {
 /* Port 7 is free for use by any application in Windows, so this test fails. */
 Assume.assumeFalse(System.getProperty("os.name").startsWith("Windows"));
 server.close();
 server = vertx.createHttpServer(new HttpServerOptions().setPort(7));
 server.requestHandler(noOpHandler()).listen(onFailure(server -> testComplete()));
 await();
}

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

@Test
public void testKeepAliveTimeoutHeader() throws Exception {
 AtomicBoolean sent = new AtomicBoolean();
 server.requestHandler(req -> {
  if (sent.compareAndSet(false, true)) {
   req.response().putHeader("keep-alive", "timeout=3").end();
  }
 });
 testKeepAliveTimeout(new HttpClientOptions().setMaxPoolSize(1).setKeepAliveTimeout(30), 1);
}

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

@Test
public void testSetHandlersAfterListening() throws Exception {
 server.requestHandler(noOpHandler());
 server.listen(onSuccess(s -> {
  assertIllegalStateException(() -> server.requestHandler(noOpHandler()));
  assertIllegalStateException(() -> server.websocketHandler(noOpHandler()));
  testComplete();
 }));
 await();
}

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

@Test
public void testKeepAliveTimeoutHeaderReusePrevious() throws Exception {
 AtomicBoolean sent = new AtomicBoolean();
 server.requestHandler(req -> {
  HttpServerResponse resp = req.response();
  if (sent.compareAndSet(false, true)) {
   resp.putHeader("keep-alive", "timeout=3");
  }
  resp.end();
 });
 testKeepAliveTimeout(new HttpClientOptions().setMaxPoolSize(1).setKeepAliveTimeout(30), 2);
}

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

@Test
public void testSetHandlersAfterListening2() throws Exception {
 server.requestHandler(noOpHandler());
 server.listen(onSuccess(v -> testComplete()));
 assertIllegalStateException(() -> server.requestHandler(noOpHandler()));
 assertIllegalStateException(() -> server.websocketHandler(noOpHandler()));
 await();
}

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

@Test
public void testServerChainingSendFile() throws Exception {
 File file = setupFile("test-server-chaining.dat", "blah");
 server.requestHandler(req -> {
  assertTrue(req.response().sendFile(file.getAbsolutePath()) == req.response());
  assertTrue(req.response().ended());
  file.delete();
  testComplete();
 });
 server.listen(onSuccess(server -> {
  client.request(HttpMethod.PUT, DEFAULT_HTTP_PORT, DEFAULT_HTTP_HOST, DEFAULT_TEST_URI, noOpHandler()).end();
 }));
 await();
}

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

@Test
public void testListenInvalidHost() {
 server.close();
 server = vertx.createHttpServer(new HttpServerOptions().setPort(DEFAULT_HTTP_PORT).setHost("iqwjdoqiwjdoiqwdiojwd"));
 server.requestHandler(noOpHandler());
 server.listen(onFailure(s -> testComplete()));
}

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

@Test
public void testRandomPorts() throws Exception {
 int numServers = 10;
 Set<Integer> ports = Collections.synchronizedSet(new HashSet<>());
 AtomicInteger count = new AtomicInteger();
 for (int i = 0;i < numServers;i++) {
  vertx.createHttpServer().requestHandler(req -> {
   req.response().end();
  }).listen(0, DEFAULT_HTTP_HOST, onSuccess(s -> {
   int port = s.actualPort();
   ports.add(port);
   client.getNow(port, DEFAULT_HTTP_HOST, "/somepath", resp -> {
    if (count.incrementAndGet() == numServers) {
     assertEquals(numServers, ports.size());
     testComplete();
    }
   });
  }));
 }
 await();
}

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

@Test
public void testKeepAliveTimeout() throws Exception {
 server.requestHandler(req -> {
  req.response().end();
 });
 testKeepAliveTimeout(new HttpClientOptions().setMaxPoolSize(1).setKeepAliveTimeout(3), 1);
}

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

@Test
public void testRemoteAddress() {
 server.requestHandler(req -> {
  assertEquals("127.0.0.1", req.remoteAddress().host());
  req.response().end();
 });
 server.listen(onSuccess(s -> {
  client.request(HttpMethod.GET, DEFAULT_HTTP_PORT, DEFAULT_HTTP_HOST, DEFAULT_TEST_URI, onSuccess(resp -> resp.endHandler(v -> testComplete()))).end();
 }));
 await();
}

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

@Test
public void testGetAbsoluteURI() {
 server.requestHandler(req -> {
  assertEquals(req.scheme() + "://localhost:" + DEFAULT_HTTP_PORT + "/foo/bar", req.absoluteURI());
  req.response().end();
 });
 server.listen(onSuccess(s -> {
  client.request(HttpMethod.GET, DEFAULT_HTTP_PORT, DEFAULT_HTTP_HOST, "/foo/bar", onSuccess(resp -> resp.endHandler(v -> testComplete()))).end();
 }));
 await();
}

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

@Test
public void testNoParams() {
 server.requestHandler(req -> {
  assertNull(req.query());
  assertTrue(req.params().isEmpty());
  req.response().end();
 });
 server.listen(onSuccess(server -> {
  client.request(HttpMethod.GET, DEFAULT_HTTP_PORT, DEFAULT_HTTP_HOST, DEFAULT_TEST_URI, resp -> testComplete()).end();
 }));
 await();
}

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

@Test
public void testSendFileNotFound() throws Exception {
 server.requestHandler(req -> {
  req.response().putHeader("Content-Type", "wibble");
  req.response().sendFile("nosuchfile.html");
 });
 server.listen(onSuccess(s -> {
  client.request(HttpMethod.GET, DEFAULT_HTTP_PORT, DEFAULT_HTTP_HOST, DEFAULT_TEST_URI, onFailure(err -> {})).end();
  vertx.setTimer(100, tid -> testComplete());
 }));
 await();
}