org.apache.http.client.CredentialsProvider类的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(16.0k)|赞(0)|评价(0)|浏览(1202)

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

CredentialsProvider介绍

[英]Abstract credentials provider.
[中]抽象凭证提供者。

代码示例

代码示例来源：origin: eirslett/frontend-maven-plugin

private CredentialsProvider makeCredentialsProvider(String host, int port, String username, String password) {
  CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
  credentialsProvider.setCredentials(
      new AuthScope(host, port),
      new UsernamePasswordCredentials(username, password)
  );
  return credentialsProvider;
}

代码示例来源：origin: yasserg/crawler4j

@Override
  public void process(HttpRequest request, HttpContext context) {
    AuthState authState = (AuthState) context.getAttribute(HttpClientContext.TARGET_AUTH_STATE);
    if (authState.getAuthScheme() == null) {
      CredentialsProvider credsProvider =
          (CredentialsProvider) context.getAttribute(HttpClientContext.CREDS_PROVIDER);
      HttpHost targetHost = (HttpHost) context.getAttribute(HttpCoreContext.HTTP_TARGET_HOST);
      Credentials credentials = credsProvider.getCredentials(
          new AuthScope(targetHost.getHostName(), targetHost.getPort()));
      if (credentials != null) {
        authState.update(new BasicScheme(), credentials);
      }
    }
  }
}

代码示例来源：origin: kaaproject/kaa

/**
 * Clear credentials of current user.
 */
public void clearCredentials() {
 HttpComponentsRequestFactoryBasicAuth requestFactory =
   (HttpComponentsRequestFactoryBasicAuth) restTemplate.getRequestFactory();
 requestFactory.getCredentialsProvider().clear();
}

代码示例来源：origin: pentaho/pentaho-kettle

public HttpClient createHttpClient( String user, String password,
                       String proxyHost, int proxyPort, AuthScope authScope ) {
 HttpHost httpHost = new HttpHost( proxyHost, proxyPort );
 RequestConfig requestConfig = RequestConfig.custom()
  .setProxy( httpHost )
  .build();
 CredentialsProvider provider = new BasicCredentialsProvider();
 UsernamePasswordCredentials credentials = new UsernamePasswordCredentials( user, password );
 provider.setCredentials( authScope, credentials );
 return
  HttpClientBuilder
   .create()
   .setDefaultCredentialsProvider( provider )
   .setDefaultRequestConfig( requestConfig )
   .setConnectionManager( manager )
   .build();
}

代码示例来源：origin: yasserg/crawler4j

