org.apache.http.client.utils.URIBuilder.setScheme()方法的使用及代码示例

x33g5p2x  于2022-01-31 转载在 其他  
字(9.0k)|赞(0)|评价(0)|浏览(172)

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

URIBuilder.setScheme介绍

[英]Sets URI scheme.
[中]设置URI方案。

代码示例

代码示例来源：origin: stackoverflow.com

URIBuilder builder = new URIBuilder();
 builder.setScheme("http").setHost(host).setPort(port).setPath(restPath + taskUri + "/" + taskId)
 .setParameter("parts", "all")
 .setParameter("params", routingOptionsJson)
 .setParameter("action", "finish");
 HttpPost post = getHttpPostMethod(builder.build());

代码示例来源：origin: apache/incubator-gobblin

private MySqlJdbcUrl() {
 builder = new URIBuilder();
 builder.setScheme("mysql");
}

代码示例来源：origin: spotify/helios

private URI uri(final String path, final Multimap<String, String> query) {
 checkArgument(path.startsWith("/"));
 final URIBuilder builder = new URIBuilder()
   .setScheme("http")
   .setHost("helios")
   .setPath(path);
 for (final Map.Entry<String, String> q : query.entries()) {
  builder.addParameter(q.getKey(), q.getValue());
 }
 builder.addParameter("user", user);
 try {
  return builder.build();
 } catch (URISyntaxException e) {
  throw new RuntimeException(e);
 }
}

代码示例来源：origin: kamax-matrix/mxhsd

public PathBuilder() {
  b = new URIBuilder();
  b.setScheme("matrix");
  b.setHost("dummy");
}

代码示例来源：origin: alibaba/Sentinel

public CompletableFuture<ClusterStateSimpleEntity> fetchClusterMode(String app, String ip, int port) {
  if (StringUtil.isBlank(ip) || port <= 0) {
    return AsyncUtils.newFailedFuture(new IllegalArgumentException("Invalid parameter"));
  }
  try {
    URIBuilder uriBuilder = new URIBuilder();
    uriBuilder.setScheme("http").setHost(ip).setPort(port)
      .setPath(FETCH_CLUSTER_MODE_PATH);
    return executeCommand(FETCH_CLUSTER_MODE_PATH, uriBuilder.build())
      .thenApply(r -> JSON.parseObject(r, ClusterStateSimpleEntity.class));
  } catch (Exception ex) {
    logger.warn("Error when fetching cluster mode", ex);
    return AsyncUtils.newFailedFuture(ex);
  }
}

代码示例来源：origin: stackoverflow.com

URIBuilder builder = new URIBuilder();
builder.setScheme("http").setHost("www.google.com").setPath("/search")
  .setParameter("q", "httpclient")
  .setParameter("btnG", "Google Search")
  .setParameter("aq", "f")
  .setParameter("oq", "");
URI uri = builder.build();
HttpGet httpget = new HttpGet(uri);
System.out.println(httpget.getURI());

代码示例来源：origin: org.metaeffekt.dcc/dcc-agent-core

protected URIBuilder createUriBuilder() {

    Assert.notNull(host,"No host configured");
    Assert.notNull(port,"No port configured");
    
    URIBuilder builder = new URIBuilder();
    builder
      .setScheme(DEFAULT_PROTOCOL)
      .setHost(host)
      .setPort(port);

    return builder;
  }
}

代码示例来源：origin: apache/geode

public Client() {
 reqURIBuild = new URIBuilder();
 reqURIBuild.setScheme("http");
 httpclient = HttpClients.createDefault();
 context = new BasicHttpContext();
 cookie = null;
}

代码示例来源：origin: alibaba/Sentinel

public CompletableFuture<ClusterClientInfoVO> fetchClusterClientInfoAndConfig(String app, String ip, int port) {
  if (StringUtil.isBlank(ip) || port <= 0) {
    return AsyncUtils.newFailedFuture(new IllegalArgumentException("Invalid parameter"));
  }
  try {
    URIBuilder uriBuilder = new URIBuilder();
    uriBuilder.setScheme("http").setHost(ip).setPort(port)
      .setPath(FETCH_CLUSTER_CLIENT_CONFIG_PATH);
    return executeCommand(FETCH_CLUSTER_CLIENT_CONFIG_PATH, uriBuilder.build())
      .thenApply(r -> JSON.parseObject(r, ClusterClientInfoVO.class));
  } catch (Exception ex) {
    logger.warn("Error when fetching cluster client config", ex);
    return AsyncUtils.newFailedFuture(ex);
  }
}

代码示例来源：origin: stackoverflow.com

final URIBuilder builder = new URIBuilder();
builder.setScheme("http")
  .setHost("testurl.com")
  .setPath("/lists/lprocess")
  .addParameter("action", "LoadList|401814|1");
final URI uri = builder.build();
final HttpPost post = new HttpPost(uri);

代码示例来源：origin: com.github.detro/browsermob-proxy-client

private URIBuilder requestURIBuilder() {
  return new URIBuilder()
      .setScheme("http")
      .setHost(APIHost)
      .setPort(APIPort);
}

代码示例来源：origin: gocd/gocd

public String sslServerUrl(String sslPort) {
    String serverUrl = serverUrl();

    try {
      // backward compatibility, since the agent.jar requires an ssl url, but the old bootstrapper does not have one.
      URIBuilder url = new URIBuilder(serverUrl);
      if (url.getScheme().equals("http")) {
        url.setPort(Integer.valueOf(sslPort));
        url.setScheme("https");
      }
      return url.toString();
    } catch (URISyntaxException e) {
      throw bomb(e);
    }

  }
}

代码示例来源：origin: apache/storm

