org.apache.http.config.Lookup.lookup()方法的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(16.4k)|赞(0)|评价(0)|浏览(120)

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

Lookup.lookup介绍

暂无

代码示例

代码示例来源：origin: internetarchive/heritrix3

protected AuthScheme chooseAuthScheme(Map<String, String> challenges, String challengeHeaderKey) {
  HashSet<String> authSchemesLeftToTry = new HashSet<String>(challenges.keySet());
  for (String authSchemeName: new String[]{"digest","basic"}) {
    if (authSchemesLeftToTry.remove(authSchemeName)) {
      AuthScheme authScheme = AUTH_SCHEME_REGISTRY.lookup(authSchemeName).create(null);;
      BasicHeader challenge = new BasicHeader(challengeHeaderKey, challenges.get(authSchemeName));
      try {
        authScheme.processChallenge(challenge);
      } catch (MalformedChallengeException e) {
        logger.fine(e.getMessage() + " " + challenge);
        continue;
      }
      if (authScheme.isConnectionBased()) {
        logger.fine("Connection based " + authScheme);
        continue;
      }
      if (authScheme.getRealm() == null
          || authScheme.getRealm().length() <= 0) {
        logger.fine("Empty realm " + authScheme);
        continue;
      }
      return authScheme;
    }
  }
  for (String unsupportedSchemeName: authSchemesLeftToTry) {
    logger.fine("Unsupported http auth scheme: " + unsupportedSchemeName);
  }
  
  return null;
}

代码示例来源：origin: com.joyent.http-signature/apache-http-client-signature

/**
 * Create a new instance using a provider found via a {@link Lookup}.
 *
 * @param authSchemeProviderLookup Lookup that will return an {@link AuthScheme}
 *                                 when asked for "Signatures"
 * @param credentials credentials containing the HTTP Signature username
 */
public HttpSignatureAuthenticationStrategy(
    final Lookup<AuthSchemeProvider> authSchemeProviderLookup,
    final Credentials credentials) {
  this(authSchemeProviderLookup.lookup("Signatures").create(null), credentials);
}

代码示例来源：origin: io.cloudslang.content/cs-http-client

public HttpClientContext build() {
    if (StringUtils.isEmpty(preemptiveAuth)) {
      preemptiveAuth = "true";
    }
    HttpClientContext context = HttpClientContext.create();
    if (authTypes.size() == 1 && Boolean.parseBoolean(preemptiveAuth) && !authTypes.contains(AuthTypes.ANONYMOUS)) {
      AuthCache authCache = new BasicAuthCache();
      authCache.put(new HttpHost(uri.getHost(), uri.getPort(), uri.getScheme()),
          authSchemeLookup.lookup(authTypes.iterator().next()).create(context));
      context.setCredentialsProvider(credentialsProvider);
      context.setAuthCache(authCache);
    }
    return context;
  }
}

代码示例来源：origin: io.cloudslang.content/score-http-client

public HttpClientContext build() {
    if (StringUtils.isEmpty(preemptiveAuth)) {
      preemptiveAuth = "true";
    }
    HttpClientContext context = HttpClientContext.create();
    if (authTypes.size() == 1 && Boolean.parseBoolean(preemptiveAuth) && !authTypes.contains(AuthTypes.ANONYMOUS)) {
      AuthCache authCache = new BasicAuthCache();
      authCache.put(new HttpHost(uri.getHost(), uri.getPort(), uri.getScheme()),
          authSchemeLookup.lookup(authTypes.iterator().next()).create(context));
      context.setCredentialsProvider(credentialsProvider);
      context.setAuthCache(authCache);
    }
    return context;
  }
}

代码示例来源：origin: io.openscore.content/score-http-client

public HttpClientContext build() {
    if (StringUtils.isEmpty(preemptiveAuth)) {
      preemptiveAuth = "true";
    }
    HttpClientContext context = HttpClientContext.create();
    if (authTypes.size() == 1 && Boolean.parseBoolean(preemptiveAuth) && !authTypes.contains(AuthTypes.ANONYMOUS)) {
      AuthCache authCache = new BasicAuthCache();
      authCache.put(new HttpHost(uri.getHost(), uri.getPort(), uri.getScheme()),
          authSchemeLookup.lookup(authTypes.iterator().next()).create(context));
      context.setCredentialsProvider(credentialsProvider);
      context.setAuthCache(authCache);
    }
    return context;
  }
}

代码示例来源：origin: CloudSlang/cs-actions

