org.apache.http.conn.HttpHostConnectException类的使用及代码示例

x33g5p2x  于2022-01-20 转载在 其他  
字(10.4k)|赞(0)|评价(0)|浏览(242)

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

HttpHostConnectException介绍

[英]A ConnectException that specifies the HttpHost that was being connected to.
[中]ConnectException，指定要连接到的HttpHost。

代码示例

代码示例来源：origin: dreamhead/moco

@Test(expected = ConnectException.class)
public void should_stop_runner_directly() throws IOException {
  runner.run();
  try {
    assertThat(helper.get(root()), is("foo"));
  } catch (HttpHostConnectException e) {
    fail(e.getMessage());
  }
  runner.stop();
  shutdownMoco(SHUTDOWN_PORT, SHUTDOWN_MOCO_KEY);
}

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

final Scheme schm = schemeRegistry.getScheme(target.getSchemeName());
if (!(schm.getSocketFactory() instanceof LayeredSocketFactory)) {
  throw new IllegalArgumentException
try {
  sock = lsf.createSocket
    (conn.getSocket(), target.getHostName(), schm.resolvePort(target.getPort()), true);
} catch (ConnectException ex) {
  throw new HttpHostConnectException(target, ex);

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

public HttpHostConnectException(final HttpHost host, final ConnectException cause) {
  super("Connection to " + host + " refused");
  this.host = host;
  initCause(cause);
}

代码示例来源：origin: com.hynnet/httpclient

final HttpContext context) throws IOException {
final Lookup<ConnectionSocketFactory> registry = getSocketFactoryRegistry(context);
final ConnectionSocketFactory sf = registry.lookup(host.getSchemeName());
if (sf == null) {
  throw new UnsupportedSchemeException(host.getSchemeName() +
      " protocol is not supported");
final InetAddress[] addresses = host.getAddress() != null ?
    new InetAddress[] { host.getAddress() } : this.dnsResolver.resolve(host.getHostName());
final int port = this.schemePortResolver.resolve(host);
        throw new ConnectTimeoutException(ex, host, addresses);
      } else {
        throw new HttpHostConnectException(ex, host, addresses);

代码示例来源：origin: org.apache.httpcomponents/httpclient-android

final HttpContext context) throws IOException {
final Lookup<ConnectionSocketFactory> registry = getSocketFactoryRegistry(context);
final ConnectionSocketFactory sf = registry.lookup(host.getSchemeName());
if (sf == null) {
  throw new UnsupportedSchemeException(host.getSchemeName() +
      " protocol is not supported");
final InetAddress[] addresses = this.dnsResolver.resolve(host.getHostName());
final int port = this.schemePortResolver.resolve(host);
for (int i = 0; i < addresses.length; i++) {
        throw cex;
      } else {
        throw new HttpHostConnectException(host, ex);

代码示例来源：origin: searchbox-io/Jest

@Override
public void failed(final Exception ex) {
  log.error("Exception occurred during async execution.", ex);
  if (ex instanceof HttpHostConnectException) {
    String host = ((HttpHostConnectException) ex).getHost().toURI();
    resultHandler.failed(new CouldNotConnectException(host, ex));
    return;
  }
  resultHandler.failed(ex);
}

代码示例来源：origin: ibinti/bugvm

/**
 * Creates a HttpHostConnectException based on original {@link java.io.IOException}.
 *
 * @since 4.3
 */
public HttpHostConnectException(
    final IOException cause,
    final HttpHost host,
    final InetAddress... remoteAddresses) {
  super("Connect to " +
      (host != null ? host.toHostString() : "remote host") +
      (remoteAddresses != null && remoteAddresses .length > 0 ?
          " " + Arrays.asList(remoteAddresses) : "") +
      ((cause != null && cause.getMessage() != null) ?
          " failed: " + cause.getMessage() : " refused"));
  this.host = host;
  initCause(cause);
}

代码示例来源：origin: at.bestsolution.efxclipse.eclipse/org.apache.httpcomponents.httpclient

final HttpContext context) throws IOException {
final Lookup<ConnectionSocketFactory> registry = getSocketFactoryRegistry(context);
final ConnectionSocketFactory sf = registry.lookup(host.getSchemeName());
if (sf == null) {
  throw new UnsupportedSchemeException(host.getSchemeName() +
      " protocol is not supported");
final InetAddress[] addresses = host.getAddress() != null ?
    new InetAddress[] { host.getAddress() } : this.dnsResolver.resolve(host.getHostName());
final int port = this.schemePortResolver.resolve(host);
        throw new ConnectTimeoutException(ex, host, addresses);
      } else {
        throw new HttpHostConnectException(ex, host, addresses);

代码示例来源：origin: searchbox-io/Jest

public <T extends JestResult> T execute(Action<T> clientRequest, RequestConfig requestConfig) throws IOException {
  HttpUriRequest request = prepareRequest(clientRequest, requestConfig);
  CloseableHttpResponse response = null;
  try {
    response = executeRequest(request);
    return deserializeResponse(response, request, clientRequest);
  } catch (HttpHostConnectException ex) {
    throw new CouldNotConnectException(ex.getHost().toURI(), ex);
  } finally {
    if (response != null) {
      try {
        response.close();
      } catch (IOException ex) {
        log.error("Exception occurred while closing response stream.", ex);
      }
    }
  }
}

代码示例来源：origin: com.hynnet/httpclient

/**
 * Creates a HttpHostConnectException based on original {@link java.io.IOException}.
 *
 * @since 4.3
 */
public HttpHostConnectException(
    final IOException cause,
    final HttpHost host,
    final InetAddress... remoteAddresses) {
  super("Connect to " +
      (host != null ? host.toHostString() : "remote host") +
      (remoteAddresses != null && remoteAddresses .length > 0 ?
          " " + Arrays.asList(remoteAddresses) : "") +
      ((cause != null && cause.getMessage() != null) ?
          " failed: " + cause.getMessage() : " refused"));
  this.host = host;
  initCause(cause);
}

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

final Scheme schm = schemeRegistry.getScheme(target.getSchemeName());
final SocketFactory sf = schm.getSocketFactory();
final SocketFactory plain_sf;
  layered_sf = null;
InetAddress[] addresses = InetAddress.getAllByName(target.getHostName());
    Socket connsock = plain_sf.connectSocket(sock,
      addresses[i].getHostAddress(),
      schm.resolvePort(target.getPort()),
      local, 0, params);
    if (sock != connsock) {
      ConnectException cause = ex instanceof ConnectException
          ? (ConnectException) ex : new ConnectException(ex.getMessage(), ex);
      throw new HttpHostConnectException(target, cause);

代码示例来源：origin: ibinti/bugvm

final HttpContext context) throws IOException {
final Lookup<ConnectionSocketFactory> registry = getSocketFactoryRegistry(context);
final ConnectionSocketFactory sf = registry.lookup(host.getSchemeName());
if (sf == null) {
  throw new UnsupportedSchemeException(host.getSchemeName() +
      " protocol is not supported");
final InetAddress[] addresses = host.getAddress() != null ?
    new InetAddress[] { host.getAddress() } : this.dnsResolver.resolve(host.getHostName());
final int port = this.schemePortResolver.resolve(host);
        throw new ConnectTimeoutException(ex, host, addresses);
      } else {
        throw new HttpHostConnectException(ex, host, addresses);

代码示例来源：origin: searchbox-io/Jest

public <T extends JestResult> T execute(Action<T> clientRequest, RequestConfig requestConfig) throws IOException {
  String elasticSearchRestUrl = getRequestURL(getNextServer(), clientRequest.getURI(ElasticsearchVersion.UNKNOWN));
  HttpUriRequest request = constructHttpMethod(clientRequest.getRestMethodName(), elasticSearchRestUrl, clientRequest.getData(gson), requestConfig);
  // add headers added to action
  if (!clientRequest.getHeaders().isEmpty()) {
    for (Map.Entry<String, Object> header : clientRequest.getHeaders().entrySet()) {
      request.addHeader(header.getKey(), header.getValue().toString());
    }
  }
  try {
    HttpResponse response = httpClient.execute(request);
    return deserializeResponse(response, clientRequest);
  } catch (HttpHostConnectException ex) {
    throw new CouldNotConnectException(ex.getHost().toURI(), ex);
  }
}

代码示例来源：origin: at.bestsolution.efxclipse.eclipse/org.apache.httpcomponents.httpclient

/**
 * Creates a HttpHostConnectException based on original {@link java.io.IOException}.
 *
 * @since 4.3
 */
public HttpHostConnectException(
    final IOException cause,
    final HttpHost host,
    final InetAddress... remoteAddresses) {
  super("Connect to " +
      (host != null ? host.toHostString() : "remote host") +
      (remoteAddresses != null && remoteAddresses .length > 0 ?
          " " + Arrays.asList(remoteAddresses) : "") +
      ((cause != null && cause.getMessage() != null) ?
          " failed: " + cause.getMessage() : " refused"));
  this.host = host;
  initCause(cause);
}

代码示例来源：origin: dreamhead/moco

@Test(expected = HttpHostConnectException.class)
public void should_stop_runner_via_shutdown_task() throws IOException {
  runner.run();
  try {
    assertThat(helper.get(root()), is("foo"));
  } catch (HttpHostConnectException e) {
    fail(e.getMessage());
  }
  ShutdownTask task = new ShutdownTask(SHUTDOWN_MOCO_KEY);
  task.run(new String[]{"-s", Integer.toString(SHUTDOWN_PORT)});
  waitChangeHappens();
  helper.get(root());
}

代码示例来源：origin: MobiVM/robovm

public HttpHostConnectException(final HttpHost host, final ConnectException cause) {
  super("Connection to " + host + " refused");
  this.host = host;
  initCause(cause);
}

代码示例来源：origin: MobiVM/robovm

final Scheme schm = schemeRegistry.getScheme(target.getSchemeName());
if (!(schm.getSocketFactory() instanceof LayeredSocketFactory)) {
  throw new IllegalArgumentException
try {
  sock = lsf.createSocket
    (conn.getSocket(), target.getHostName(), schm.resolvePort(target.getPort()), true);
} catch (ConnectException ex) {
  throw new HttpHostConnectException(target, ex);

代码示例来源：origin: com.impetus.fabric/fabric-jdbc-driver-shaded

final HttpContext context) throws IOException {
final Lookup<ConnectionSocketFactory> registry = getSocketFactoryRegistry(context);
final ConnectionSocketFactory sf = registry.lookup(host.getSchemeName());
if (sf == null) {
  throw new UnsupportedSchemeException(host.getSchemeName() +
      " protocol is not supported");
final InetAddress[] addresses = host.getAddress() != null ?
    new InetAddress[] { host.getAddress() } : this.dnsResolver.resolve(host.getHostName());
final int port = this.schemePortResolver.resolve(host);
        throw new ConnectTimeoutException(ex, host, addresses);
      } else {
        throw new HttpHostConnectException(ex, host, addresses);

代码示例来源：origin: io.searchbox/jest

@Override
public void failed(final Exception ex) {
  log.error("Exception occurred during async execution.", ex);
  if (ex instanceof HttpHostConnectException) {
    String host = ((HttpHostConnectException) ex).getHost().toURI();
    resultHandler.failed(new CouldNotConnectException(host, ex));
    return;
  }
  resultHandler.failed(ex);
}

代码示例来源：origin: com.bugvm/bugvm-rt

/**
 * Creates a HttpHostConnectException based on original {@link java.io.IOException}.
 *
 * @since 4.3
 */
public HttpHostConnectException(
    final IOException cause,
    final HttpHost host,
    final InetAddress... remoteAddresses) {
  super("Connect to " +
      (host != null ? host.toHostString() : "remote host") +
      (remoteAddresses != null && remoteAddresses .length > 0 ?
          " " + Arrays.asList(remoteAddresses) : "") +
      ((cause != null && cause.getMessage() != null) ?
          " failed: " + cause.getMessage() : " refused"));
  this.host = host;
  initCause(cause);
}

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

HttpHostConnectException

相关文章

    查看更多

    热门标签

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

    最新文章

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