URIBuilder builder = new URIBuilder().setScheme(scheme).setHost(host).setPort(port);
builder.setPath(path);
try {
  LOG.debug("About to issue a GET to {}", builder);
  HttpGet httpget = new HttpGet(builder.build());
  String responseBody;
  responseBody = httpclient.execute(httpget, GETStringResponseHandler.getInstance());

代码示例来源：origin: stackoverflow.com

public PeopleDetailInstance peopledetail(String peopleId) {    
  URIBuilder builder = new URIBuilder();
  builder.setScheme("https")
    .setHost("api.insideview.com")
    .setPath("/api/v1")
    .setParameter("people", peopleId)
    .setParameter("active", "true")
  URI uri = builder.build();
  HttpGet httpget = new HttpGet(uri);
}

代码示例来源：origin: org.metaeffekt.dcc/dcc-agent-core

private URIBuilder getUriBuilder() {
  
  URIBuilder builder = new URIBuilder();
  builder
    .setScheme(DEFAULT_PROTOCOL)
    .setHost(host)
    .setPort(port);
  
  return builder;
}

代码示例来源：origin: alibaba/Sentinel

public CompletableFuture<ClusterServerStateVO> fetchClusterServerBasicInfo(String app, String ip, int port) {
    if (StringUtil.isBlank(ip) || port <= 0) {
      return AsyncUtils.newFailedFuture(new IllegalArgumentException("Invalid parameter"));
    }
    try {
      URIBuilder uriBuilder = new URIBuilder();
      uriBuilder.setScheme("http").setHost(ip).setPort(port)
        .setPath(FETCH_CLUSTER_SERVER_BASIC_INFO_PATH);
      return executeCommand(FETCH_CLUSTER_SERVER_BASIC_INFO_PATH, uriBuilder.build())
        .thenApply(r -> JSON.parseObject(r, ClusterServerStateVO.class));
    } catch (Exception ex) {
      logger.warn("Error when fetching cluster sever all config and basic info", ex);
      return AsyncUtils.newFailedFuture(ex);
    }
  }
}

代码示例来源：origin: stackoverflow.com

URIBuilder builder = new URIBuilder();
  builder.setScheme("http").setHost("api.themoviedb.org").setPath("/3/search/person")
    .setParameter("api_key", YOURAPIKEY)
    .setParameter("page", 1)
    .setParameter("query", query)
  URI uri = builder.build();
  HttpGet httpget = new HttpGet(uri);

.....
  response = httpclient.execute(new HttpGet(httpget ));

代码示例来源：origin: alibaba/Sentinel

public CompletableFuture<Void> setParamFlowRuleOfMachine(String app, String ip, int port, List<ParamFlowRuleEntity> rules) {
  if (rules == null) {
    return CompletableFuture.completedFuture(null);
  }
  if (StringUtil.isBlank(ip) || port <= 0) {
    return AsyncUtils.newFailedFuture(new IllegalArgumentException("Invalid parameter"));
  }
  try {
    String data = JSON.toJSONString(
      rules.stream().map(ParamFlowRuleEntity::getRule).collect(Collectors.toList())
    );
    data = URLEncoder.encode(data, DEFAULT_CHARSET.name());
    URIBuilder uriBuilder = new URIBuilder();
    uriBuilder.setScheme("http").setHost(ip).setPort(port)
      .setPath(SET_PARAM_RULE_PATH)
      .setParameter("data", data);
    return executeCommand(SET_PARAM_RULE_PATH, uriBuilder.build())
      .thenCompose(e -> {
        if (CommandConstants.MSG_SUCCESS.equals(e)) {
          return CompletableFuture.completedFuture(null);
        } else {
          logger.warn("Push parameter flow rules to client failed: " + e);
          return AsyncUtils.newFailedFuture(new RuntimeException(e));
        }
      });
  } catch (Exception ex) {
    logger.warn("Error when setting parameter flow rule", ex);
    return AsyncUtils.newFailedFuture(ex);
  }
}

代码示例来源：origin: com.github.mike10004/har-replay-test-support

private URI transformUri(URI uri) { // equivalent of switcheroo extension
  if (transformHttpsToHttp && "https".equals(uri.getScheme())) {
    try {
      return new URIBuilder(uri).setScheme("http").build();
    } catch (URISyntaxException e) {
      throw new IllegalStateException(e);
    }
  } else {
    return uri;
  }
}

代码示例来源：origin: alibaba/Sentinel

public CompletableFuture<Void> modifyClusterServerFlowConfig(String app, String ip, int port, ServerFlowConfig config) {
  if (StringUtil.isBlank(ip) || port <= 0) {
    return AsyncUtils.newFailedFuture(new IllegalArgumentException("Invalid parameter"));
  }
  try {
    URIBuilder uriBuilder = new URIBuilder();
    uriBuilder.setScheme("http").setHost(ip).setPort(port)
      .setPath(MODIFY_CLUSTER_SERVER_FLOW_CONFIG_PATH)
      .setParameter("data", JSON.toJSONString(config));
    return executeCommand(MODIFY_CLUSTER_SERVER_FLOW_CONFIG_PATH, uriBuilder.build())
      .thenCompose(e -> {
        if (CommandConstants.MSG_SUCCESS.equals(e)) {
          return CompletableFuture.completedFuture(null);
        } else {
          logger.warn("Error when modifying cluster server flow config: " + e);
          return AsyncUtils.newFailedFuture(new RuntimeException(e));
        }
      });
  } catch (Exception ex) {
    logger.warn("Error when modifying cluster server flow config", ex);
    return AsyncUtils.newFailedFuture(ex);
  }
}

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

UriBuilder

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    URIBuilder类方法

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