Java 类io.vertx.core.http.HttpClient 实例源码

项目：redpipe 文件：MyResource.java

@Path("3")
@GET
public void hello3(@Suspended final AsyncResponse asyncResponse,
          // Inject the Vertx instance
          @Context Vertx vertx){
    System.err.println("Creating client");
    HttpClientOptions options = new HttpClientOptions();
    options.setSsl(true);
    options.setTrustAll(true);
    options.setVerifyHost(false);
    HttpClient client = vertx.createHttpClient(options);
    client.getNow(443,
            "www.google.com", 
            "/robots.txt", 
            resp -> {
                System.err.println("Got response");
                resp.bodyHandler(body -> {
                    System.err.println("Got body");
                    asyncResponse.resume(Response.ok(body.toString()).build());
                });
            });
    System.err.println("Created client");
}

项目：incubator-servicecomb-java-chassis 文件：TestHttpClientPoolFactory.java

@Test
public void createClientPool(@Mocked Vertx vertx, @Mocked Context context, @Mocked HttpClient httpClient) {
  new Expectations(VertxImpl.class) {
    {
      VertxImpl.context();
      result = context;
      context.owner();
      result = vertx;
      vertx.createHttpClient(httpClientOptions);
      result = httpClient;
    }
  };
  HttpClientWithContext pool = factory.createClientPool();

  Assert.assertSame(context, pool.context());
  Assert.assertSame(httpClient, pool.getHttpClient());
}

项目：incubator-servicecomb-java-chassis 文件：VertxHttpMethod.java

HttpClientRequest createRequest(HttpClient client, Invocation invocation, IpPort ipPort, String path,
    AsyncResponse asyncResp) {
  URIEndpointObject endpoint = (URIEndpointObject) invocation.getEndpoint().getAddress();
  RequestOptions requestOptions = new RequestOptions();
  requestOptions.setHost(ipPort.getHostOrIp())
      .setPort(ipPort.getPort())
      .setSsl(endpoint.isSslEnabled())
      .setURI(path);

  HttpMethod method = getMethod(invocation);
  LOGGER.debug("Sending request by rest, method={}, qualifiedName={}, path={}, endpoint={}.",
      method,
      invocation.getMicroserviceQualifiedName(),
      path,
      invocation.getEndpoint().getEndpoint());
  HttpClientRequest request = client.request(method, requestOptions, response -> {
    handleResponse(invocation, response, asyncResp);
  });
  return request;
}

项目：incubator-servicecomb-java-chassis 文件：TestVertxHttpMethod.java

@Test
public void testDoMethodNullPointerException(@Mocked HttpClient httpClient) throws Exception {
  Context context = new MockUp<Context>() {
    @Mock
    public void runOnContext(Handler<Void> action) {
      action.handle(null);
    }
  }.getMockInstance();
  HttpClientWithContext httpClientWithContext = new HttpClientWithContext(httpClient, context);

  Invocation invocation = mock(Invocation.class);
  AsyncResponse asyncResp = mock(AsyncResponse.class);

  try {
    this.doMethod(httpClientWithContext, invocation, asyncResp);
    fail("Expect to throw NullPointerException, but got none");
  } catch (NullPointerException e) {
  }
}

项目：incubator-servicecomb-java-chassis 文件：TestVertxHttpMethod.java

@Test
public void testCreateRequest() {
  HttpClient client = mock(HttpClient.class);
  Invocation invocation = mock(Invocation.class);
  OperationMeta operationMeta = mock(OperationMeta.class);
  Endpoint endpoint = mock(Endpoint.class);
  URIEndpointObject address = mock(URIEndpointObject.class);
  when(invocation.getEndpoint()).thenReturn(endpoint);
  when(endpoint.getAddress()).thenReturn(address);
  when(address.isSslEnabled()).thenReturn(false);
  when(invocation.getOperationMeta()).thenReturn(operationMeta);
  RestOperationMeta swaggerRestOperation = mock(RestOperationMeta.class);
  when(operationMeta.getExtData(RestConst.SWAGGER_REST_OPERATION)).thenReturn(swaggerRestOperation);
  IpPort ipPort = mock(IpPort.class);
  when(ipPort.getPort()).thenReturn(10);
  when(ipPort.getHostOrIp()).thenReturn("ever");
  AsyncResponse asyncResp = mock(AsyncResponse.class);
  List<HttpMethod> methods = new ArrayList<>(
      Arrays.asList(HttpMethod.GET, HttpMethod.PUT, HttpMethod.POST, HttpMethod.DELETE, HttpMethod.PATCH));
  for (HttpMethod method : methods) {
    when(swaggerRestOperation.getHttpMethod()).thenReturn(method.toString());
    HttpClientRequest obj =
        VertxHttpMethod.INSTANCE.createRequest(client, invocation, ipPort, "good", asyncResp);
    Assert.assertNull(obj);
  }
}