public HttpClientContext build() {
    if (StringUtils.isEmpty(preemptiveAuth)) {
      preemptiveAuth = "true";
    }
    HttpClientContext context = HttpClientContext.create();
    if (authTypes.size() == 1 && Boolean.parseBoolean(preemptiveAuth) && !authTypes.contains(AuthTypes.ANONYMOUS)) {
      AuthCache authCache = new BasicAuthCache();
      authCache.put(new HttpHost(uri.getHost(), uri.getPort(), uri.getScheme()),
          authSchemeLookup.lookup(authTypes.iterator().next()).create(context));
      context.setCredentialsProvider(credentialsProvider);
      context.setAuthCache(authCache);
    }
    return context;
  }
}

代码示例来源：origin: org.archive.heritrix/heritrix-modules

protected AuthScheme chooseAuthScheme(Map<String, String> challenges, String challengeHeaderKey) {
  HashSet<String> authSchemesLeftToTry = new HashSet<String>(challenges.keySet());
  for (String authSchemeName: new String[]{"digest","basic"}) {
    if (authSchemesLeftToTry.remove(authSchemeName)) {
      AuthScheme authScheme = AUTH_SCHEME_REGISTRY.lookup(authSchemeName).create(null);;
      BasicHeader challenge = new BasicHeader(challengeHeaderKey, challenges.get(authSchemeName));
      try {
        authScheme.processChallenge(challenge);
      } catch (MalformedChallengeException e) {
        logger.fine(e.getMessage() + " " + challenge);
        continue;
      }
      if (authScheme.isConnectionBased()) {
        logger.fine("Connection based " + authScheme);
        continue;
      }
      if (authScheme.getRealm() == null
          || authScheme.getRealm().length() <= 0) {
        logger.fine("Empty realm " + authScheme);
        continue;
      }
      return authScheme;
    }
  }
  for (String unsupportedSchemeName: authSchemesLeftToTry) {
    logger.fine("Unsupported http auth scheme: " + unsupportedSchemeName);
  }
  
  return null;
}

代码示例来源：origin: PreferredAI/venom

/**
 * Decompress http response.
 *
 * @param response An instance of http response
 */
public final void decompress(final HttpResponse response) {
 final HttpEntity entity = response.getEntity();
 if (entity != null && entity.getContentLength() != 0) {
  final Header ceheader = entity.getContentEncoding();
  if (ceheader != null) {
   final HeaderElement[] codecs = ceheader.getElements();
   for (final HeaderElement codec : codecs) {
    final String codecName = codec.getName().toLowerCase(Locale.ROOT);
    final InputStreamFactory decoderFactory = decoderRegistry.lookup(codecName);
    if (decoderFactory != null) {
     response.setEntity(new DecompressingEntity(response.getEntity(), decoderFactory));
     response.removeHeaders("Content-Length");
     response.removeHeaders("Content-Encoding");
     response.removeHeaders("Content-MD5");
    }
   }
  }
 }
}

代码示例来源：origin: spring-cloud/spring-cloud-commons

@Test
public void newConnectionManagerWithDisabledSSLValidation() throws Exception {
  HttpClientConnectionManager connectionManager = new DefaultApacheHttpClientConnectionManagerFactory()
      .newConnectionManager(true, 2, 6);
  Lookup<ConnectionSocketFactory> socketFactoryRegistry = getConnectionSocketFactoryLookup(
      connectionManager);
  assertThat(socketFactoryRegistry.lookup("https"), is(notNullValue()));
  assertThat(getX509TrustManager(socketFactoryRegistry).getAcceptedIssuers(),
      is(nullValue()));
}

代码示例来源：origin: spring-cloud/spring-cloud-commons

@Test
public void newConnectionManagerWithSSL() throws Exception {
  HttpClientConnectionManager connectionManager = new DefaultApacheHttpClientConnectionManagerFactory()
      .newConnectionManager(false, 2, 6);
  Lookup<ConnectionSocketFactory> socketFactoryRegistry = getConnectionSocketFactoryLookup(
      connectionManager);
  assertThat(socketFactoryRegistry.lookup("https"), is(notNullValue()));
  assertThat(getX509TrustManager(socketFactoryRegistry).getAcceptedIssuers(),
      is(notNullValue()));
}

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

@Override
public void process(
    final HttpResponse response,
    final HttpContext context) throws HttpException, IOException {
  final HttpEntity entity = response.getEntity();
  final HttpClientContext clientContext = HttpClientContext.adapt(context);
  final RequestConfig requestConfig = clientContext.getRequestConfig();
  // entity can be null in case of 304 Not Modified, 204 No Content or similar
  // check for zero length entity.
  if (requestConfig.isContentCompressionEnabled() && entity != null && entity.getContentLength() != 0) {
    final Header ceheader = entity.getContentEncoding();
    if (ceheader != null) {
      final HeaderElement[] codecs = ceheader.getElements();
      for (final HeaderElement codec : codecs) {
        final String codecname = codec.getName().toLowerCase(Locale.ROOT);
        final InputStreamFactory decoderFactory = decoderRegistry.lookup(codecname);
        if (decoderFactory != null) {
          response.setEntity(new DecompressingEntity(response.getEntity(), decoderFactory));
          response.removeHeaders("Content-Length");
          response.removeHeaders("Content-Encoding");
          response.removeHeaders("Content-MD5");
        } else {
          if (!"identity".equals(codecname) && !ignoreUnknown) {
            throw new HttpException("Unsupported Content-Encoding: " + codec.getName());
          }
        }
      }
    }
  }
}

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

