io.vertx.ext.web.client.WebClientOptions.setSsl()方法的使用及代码示例

x33g5p2x  于2022-02-03 转载在 其他  
字(8.8k)|赞(0)|评价(0)|浏览(193)

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

WebClientOptions.setSsl介绍

暂无

代码示例

代码示例来源：origin: vert-x3/vertx-examples

@Override
 public void start() throws Exception {

  // Create the web client and enable SSL/TLS with a trust store
  WebClient client = WebClient.create(vertx,
   new WebClientOptions()
    .setSsl(true)
    .setTrustStoreOptions(new JksOptions()
     .setPath("client-truststore.jks")
     .setPassword("wibble")
    )
  );

  client.get(8443, "localhost", "/")
   .send(ar -> {
    if (ar.succeeded()) {
     HttpResponse<Buffer> response = ar.result();
     System.out.println("Got HTTP response with status " + response.statusCode());
    } else {
     ar.cause().printStackTrace();
    }
   });
 }
}

代码示例来源：origin: io.vertx/vertx-consul-client

/**
 * Set whether SSL/TLS is enabled
 *
 * @param ssl  true if enabled
 * @return reference to this, for fluency
 */
public ConsulClientOptions setSsl(boolean ssl) {
 super.setSsl(ssl);
 return this;
}

代码示例来源：origin: FroMage/redpipe

@Path("coroutines/1")
  @GET
  public Single<Response> helloAsync(@Context io.vertx.reactivex.core.Vertx rxVertx){
    return Fibers.fiber(() -> {
      System.err.println("Creating client");
      WebClientOptions options = new WebClientOptions();
      options.setSsl(true);
      options.setTrustAll(true);
      options.setVerifyHost(false);
      WebClient client = WebClient.create(rxVertx, options);
      Single<HttpResponse<io.vertx.reactivex.core.buffer.Buffer>> responseHandler = client.get(443,
          "www.google.com", 
          "/robots.txt").rxSend();

      System.err.println("Got response");

      HttpResponse<io.vertx.reactivex.core.buffer.Buffer> httpResponse = Fibers.await(responseHandler);
      System.err.println("Got body");
      client.close();
      
      return Response.ok(httpResponse.body().toString()).build();
    });
  }
}

代码示例来源：origin: EnMasseProject/enmasse

@Override
protected void connect() {
  this.client = WebClient.create(vertx, new WebClientOptions()
      .setSsl(false)
      .setTrustAll(true)
      .setVerifyHost(false));
}

代码示例来源：origin: FroMage/redpipe

@Path("7error")
@GET
public CompletionStage<String> hello7Error(@Context Vertx vertx){
  io.vertx.reactivex.core.Vertx rxVertx = io.vertx.reactivex.core.Vertx.newInstance(vertx);
  System.err.println("Creating client");
  WebClientOptions options = new WebClientOptions();
  options.setSsl(true);
  options.setTrustAll(true);
  options.setVerifyHost(false);
  WebClient client = WebClient.create(rxVertx, options);
  Single<HttpResponse<io.vertx.reactivex.core.buffer.Buffer>> responseHandler = client.get(443,
      "www.google.com", 
      "/robots.txt").rxSend();
  CompletableFuture<String> ret = new CompletableFuture<>();
  responseHandler
    .doAfterTerminate(() -> client.close())
    .subscribe(body -> {
    System.err.println("Got body");
    
    ret.completeExceptionally(new MyException());
  });
  System.err.println("Created client");
  return ret;
}

代码示例来源：origin: EnMasseProject/enmasse

protected void connect() {
  this.client = WebClient.create(vertx, new WebClientOptions()
      .setSsl(true)
      // TODO: Fetch CA and use
      .setTrustAll(true)
      .setVerifyHost(false));
}

代码示例来源：origin: FroMage/redpipe

@Path("7")
@GET
public CompletionStage<String> hello7(@Context Vertx vertx){
  io.vertx.reactivex.core.Vertx rxVertx = io.vertx.reactivex.core.Vertx.newInstance(vertx);
  System.err.println("Creating client");
  WebClientOptions options = new WebClientOptions();
  options.setSsl(true);
  options.setTrustAll(true);
  options.setVerifyHost(false);
  WebClient client = WebClient.create(rxVertx, options);
  Single<HttpResponse<io.vertx.reactivex.core.buffer.Buffer>> responseHandler = client.get(443,
      "www.google.com", 
      "/robots.txt").rxSend();
  CompletableFuture<String> ret = new CompletableFuture<>();
  responseHandler
    .doAfterTerminate(() -> client.close())
    .subscribe(body -> {
    System.err.println("Got body");
    ret.complete(body.body().toString());
  });
  
  System.err.println("Created client");
  return ret;
}

代码示例来源：origin: FroMage/redpipe

@Path("8")
@GET
public Single<String> hello8(@Context io.vertx.reactivex.core.Vertx rxVertx){
  System.err.println("Creating client");
  WebClientOptions options = new WebClientOptions();
  options.setSsl(true);
  options.setTrustAll(true);
  options.setVerifyHost(false);
  WebClient client = WebClient.create(rxVertx, options);
  Single<HttpResponse<io.vertx.reactivex.core.buffer.Buffer>> responseHandler = client.get(443,
      "www.google.com", 
      "/robots.txt").rxSend();
  System.err.println("Created client");
  return responseHandler.map(body -> {
    System.err.println("Got body");
    return body.body().toString();
  }).doAfterTerminate(() -> client.close());
}