项目：app-ms 文件：VertxClientEngine.java

public VertxClientEngine(final HttpClient httpClient) {

        try {
            this.httpClient = httpClient;
            sslContext = SSLContext.getDefault();
            hostnameVerifier = HttpsURLConnection.getDefaultHostnameVerifier();
        } catch (final NoSuchAlgorithmException e) {
            throw new ExceptionInInitializerError(e);
        }
    }

项目：app-ms 文件：SpringJaxrsHandlerTest.java

@Test
public void testEngineWithInjectedClientPost() {

    final HttpClient httpClient = Vertx.vertx().createHttpClient(httpClientOptions);
    final Client client = new ResteasyClientBuilder().httpEngine(new VertxClientEngine(httpClient))
        .register(GsonMessageBodyHandler.class).build();
    final Form xform = new Form();
    xform.param("userName", "ca1\\\\meowmix");
    xform.param("password", "mingnamulan");
    xform.param("state", "authenticate");
    xform.param("style", "xml");
    xform.param("xsl", "none");

    final JsonObject arsString = client.target("https://httpbin.org/post").request()
        .post(Entity.form(xform), JsonObject.class);
    assertEquals("xml", arsString.getAsJsonObject("form").get("style").getAsString());
}

项目：microtrader 文件：PortfolioServiceImpl.java

private Future<Double> getValueForCompany(HttpClient client, String company, int numberOfShares) {
    // Create the future object that will  get the value once the value have been retrieved
    Future<Double> future = Future.future();

    client
            .get(root + "/?name=" + encode(company), response -> {
                response.exceptionHandler(future::fail);
                if (response.statusCode() == 200) {
                    response.bodyHandler(buffer -> {
                        double v = numberOfShares * buffer.toJsonObject().getDouble("bid");
                        future.complete(v);
                    });
                } else {
                    future.complete(0.0);
                }
            })
            .exceptionHandler(future::fail)
            .end();

    return future;
}

项目：standalone-hystrix-dashboard 文件：HystrixDashboardConfigurationTest.java

@Test
public void testConfigurationOptions(TestContext testContext) throws Exception {
  final HttpClientOptions options = new HttpClientOptions().setTryUseCompression(false);

  final HttpClient httpClient = runTestOnContext.vertx().createHttpClient(options);

  final Async asyncOp = testContext.async();

  // issue a request on the custom server bind address and port, testing for compression
  httpClient.get(SERVER_PORT, SERVER_BIND_ADDRESS, "/hystrix-dashboard/")
            .setChunked(false)
            .putHeader(HttpHeaders.ACCEPT_ENCODING, HttpHeaders.DEFLATE_GZIP)
            .handler(resp -> {
              testContext.assertEquals(200, resp.statusCode(), "Should have fetched the index page with status 200");
              testContext.assertEquals("gzip", resp.getHeader(HttpHeaders.CONTENT_ENCODING));
            })
            .exceptionHandler(testContext::fail)
            .endHandler(event -> asyncOp.complete())
            .end();
}

项目：vertx-service-discovery 文件：HTTPEndpointExamples.java