@Override
public void process(
    final HttpResponse response,
    final HttpContext context) throws HttpException, IOException {
  final HttpEntity entity = response.getEntity();
  final HttpClientContext clientContext = HttpClientContext.adapt(context);
  final RequestConfig requestConfig = clientContext.getRequestConfig();
  // entity can be null in case of 304 Not Modified, 204 No Content or similar
  // check for zero length entity.
  if (requestConfig.isContentCompressionEnabled() && entity != null && entity.getContentLength() != 0) {
    final Header ceheader = entity.getContentEncoding();
    if (ceheader != null) {
      final HeaderElement[] codecs = ceheader.getElements();
      for (final HeaderElement codec : codecs) {
        final String codecname = codec.getName().toLowerCase(Locale.ROOT);
        final InputStreamFactory decoderFactory = decoderRegistry.lookup(codecname);
        if (decoderFactory != null) {
          response.setEntity(new DecompressingEntity(response.getEntity(), decoderFactory));
          response.removeHeaders("Content-Length");
          response.removeHeaders("Content-Encoding");
          response.removeHeaders("Content-MD5");
        } else {
          if (!"identity".equals(codecname) && !ignoreUnknown) {
            throw new HttpException("Unsupported Content-Encoding: " + codec.getName());
          }
        }
      }
    }
  }
}

代码示例来源：origin: spring-cloud/spring-cloud-commons

private X509TrustManager getX509TrustManager(
    Lookup<ConnectionSocketFactory> socketFactoryRegistry) {
  ConnectionSocketFactory connectionSocketFactory = socketFactoryRegistry
      .lookup("https");
  SSLSocketFactory sslSocketFactory = getField(connectionSocketFactory,
      "socketfactory");
  SSLContextSpi sslContext = getField(sslSocketFactory, "context");
  return getField(sslContext, "trustManager");
}

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

@Override
public void upgrade(
    final ManagedHttpClientConnection conn,
    final HttpHost host,
    final HttpContext context) throws IOException {
  final HttpClientContext clientContext = HttpClientContext.adapt(context);
  final Lookup<ConnectionSocketFactory> registry = getSocketFactoryRegistry(clientContext);
  final ConnectionSocketFactory sf = registry.lookup(host.getSchemeName());
  if (sf == null) {
    throw new UnsupportedSchemeException(host.getSchemeName() +
        " protocol is not supported");
  }
  if (!(sf instanceof LayeredConnectionSocketFactory)) {
    throw new UnsupportedSchemeException(host.getSchemeName() +
        " protocol does not support connection upgrade");
  }
  final LayeredConnectionSocketFactory lsf = (LayeredConnectionSocketFactory) sf;
  Socket sock = conn.getSocket();
  final int port = this.schemePortResolver.resolve(host);
  sock = lsf.createLayeredSocket(sock, host.getHostName(), port, context);
  conn.bind(sock);
}

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

@Override
public void upgrade(
    final ManagedHttpClientConnection conn,
    final HttpHost host,
    final HttpContext context) throws IOException {
  final HttpClientContext clientContext = HttpClientContext.adapt(context);
  final Lookup<ConnectionSocketFactory> registry = getSocketFactoryRegistry(clientContext);
  final ConnectionSocketFactory sf = registry.lookup(host.getSchemeName());
  if (sf == null) {
    throw new UnsupportedSchemeException(host.getSchemeName() +
        " protocol is not supported");
  }
  if (!(sf instanceof LayeredConnectionSocketFactory)) {
    throw new UnsupportedSchemeException(host.getSchemeName() +
        " protocol does not support connection upgrade");
  }
  final LayeredConnectionSocketFactory lsf = (LayeredConnectionSocketFactory) sf;
  Socket sock = conn.getSocket();
  final int port = this.schemePortResolver.resolve(host);
  sock = lsf.createLayeredSocket(sock, host.getHostName(), port, context);
  conn.bind(sock);
}

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