代码示例来源：origin: FroMage/redpipe

@Path("8error")
@GET
public Single<String> hello8Error(@Context io.vertx.reactivex.core.Vertx rxVertx){
  System.err.println("Creating client");
  WebClientOptions options = new WebClientOptions();
  options.setSsl(true);
  options.setTrustAll(true);
  options.setVerifyHost(false);
  WebClient client = WebClient.create(rxVertx, options);
  Single<HttpResponse<io.vertx.reactivex.core.buffer.Buffer>> responseHandler = client.get(443,
      "www.google.com", 
      "/robots.txt").rxSend();
  System.err.println("Created client");
  return responseHandler
      .doAfterTerminate(() -> client.close())
      .map(body -> {
    System.err.println("Got body");
    throw new MyException();
  });
}

代码示例来源：origin: FroMage/redpipe

@Path("8user")
@Produces("text/json")
@GET
public Single<DataClass> hello8User(@Context io.vertx.reactivex.core.Vertx rxVertx){
  System.err.println("Creating client");
  WebClientOptions options = new WebClientOptions();
  options.setSsl(true);
  options.setTrustAll(true);
  options.setVerifyHost(false);
  WebClient client = WebClient.create(rxVertx, options);
  Single<HttpResponse<io.vertx.reactivex.core.buffer.Buffer>> responseHandler = client.get(443,
      "www.google.com", 
      "/robots.txt").rxSend();
  System.err.println("Created client");
  return responseHandler.map(body -> {
    System.err.println("Got body");
    return new DataClass(body.body().toString());
  }).doAfterTerminate(() -> client.close());
}

代码示例来源：origin: FroMage/redpipe

@Path("6")
@GET
public void hello6(@Suspended final AsyncResponse asyncResponse,
     // Inject the Vertx instance
     @Context Vertx vertx){
  io.vertx.reactivex.core.Vertx rxVertx = io.vertx.reactivex.core.Vertx.newInstance(vertx);
  System.err.println("Creating client");
  WebClientOptions options = new WebClientOptions();
  options.setSsl(true);
  options.setTrustAll(true);
  options.setVerifyHost(false);
  WebClient client = WebClient.create(rxVertx, options);
  Single<HttpResponse<io.vertx.reactivex.core.buffer.Buffer>> responseHandler = client.get(443,
      "www.google.com", 
      "/robots.txt").rxSend();
  responseHandler
    .doAfterTerminate(() -> client.close())
    .subscribe(body -> {
    System.err.println("Got body");
    asyncResponse.resume(Response.ok(body.body().toString()).build());
  });
  
  System.err.println("Created client");
}

代码示例来源：origin: io.gravitee.elasticsearch/gravitee-common-elasticsearch

.setSsl(true)
.setTrustAll(true);

代码示例来源：origin: FroMage/redpipe

.setSsl(true)
    .setUserAgent("vert-x3"));
String clientId = session.get("github_client_id");

代码示例来源：origin: FroMage/redpipe

.setSsl(true)
    .setUserAgent("vert-x3"));
String clientId = session.get("github_client_id");

代码示例来源：origin: FroMage/redpipe

.setSsl(true)
    .setUserAgent("vert-x3"));
HttpResponse<JsonObject> response = await(webClient.post(443, "api.github.com", "/gists")

代码示例来源：origin: FroMage/redpipe

.setSsl(true)
    .setUserAgent("vert-x3"));
HttpResponse<JsonObject> response = await(webClient.post(443, "api.github.com", "/gists")

代码示例来源：origin: vert-x3/vertx-config

new WebClientOptions()
 .setTrustAll(true)
 .setSsl(configuration.getBoolean("ssl", true))
 .setDefaultHost(host)
 .setDefaultPort(port)

代码示例来源：origin: vert-x3/vertx-service-discovery

new WebClientOptions()
 .setTrustAll(true)
 .setSsl(conf.getBoolean("ssl", true))
 .setDefaultHost(host)
 .setDefaultPort(port)

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

private void testTLS(boolean clientSSL, boolean serverSSL, Function<WebClient, HttpRequest<Buffer>> requestProvider, Consumer<HttpServerRequest> serverAssertions) throws Exception {
 WebClientOptions clientOptions = new WebClientOptions()
  .setSsl(clientSSL)
  .setTrustAll(true)
  .setDefaultHost(DEFAULT_HTTPS_HOST)
  .setDefaultPort(DEFAULT_HTTPS_PORT);
 HttpServerOptions serverOptions = new HttpServerOptions()
  .setSsl(serverSSL)
  .setKeyStoreOptions(Cert.SERVER_JKS.get())
  .setPort(DEFAULT_HTTPS_PORT)
  .setHost(DEFAULT_HTTPS_HOST);
 testTLS(clientOptions, serverOptions, requestProvider, serverAssertions);
}

内容来源于网络，如有侵权，请联系作者删除！

WebClientOptions

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com