public void example2(ServiceDiscovery discovery) {
  // Get the record
  discovery.getRecord(new JsonObject().put("name", "some-http-service"), ar -> {
    if (ar.succeeded() && ar.result() != null) {
      // Retrieve the service reference
      ServiceReference reference = discovery.getReference(ar.result());
      // Retrieve the service object
      HttpClient client = reference.getAs(HttpClient.class);

      // You need to path the complete path
      client.getNow("/api/persons", response -> {

        // ...

        // Dont' forget to release the service
        reference.release();

      });
    }
  });
}

项目：vertx-service-discovery 文件：HTTPEndpointExamples.java

public void example3(ServiceDiscovery discovery) {
  HttpEndpoint.getClient(discovery, new JsonObject().put("name", "some-http-service"), ar -> {
    if (ar.succeeded()) {
      HttpClient client = ar.result();

      // You need to path the complete path
      client.getNow("/api/persons", response -> {

        // ...

        // Dont' forget to release the service
        ServiceDiscovery.releaseServiceObject(discovery, client);

      });
    }
  });
}

项目：vertx-service-discovery 文件：HttpEndpointTest.java

@Test
public void testPublicationAndConsumptionWithConfiguration(TestContext context) {
  Async async = context.async();

  // Publish the service
  Record record = HttpEndpoint.createRecord("hello-service", "localhost", 8080, "/foo");
  discovery.publish(record, rec -> {
    Record published = rec.result();

    HttpEndpoint.getClient(discovery, new JsonObject().put("name", "hello-service"), new JsonObject().put
      ("keepAlive", false), found -> {
      context.assertTrue(found.succeeded());
      context.assertTrue(found.result() != null);
      HttpClient client = found.result();
      client.getNow("/foo", response -> {
        context.assertEquals(response.statusCode(), 200);
        context.assertEquals(response.getHeader("connection"), "close");
        response.bodyHandler(body -> {
          context.assertEquals(body.toString(), "hello");
          ServiceDiscovery.releaseServiceObject(discovery, client);
          discovery.unpublish(published.getRegistration(), v -> async.complete());
        });
      });
    });
  });
}

项目：df 文件：StreamingClient.java

public void handshake(HttpClient hc, FileSystem fs) {

        HttpClientRequest request = hc.put(AgentConstant.SERVER_PORT, AgentConstant.SERVER_ADDR, "", resp -> {
            System.out.println("Response: Hand Shake Status Code - " + resp.statusCode());
            System.out.println("Response: Hand Shake Status Message - " + resp.statusMessage());
            if (resp.statusCode() == AgentConstant.RES_SUCCESS) {
                System.out.println("Response: Hand Shake Status - SUCCESSFUL!");

                //check if it is file/folder processing
                if(Files.isDirectory(Paths.get(AgentConstant.FILE_NAME))) {
                    streamFilesDir(hc, fs);
                } else streamFile(hc, fs);
            }
            else System.out.println("Response: Hand Shake Status - FAILED!");
        });
        request.headers().add("DF_PROTOCOL","REGISTER");
        request.headers().add("DF_MODE", AgentConstant.TRANS_MODE);
        request.headers().add("DF_TYPE", "META");
        request.headers().add("DF_TOPIC", AgentConstant.META_TOPIC);
        request.headers().add("DF_FILENAME", AgentConstant.FILE_NAME);
        request.headers().add("DF_FILTER", AgentConstant.FILTER_TYPE);
        request.headers().add("DF_DATA_TRANS", AgentConstant.DATA_TRANS);

        request.end(setMetaData(AgentConstant.FILE_NAME));
    }

项目：vertx-blueprint-microservice 文件：CheckoutServiceImpl.java

private Future<JsonObject> getInventory(ProductTuple product, HttpClient client) {
  Future<Integer> future = Future.future();
  client.get("/" + product.getProductId(), response -> {
    if (response.statusCode() == 200) {
      response.bodyHandler(buffer -> {
        try {
          int inventory = Integer.valueOf(buffer.toString());
          future.complete(inventory);
        } catch (NumberFormatException ex) {
          future.fail(ex);
        }
      });
    } else {
      future.fail("not_found:" + product.getProductId());
    }
  })
    .exceptionHandler(future::fail)
    .end();
  return future.map(inv -> new JsonObject()
    .put("id", product.getProductId())
    .put("inventory", inv)
    .put("amount", product.getAmount()));
}