@Override
public void upgrade(
    final ManagedHttpClientConnection conn,
    final HttpHost host,
    final HttpContext context) throws IOException {
  final HttpClientContext clientContext = HttpClientContext.adapt(context);
  final Lookup<ConnectionSocketFactory> registry = getSocketFactoryRegistry(clientContext);
  final ConnectionSocketFactory sf = registry.lookup(host.getSchemeName());
  if (sf == null) {
    throw new UnsupportedSchemeException(host.getSchemeName() +
        " protocol is not supported");
  }
  if (!(sf instanceof LayeredConnectionSocketFactory)) {
    throw new UnsupportedSchemeException(host.getSchemeName() +
        " protocol does not support connection upgrade");
  }
  final LayeredConnectionSocketFactory lsf = (LayeredConnectionSocketFactory) sf;
  Socket sock = conn.getSocket();
  final int port = this.schemePortResolver.resolve(host);
  sock = lsf.createLayeredSocket(sock, host.getHostName(), port, context);
  conn.bind(sock);
}

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

public void upgrade(
    final ManagedHttpClientConnection conn,
    final HttpHost host,
    final HttpContext context) throws IOException {
  final HttpClientContext clientContext = HttpClientContext.adapt(context);
  final Lookup<ConnectionSocketFactory> registry = getSocketFactoryRegistry(clientContext);
  final ConnectionSocketFactory sf = registry.lookup(host.getSchemeName());
  if (sf == null) {
    throw new UnsupportedSchemeException(host.getSchemeName() +
        " protocol is not supported");
  }
  if (!(sf instanceof LayeredConnectionSocketFactory)) {
    throw new UnsupportedSchemeException(host.getSchemeName() +
        " protocol does not support connection upgrade");
  }
  final LayeredConnectionSocketFactory lsf = (LayeredConnectionSocketFactory) sf;
  Socket sock = conn.getSocket();
  final int port = this.schemePortResolver.resolve(host);
  sock = lsf.createLayeredSocket(sock, host.getHostName(), port, context);
  conn.bind(sock);
}

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

public void upgrade(
    final ManagedHttpClientConnection conn,
    final HttpHost host,
    final HttpContext context) throws IOException {
  final HttpClientContext clientContext = HttpClientContext.adapt(context);
  final Lookup<ConnectionSocketFactory> registry = getSocketFactoryRegistry(clientContext);
  final ConnectionSocketFactory sf = registry.lookup(host.getSchemeName());
  if (sf == null) {
    throw new UnsupportedSchemeException(host.getSchemeName() +
        " protocol is not supported");
  }
  if (!(sf instanceof LayeredConnectionSocketFactory)) {
    throw new UnsupportedSchemeException(host.getSchemeName() +
        " protocol does not support connection upgrade");
  }
  final LayeredConnectionSocketFactory lsf = (LayeredConnectionSocketFactory) sf;
  Socket sock = conn.getSocket();
  final int port = this.schemePortResolver.resolve(host);
  sock = lsf.createLayeredSocket(sock, host.getHostName(), port, context);
  conn.bind(sock);
}

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

@Override
public void upgrade(
    final ManagedHttpClientConnection conn,
    final HttpHost host,
    final HttpContext context) throws IOException {
  final HttpClientContext clientContext = HttpClientContext.adapt(context);
  final Lookup<ConnectionSocketFactory> registry = getSocketFactoryRegistry(clientContext);
  final ConnectionSocketFactory sf = registry.lookup(host.getSchemeName());
  if (sf == null) {
    throw new UnsupportedSchemeException(host.getSchemeName() +
        " protocol is not supported");
  }
  if (!(sf instanceof LayeredConnectionSocketFactory)) {
    throw new UnsupportedSchemeException(host.getSchemeName() +
        " protocol does not support connection upgrade");
  }
  final LayeredConnectionSocketFactory lsf = (LayeredConnectionSocketFactory) sf;
  Socket sock = conn.getSocket();
  final int port = this.schemePortResolver.resolve(host);
  sock = lsf.createLayeredSocket(sock, host.getHostName(), port, context);
  conn.bind(sock);
}

代码示例来源：origin: Nextdoor/bender

@Override
public void upgrade(
    final ManagedHttpClientConnection conn,
    final HttpHost host,
    final HttpContext context) throws IOException {
  final HttpClientContext clientContext = HttpClientContext.adapt(context);
  final Lookup<ConnectionSocketFactory> registry = getSocketFactoryRegistry(clientContext);
  final ConnectionSocketFactory sf = registry.lookup(host.getSchemeName());
  if (sf == null) {
    throw new UnsupportedSchemeException(host.getSchemeName() +
        " protocol is not supported");
  }
  if (!(sf instanceof LayeredConnectionSocketFactory)) {
    throw new UnsupportedSchemeException(host.getSchemeName() +
        " protocol does not support connection upgrade");
  }
  final LayeredConnectionSocketFactory lsf = (LayeredConnectionSocketFactory) sf;
  Socket sock = conn.getSocket();
  final int port = this.schemePortResolver.resolve(host);
  sock = lsf.createLayeredSocket(sock, host.getHostName(), port, context);
  conn.bind(sock);
}

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

Lookup

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    Lookup类方法

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