org.keycloak.models.sessions.infinispan.util.InfinispanKeyGenerator クラス

org.keycloak.models.sessions.infinispan.util.InfinispanKeyGenerator 連携図

クラス
class	StringKeyGenerator
class	UUIDKeyGenerator

公開メンバ関数
String	generateKeyString (KeycloakSession session, Cache< String, ?> cache)
UUID	generateKeyUUID (KeycloakSession session, Cache< UUID, ?> cache)

関数
private< K > K	generateKey (KeycloakSession session, Cache< K, ?> cache, KeyGenerator< K > keyGenerator)
private< K > KeyAffinityService< K >	createKeyAffinityService (Cache< K, ?> cache, KeyGenerator< K > keyGenerator)

非公開変数類
final Map< String, KeyAffinityService >	keyAffinityServices = new ConcurrentHashMap<>()

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

詳解

著者

Marek Posolda

関数詳解

createKeyAffinityService()

private<K> KeyAffinityService<K> org.keycloak.models.sessions.infinispan.util.InfinispanKeyGenerator.createKeyAffinityService ( Cache< K, ?>  cache, KeyGenerator< K >  keyGenerator  )

inlinepackage

                                                                                                                {
        // SingleThreadExecutor is recommended due it needs the single thread and leave it in the WAITING state
        return KeyAffinityServiceFactory.newLocalKeyAffinityService(
                cache,
                keyGenerator,
                Executors.newSingleThreadExecutor(),
                16);
    }

generateKey()

private<K> K org.keycloak.models.sessions.infinispan.util.InfinispanKeyGenerator.generateKey ( KeycloakSession  session, Cache< K, ?>  cache, KeyGenerator< K >  keyGenerator  )

inlinepackage

                                                                                                        {
        String cacheName = cache.getName();

        // "wantsLocalKey" is true if route is not attached to the sticky session cookie. Without attached route, We want the key, which will be "owned" by this node.
        // This is needed due the fact that external loadbalancer will attach route corresponding to our node, which will be the owner of the particular key, hence we
        // will be able to lookup key locally.
        boolean wantsLocalKey = !session.getProvider(StickySessionEncoderProvider.class).shouldAttachRoute();

        if (wantsLocalKey && cache.getCacheConfiguration().clustering().cacheMode().isClustered()) {
            KeyAffinityService<K> keyAffinityService = keyAffinityServices.get(cacheName);
            if (keyAffinityService == null) {
                keyAffinityService = createKeyAffinityService(cache, keyGenerator);
                keyAffinityServices.put(cacheName, keyAffinityService);

                log.debugf("Registered key affinity service for cache '%s'", cacheName);
            }

            return keyAffinityService.getKeyForAddress(cache.getCacheManager().getAddress());
        } else {
            return keyGenerator.getKey();
        }

    }

generateKeyString()

String org.keycloak.models.sessions.infinispan.util.InfinispanKeyGenerator.generateKeyString ( KeycloakSession  session, Cache< String, ?>  cache  )

inline

                                                                                     {
        return generateKey(session, cache, new StringKeyGenerator());
    }

generateKeyUUID()

UUID org.keycloak.models.sessions.infinispan.util.InfinispanKeyGenerator.generateKeyUUID ( KeycloakSession  session, Cache< UUID, ?>  cache  )

inline

                                                                               {
        return generateKey(session, cache, new UUIDKeyGenerator());
    }

メンバ詳解

keyAffinityServices

final Map<String, KeyAffinityService> org.keycloak.models.sessions.infinispan.util.InfinispanKeyGenerator.keyAffinityServices = new ConcurrentHashMap<>()

private

log

final Logger org.keycloak.models.sessions.infinispan.util.InfinispanKeyGenerator.log = Logger.getLogger(InfinispanKeyGenerator.class)

staticprivate

---

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

• D:/AppData/doxygen/keycloak/src/keycloak/src/main/java/org/keycloak/models/sessions/infinispan/util/InfinispanKeyGenerator.java