connectionManager.setDefaultMaxPerRoute(config.getMaxConnectionsPerHost());
HttpClientBuilder clientBuilder = HttpClientBuilder.create();
if (config.getCookieStore() != null) {
  clientBuilder.setDefaultCookieStore(config.getCookieStore());
clientBuilder.setDefaultRequestConfig(requestConfig);
clientBuilder.setConnectionManager(connectionManager);
clientBuilder.setUserAgent(config.getUserAgentString());
if (config.getProxyHost() != null) {
  if (config.getProxyUsername() != null) {
    AuthScope authScope = new AuthScope(config.getProxyHost(), config.getProxyPort());
    Credentials credentials = new UsernamePasswordCredentials(config.getProxyUsername(),
        config.getProxyPassword());
    credentialsMap.put(authScope, credentials);
  HttpHost proxy = new HttpHost(config.getProxyHost(), config.getProxyPort());
  clientBuilder.setProxy(proxy);
  logger.debug("Working through Proxy: {}", proxy.getHostName());
    CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
    credentialsMap.forEach((AuthScope authscope, Credentials credentials) -> {
      credentialsProvider.setCredentials(authscope, credentials);
    });
    clientBuilder.setDefaultCredentialsProvider(credentialsProvider);

代码示例来源：origin: pentaho/pentaho-kettle

public HttpClient createHttpClient( String user, String password ) {
 CredentialsProvider provider = new BasicCredentialsProvider();
 UsernamePasswordCredentials credentials = new UsernamePasswordCredentials( user, password );
 provider.setCredentials( AuthScope.ANY, credentials );
 return
  HttpClientBuilder
   .create()
   .setDefaultCredentialsProvider( provider )
   .setConnectionManager( manager )
   .build();
}

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

final HttpClientBuilder clientBuilder = HttpClientBuilder.create();
clientBuilder.setConnectionManager(getConnectionManager(client, config, sslContext));
clientBuilder.setConnectionManagerShared(
    PropertiesHelper.getValue(config.getProperties(), ApacheClientProperties.CONNECTION_MANAGER_SHARED, false, null));
clientBuilder.setSslcontext(sslContext);
if (proxyUri != null) {
  final URI u = getProxyUri(proxyUri);
  final HttpHost proxy = new HttpHost(u.getHost(), u.getPort(), u.getScheme());
  final String userName;
  userName = ClientProperties.getValue(config.getProperties(), ClientProperties.PROXY_USERNAME, String.class);
      final CredentialsProvider credsProvider = new BasicCredentialsProvider();
      credsProvider.setCredentials(
          new AuthScope(u.getHost(), u.getPort()),
          new UsernamePasswordCredentials(userName, password)
      );
      clientBuilder.setDefaultCredentialsProvider(credsProvider);

代码示例来源：origin: igniterealtime/Openfire

final HttpHost target = HttpHost.create(crowdServer.toString());
final PoolingHttpClientConnectionManager connectionManager = new PoolingHttpClientConnectionManager();
connectionManager.setDefaultMaxPerRoute(crowdProps.getHttpMaxConnections());
final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
credentialsProvider.setCredentials(
  new AuthScope(target.getHostName(), target.getPort()),
  new UsernamePasswordCredentials(crowdProps.getApplicationName(), crowdProps.getApplicationPassword()));
final AuthCache authCache = new BasicAuthCache();
authCache.put(target, new BasicScheme());
  proxyString = proxyHost.toString();
  if (StringUtils.isNotBlank(crowdProps.getHttpProxyUsername()) || StringUtils.isNotBlank(crowdProps.getHttpProxyPassword())) {
    credentialsProvider.setCredentials(new AuthScope(crowdProps.getHttpProxyHost(), crowdProps.getHttpProxyPort()),
      new UsernamePasswordCredentials(crowdProps.getHttpProxyUsername(), crowdProps.getHttpProxyPassword()));
client = HttpClientBuilder.create()
  .setConnectionManager(connectionManager)
  .setDefaultCredentialsProvider(credentialsProvider)
  .setRoutePlanner(httpRoutePlanner)
  .build();

代码示例来源：origin: kaaproject/kaa

this.configuration = configuration;
this.executor = Executors.newFixedThreadPool(configuration.getConnectionPoolSize());
target = new HttpHost(configuration.getHost(),
  configuration.getPort(), configuration.getSsl() ? "https" : "http");
HttpClientBuilder builder = HttpClients.custom();
if (configuration.getUsername() != null && configuration.getPassword() != null) {
 LOG.info("Adding basic auth credentials provider");
 CredentialsProvider credsProvider = new BasicCredentialsProvider();
 credsProvider.setCredentials(new AuthScope(target.getHostName(), target.getPort()),
   new UsernamePasswordCredentials(configuration.getUsername(), configuration.getPassword())
 );
 builder.setDefaultCredentialsProvider(credsProvider);
  sslBuilder.loadTrustMaterial(null, new TrustSelfSignedStrategy());
  SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(sslBuilder.build());
  builder.setSSLSocketFactory(sslsf);
 } catch (NoSuchAlgorithmException | KeyStoreException | KeyManagementException ex) {
  LOG.error("Failed to init socket factory {}", ex.getMessage(), ex);
cm.setDefaultMaxPerRoute(configuration.getConnectionPoolSize());
cm.setMaxTotal(configuration.getConnectionPoolSize());
builder.setConnectionManager(cm);
this.client = builder.build();

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

.setRequestExecutor(new InstrumentedHttpRequestExecutor(metricRegistry, metricNameStrategy, name))
  .setConnectionManager(manager)
  .setDefaultRequestConfig(requestConfig)
  .setDefaultSocketConfig(socketConfig)
  .setConnectionReuseStrategy(reuseStrategy)
final HttpHost httpHost = new HttpHost(proxy.getHost(), proxy.getPort(), proxy.getScheme());
builder.setRoutePlanner(new NonProxyListProxyRoutePlanner(httpHost, proxy.getNonProxyHosts()));
if (auth != null) {
  if (credentialsProvider == null) {
    credentialsProvider = new BasicCredentialsProvider();
  AuthScope authScope = new AuthScope(httpHost, auth.getRealm(), auth.getAuthScheme());
  credentialsProvider.setCredentials(authScope, credentials);

代码示例来源：origin: wiztools/rest-client

hcBuilder.setRetryHandler(new DefaultHttpRequestRetryHandler(0, false));
proxy.acquire();
if (proxy.isEnabled()) {
  final HttpHost proxyHost = new HttpHost(proxy.getHost(), proxy.getPort(), "http");
  if (proxy.isAuthEnabled()) {
    CredentialsProvider credsProvider = new BasicCredentialsProvider();
    credsProvider.setCredentials(
        new AuthScope(proxy.getHost(), proxy.getPort()),
        new UsernamePasswordCredentials(proxy.getUsername(), new String(proxy.getPassword())));
    hcBuilder.setDefaultCredentialsProvider(credsProvider);
  hcBuilder.setProxy(proxyHost);
    String realm = StringUtil.isEmpty(a.getRealm()) ? AuthScope.ANY_REALM : a.getRealm();
    CredentialsProvider credsProvider = new BasicCredentialsProvider();
    credsProvider.setCredentials(
        new AuthScope(host, urlPort, realm),
        new UsernamePasswordCredentials(uid, pwd));
    hcBuilder.setDefaultCredentialsProvider(credsProvider);
    String pwd = new String(a.getPassword());
    CredentialsProvider credsProvider = new BasicCredentialsProvider();
    credsProvider.setCredentials(
        AuthScope.ANY,
        new NTCredentials(

代码示例来源：origin: pentaho/pentaho-kettle

HttpClientContext localContext = null;
try {
 HttpHost target = new HttpHost( host, port, schema );
 CredentialsProvider credsProvider = new BasicCredentialsProvider();
 credsProvider.setCredentials(
  new AuthScope( target.getHostName(), target.getPort() ),
  new UsernamePasswordCredentials( user, password ) );

代码示例来源：origin: jamesagnew/hapi-fhir

public static void main(String[] args) {
 /*
  * This is out ot date - Just keeping
  * it in case it's helpful...
  */
 final String authUser = "username"; 
 final String authPassword = "password"; 
 CredentialsProvider credsProvider = new BasicCredentialsProvider();
 credsProvider.setCredentials(new AuthScope("10.10.10.10", 8080),
    new UsernamePasswordCredentials(authUser, authPassword)); 
 HttpHost myProxy = new HttpHost("10.10.10.10", 8080);
 
 
 HttpClientBuilder clientBuilder = HttpClientBuilder.create(); 
 clientBuilder
   .setProxy(myProxy)
   .setProxyAuthenticationStrategy(new ProxyAuthenticationStrategy())
   .setDefaultCredentialsProvider(credsProvider) 
   .disableCookieManagement(); 
 CloseableHttpClient httpClient = clientBuilder.build();
 
 FhirContext ctx = FhirContext.forDstu2(); 
 String serverBase = "http://spark.furore.com/fhir/"; 
 ctx.getRestfulClientFactory().setHttpClient(httpClient); 
 IGenericClient client = ctx.newRestfulGenericClient(serverBase); 
 IdDt id = new IdDt("Patient", "123"); 
 client.read(Patient.class, id); 
 
}

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

private HttpClient openConnection() throws IOException {
  HttpClientBuilder httpClientBuilder = HttpClientBuilder.create();
  if (sslContextService != null) {
    try {
      SSLContext sslContext = getSslSocketFactory(sslContextService);
      httpClientBuilder.setSSLContext(sslContext);
    } catch (KeyStoreException | CertificateException | NoSuchAlgorithmException | UnrecoverableKeyException | KeyManagementException e) {
      throw new IOException(e);
    }
  }
  if (credentialsService != null) {
    CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
    credentialsProvider.setCredentials(new AuthScope(null, -1, null),
      new KerberosKeytabCredentials(credentialsService.getPrincipal(), credentialsService.getKeytab()));
    httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);
    Lookup<AuthSchemeProvider> authSchemeRegistry = RegistryBuilder.<AuthSchemeProvider> create()
      .register(AuthSchemes.SPNEGO, new KerberosKeytabSPNegoAuthSchemeProvider()).build();
    httpClientBuilder.setDefaultAuthSchemeRegistry(authSchemeRegistry);
  }
  RequestConfig.Builder requestConfigBuilder = RequestConfig.custom();
  requestConfigBuilder.setConnectTimeout(connectTimeout);
  requestConfigBuilder.setConnectionRequestTimeout(connectTimeout);
  requestConfigBuilder.setSocketTimeout(connectTimeout);
  httpClientBuilder.setDefaultRequestConfig(requestConfigBuilder.build());
  return httpClientBuilder.build();
}

代码示例来源：origin: jamesagnew/hapi-fhir

public synchronized HttpClient getNativeHttpClient() {
  if (myHttpClient == null) {
    //FIXME potential resoource leak
    PoolingHttpClientConnectionManager connectionManager = new PoolingHttpClientConnectionManager(5000,
        TimeUnit.MILLISECONDS);
    connectionManager.setMaxTotal(getPoolMaxTotal());
    connectionManager.setDefaultMaxPerRoute(getPoolMaxPerRoute());
    // @formatter:off
    //TODO: Use of a deprecated method should be resolved.
    RequestConfig defaultRequestConfig = RequestConfig.custom().setSocketTimeout(getSocketTimeout())
        .setConnectTimeout(getConnectTimeout()).setConnectionRequestTimeout(getConnectionRequestTimeout())
        .setStaleConnectionCheckEnabled(true).setProxy(myProxy).build();
    HttpClientBuilder builder = HttpClients.custom().setConnectionManager(connectionManager)
        .setDefaultRequestConfig(defaultRequestConfig).disableCookieManagement();
    if (myProxy != null && StringUtils.isNotBlank(getProxyUsername()) && StringUtils.isNotBlank(getProxyPassword())) {
      CredentialsProvider credsProvider = new BasicCredentialsProvider();
      credsProvider.setCredentials(new AuthScope(myProxy.getHostName(), myProxy.getPort()),
          new UsernamePasswordCredentials(getProxyUsername(), getProxyPassword()));
      builder.setProxyAuthenticationStrategy(new ProxyAuthenticationStrategy());
      builder.setDefaultCredentialsProvider(credsProvider);
    }
    myHttpClient = builder.build();
    // @formatter:on
  }
  return myHttpClient;
}

代码示例来源：origin: iSafeBlue/TrackRay

private CloseableHttpClient getCloseableHttpClient(HttpProxy proxy) {
  if (null != proxy && proxy.isProxy()) {
    HttpHost proxyHost = new HttpHost(proxy.getHost(), proxy.getPort());
    CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
    if (null != proxy.getUser() && null != proxy.getPassword()) {
      credentialsProvider.setCredentials(new AuthScope(proxy.getHost(), proxy.getPort()),
          new UsernamePasswordCredentials(proxy.getUser(), proxy.getPassword()));
    }
    return HttpClients.custom().setProxy(proxyHost).setDefaultCredentialsProvider(credentialsProvider).build();
  }
  return HttpClients.custom().setConnectionManager(connManager).build();
}

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

/**
 * this handles rest calls. each request creates a different httpClient object
 */
public HttpResponse doRequest(HttpRequestBase request, String username, String password) {
 HttpClientBuilder clientBuilder = HttpClients.custom();
 HttpClientContext clientContext = HttpClientContext.create();
 // configures the clientBuilder and clientContext
 if (username != null) {
  CredentialsProvider credsProvider = new BasicCredentialsProvider();
  credsProvider.setCredentials(new AuthScope(bindAddress, restPort),
    new UsernamePasswordCredentials(username, password));
  clientBuilder.setDefaultCredentialsProvider(credsProvider);
 }
 try {
  if (useSsl) {
   SSLContext ctx = SSLContext.getInstance("TLS");
   ctx.init(new KeyManager[0], new TrustManager[] {new DefaultTrustManager()},
     new SecureRandom());
   clientBuilder.setSSLContext(ctx);
   clientBuilder.setSSLHostnameVerifier(new NoopHostnameVerifier());
  }
  return clientBuilder.build().execute(host, request, clientContext);
 } catch (Exception e) {
  throw new RuntimeException(e.getMessage(), e);
 }
}

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

final HttpClientBuilder clientBuilder = HttpClientBuilder.create();
clientBuilder.setConnectionManager(conMan);
  clientBuilder.setUserAgent(userAgent);
final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
clientBuilder.setDefaultCredentialsProvider(credentialsProvider);
if (username != null) {
  credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials(username, password));

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

RestTemplate restTemplate = new RestTemplate();

CredentialsProvider credsProvider = new BasicCredentialsProvider();
credsProvider.setCredentials( new AuthScope("proxyHost", "proxyPort"), new UsernamePasswordCredentials("proxyUser", "proxyPass") );
HttpClientBuilder clientBuilder = HttpClientBuilder.create();

clientBuilder.useSystemProperties();
clientBuilder.setProxy(new HttpHost("proxyHost", "proxyPort"));
clientBuilder.setDefaultCredentialsProvider(credsProvider);
clientBuilder.setProxyAuthenticationStrategy(new ProxyAuthenticationStrategy());

CloseableHttpClient client = clientBuilder.build();

HttpComponentsClientHttpRequestFactory factory = new HttpComponentsClientHttpRequestFactory();
factory.setHttpClient(client);

restTemplate.setRequestFactory(factory);

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

CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
credentialsProvider.setCredentials(
    new AuthScope(SERVER_HOSTNAME, portConfig.getPort()),
    new UsernamePasswordCredentials(portConfig.getUser().getUsername(), portConfig.getUser().getPassword()));
    .setSslcontext(sslContext)
    .setHostnameVerifier(hostnameVerifier)
    .setDefaultCredentialsProvider(credentialsProvider)
    .build();

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

CredentialsProvider

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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