org.keycloak.connections.httpclient.DefaultHttpClientFactory クラス

org.keycloak.connections.httpclient.DefaultHttpClientFactory の継承関係図

org.keycloak.connections.httpclient.DefaultHttpClientFactory 連携図

公開メンバ関数
HttpClientProvider	create (KeycloakSession session)
void	close ()
String	getId ()
void	init (Config.Scope config)
void	postInit (KeycloakSessionFactory factory)

非公開メンバ関数
void	lazyInit (KeycloakSession session)

非公開変数類
volatile CloseableHttpClient	httpClient
Config.Scope	config

静的非公開変数類
static final Logger	logger = Logger.getLogger(DefaultHttpClientFactory.class)

詳解

The default HttpClientFactory for HttpClientProvider's used by Keycloak for outbound HTTP calls.

The constructed clients can be configured via Keycloaks SPI configuration, e.g.

standalone.xml, standalone-ha.xml, domain.xml 

.

Examples for jboss-cli

/subsystem=keycloak-server/spi=connectionsHttpClient/provider=default:add(enabled=true)
/subsystem=keycloak-server/spi=connectionsHttpClient/provider=default:write-attribute(name=properties.connection-pool-size,value=128)
/subsystem=keycloak-server/spi=connectionsHttpClient/provider=default:write-attribute(name=properties.proxy-mappings,value=[".*\\.(google|googleapis)\\.com;http://www-proxy.acme.corp.com:8080",".*\\.acme\\.corp\\.com;NO_PROXY",".*;http://fallback:8080"])
 

著者

Stian Thorgersen

関数詳解

close()

void org.keycloak.connections.httpclient.DefaultHttpClientFactory.close ( )

inline

                        {
        try {
            if (httpClient != null) {
                httpClient.close();
            }
        } catch (IOException e) {

        }
    }

create()

HttpClientProvider org.keycloak.connections.httpclient.DefaultHttpClientFactory.create ( KeycloakSession  session )

inline

                                                              {
        lazyInit(session);

        return new HttpClientProvider() {
            @Override
            public HttpClient getHttpClient() {
                return httpClient;
            }

            @Override
            public void close() {

            }

            @Override
            public int postText(String uri, String text) throws IOException {
                HttpPost request = new HttpPost(uri);
                request.setEntity(EntityBuilder.create().setText(text).setContentType(ContentType.TEXT_PLAIN).build());
                HttpResponse response = httpClient.execute(request);
                try {
                    return response.getStatusLine().getStatusCode();
                } finally {
                    HttpEntity entity = response.getEntity();
                    if (entity != null) {
                        InputStream is = entity.getContent();
                        if (is != null) is.close();
                    }

                }
            }

            @Override
            public InputStream get(String uri) throws IOException {
                HttpGet request = new HttpGet(uri);
                HttpResponse response = httpClient.execute(request);
                HttpEntity entity = response.getEntity();
                if (entity == null) return null;
                return entity.getContent();

            }
        };
    }

getId()

String org.keycloak.connections.httpclient.DefaultHttpClientFactory.getId ( )

inline

                          {
        return "default";
    }

init()

void org.keycloak.connections.httpclient.DefaultHttpClientFactory.init ( Config.Scope  config )

inline

                                          {
        this.config = config;
    }

lazyInit()

void org.keycloak.connections.httpclient.DefaultHttpClientFactory.lazyInit ( KeycloakSession  session )

inlineprivate

                                                   {
        if (httpClient == null) {
            synchronized(this) {
                if (httpClient == null) {
                    long socketTimeout = config.getLong("socket-timeout-millis", -1L);
                    long establishConnectionTimeout = config.getLong("establish-connection-timeout-millis", -1L);
                    int maxPooledPerRoute = config.getInt("max-pooled-per-route", 64);
                    int connectionPoolSize = config.getInt("connection-pool-size", 128);
                    long connectionTTL = config.getLong("connection-ttl-millis", -1L);
                    long maxConnectionIdleTime = config.getLong("max-connection-idle-time-millis", 900000L);
                    boolean disableCookies = config.getBoolean("disable-cookies", true);
                    String clientKeystore = config.get("client-keystore");
                    String clientKeystorePassword = config.get("client-keystore-password");
                    String clientPrivateKeyPassword = config.get("client-key-password");
                    String[] proxyMappings = config.getArray("proxy-mappings");

                    TruststoreProvider truststoreProvider = session.getProvider(TruststoreProvider.class);
                    boolean disableTrustManager = truststoreProvider == null || truststoreProvider.getTruststore() == null;
                    if (disableTrustManager) {
                        logger.warn("Truststore is disabled");
                    }
                    HttpClientBuilder.HostnameVerificationPolicy hostnamePolicy = disableTrustManager ? null
                            : HttpClientBuilder.HostnameVerificationPolicy.valueOf(truststoreProvider.getPolicy().name());

                    HttpClientBuilder builder = new HttpClientBuilder();

                    builder.socketTimeout(socketTimeout, TimeUnit.MILLISECONDS)
                            .establishConnectionTimeout(establishConnectionTimeout, TimeUnit.MILLISECONDS)
                            .maxPooledPerRoute(maxPooledPerRoute)
                            .connectionPoolSize(connectionPoolSize)
                            .connectionTTL(connectionTTL, TimeUnit.MILLISECONDS)
                            .maxConnectionIdleTime(maxConnectionIdleTime, TimeUnit.MILLISECONDS)
                            .disableCookies(disableCookies)
                            .proxyMappings(ProxyMappings.valueOf(proxyMappings));

                    if (disableTrustManager) {
                        // TODO: is it ok to do away with disabling trust manager?
                        //builder.disableTrustManager();
                    } else {
                        builder.hostnameVerification(hostnamePolicy);
                        try {
                            builder.trustStore(truststoreProvider.getTruststore());
                        } catch (Exception e) {
                            throw new RuntimeException("Failed to load truststore", e);
                        }
                    }

                    if (clientKeystore != null) {
                        clientKeystore = EnvUtil.replace(clientKeystore);
                        try {
                            KeyStore clientCertKeystore = KeystoreUtil.loadKeyStore(clientKeystore, clientKeystorePassword);
                            builder.keyStore(clientCertKeystore, clientPrivateKeyPassword);
                        } catch (Exception e) {
                            throw new RuntimeException("Failed to load keystore", e);
                        }
                    }
                    httpClient = builder.build();
                }
            }
        }
    }

postInit()

void org.keycloak.connections.httpclient.DefaultHttpClientFactory.postInit ( KeycloakSessionFactory  factory )

inline

                                                         {

    }

メンバ詳解

config

Config.Scope org.keycloak.connections.httpclient.DefaultHttpClientFactory.config

private

httpClient

volatile CloseableHttpClient org.keycloak.connections.httpclient.DefaultHttpClientFactory.httpClient

private

logger

final Logger org.keycloak.connections.httpclient.DefaultHttpClientFactory.logger = Logger.getLogger(DefaultHttpClientFactory.class)

staticprivate

---

このクラス詳解は次のファイルから抽出されました:

• D:/AppData/doxygen/keycloak/rest-service/src/services/src/main/java/org/keycloak/connections/httpclient/DefaultHttpClientFactory.java