项目：mesh 文件：MeshRestAPITest.java

@Test
public void test404Response() throws Exception {
    HttpClientOptions options = new HttpClientOptions();
    options.setDefaultHost("localhost");
    options.setDefaultPort(port());

    HttpClient client = Mesh.vertx().createHttpClient(options);
    CompletableFuture<String> future = new CompletableFuture<>();
    HttpClientRequest request = client.request(HttpMethod.POST, "/api/v1/test", rh -> {
        rh.bodyHandler(bh -> {
            future.complete(bh.toString());
        });
    });
    request.end();

    String response = future.get(1, TimeUnit.SECONDS);
    assertTrue("The response string should not contain any html specific characters but it was {" + response + "} ",
            response.indexOf("<") != 0);
}

项目：weld-vertx 文件：WebRouteObserversTest.java

@Test
public void testPaymentRoutes() throws InterruptedException {
    HttpClient client = vertx.createHttpClient(new HttpClientOptions().setDefaultPort(8080));
    client.get("/payments").handler(r -> r.bodyHandler(b -> SYNCHRONIZER.add(b.toString()))).end();
    String response = poll().toString();
    JsonArray array = new JsonArray(response);
    assertEquals(2, array.size());
    JsonObject fooPayment = array.getJsonObject(0);
    assertEquals("foo", fooPayment.getString("id"));
    assertEquals("1", fooPayment.getString("amount"));
    client.get("/payments/bar").handler(r -> r.bodyHandler(b -> SYNCHRONIZER.add(b.toString()))).end();
    response = poll().toString();
    JsonObject barPayment = new JsonObject(response);
    assertEquals("bar", barPayment.getString("id"));
    assertEquals("100", barPayment.getString("amount"));
}

项目：weld-vertx 文件：WebRouteTest.java

@Test
public void testNestedRoutes() throws InterruptedException {
    HttpClient client = vertx.createHttpClient(new HttpClientOptions().setDefaultPort(8080));
    client.get("/payments").handler(r -> r.bodyHandler(b -> SYNCHRONIZER.add(b.toString()))).end();
    String response = poll().toString();
    JsonArray array = new JsonArray(response);
    assertEquals(2, array.size());
    JsonObject fooPayment = array.getJsonObject(0);
    assertEquals("foo", fooPayment.getString("id"));
    assertEquals("1", fooPayment.getString("amount"));
    client.get("/payments/bar").handler(r -> r.bodyHandler(b -> SYNCHRONIZER.add(b.toString()))).end();
    response = poll().toString();
    JsonObject barPayment = new JsonObject(response);
    assertEquals("bar", barPayment.getString("id"));
    assertEquals("100", barPayment.getString("amount"));
    // Test ignored routes
    client.get("/payments/inner").handler(r -> SYNCHRONIZER.add("" + r.statusCode())).end();
    assertEquals("404", poll());
    client.get("/payments/string").handler(r -> SYNCHRONIZER.add("" + r.statusCode())).end();
    assertEquals("404", poll());
}

项目：mesh 文件：AdminGUIEndpointTest.java

@Test
public void testAdminConfigRendering() throws InterruptedException, ExecutionException, TimeoutException {

    HttpClient client = createHttpClient();
    CompletableFuture<String> future = new CompletableFuture<>();
    HttpClientRequest request = client.request(GET, "/mesh-ui/mesh-ui-config.js", rh -> {
        rh.bodyHandler(bh -> {
            if (rh.statusCode() == 200) {
                future.complete(bh.toString());
            } else {
                future.completeExceptionally(new Exception("Status code wrong {" + rh.statusCode() + "}"));
            }
        });
    });
    request.end();

    String response = future.get(10, TimeUnit.SECONDS);
    // String expectedUrl = "localhost:" + port;
    // assertTrue("The meshConfig.js file did not contain the expected url {" + expectedUrl + "} Response {" + response + "}",
    // response.contains(expectedUrl));
    // System.out.println(response);
    assertTrue("The response string should not contain any html specific characters but it was {" + response + "} ", response.indexOf("<") != 0);

}