org.keycloak.connections.infinispan.TopologyInfo クラス

org.keycloak.connections.infinispan.TopologyInfo 連携図

公開メンバ関数
	TopologyInfo (EmbeddedCacheManager cacheManager, Config.Scope config, boolean embedded)
String	getMyNodeName ()
String	getMySiteName ()
String	toString ()
boolean	amIOwner (Cache cache, Object key)
String	getRouteName (Cache cache, Object key)

非公開メンバ関数
String	generateNodeName ()
Address	getOwnerAddress (Cache cache, Object key)

静的非公開メンバ関数
static org.jgroups.Address	toJGroupsAddress (Address address)

非公開変数類
final String	myNodeName
final String	mySiteName
final boolean	isGeneratedNodeName

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

詳解

著者

Marek Posolda

構築子と解体子

TopologyInfo()

org.keycloak.connections.infinispan.TopologyInfo.TopologyInfo ( EmbeddedCacheManager  cacheManager, Config.Scope  config, boolean  embedded  )

inline

                                                                                                  {
        String siteName;
        String nodeName;
        boolean isGeneratedNodeName = false;

        if (!embedded) {
            Transport transport = cacheManager.getTransport();
            if (transport != null) {
                nodeName = transport.getAddress().toString();
                siteName = cacheManager.getCacheManagerConfiguration().transport().siteId();
                if (siteName == null) {
                    siteName = System.getProperty(InfinispanConnectionProvider.JBOSS_SITE_NAME);
                }
            } else {
                nodeName = System.getProperty(InfinispanConnectionProvider.JBOSS_NODE_NAME);
                siteName = System.getProperty(InfinispanConnectionProvider.JBOSS_SITE_NAME);
            }
            if (nodeName == null || nodeName.equals("localhost")) {
                isGeneratedNodeName = true;
                nodeName = generateNodeName();
            }
        } else {
            boolean clustered = config.getBoolean("clustered", false);

            nodeName = config.get("nodeName", System.getProperty(InfinispanConnectionProvider.JBOSS_NODE_NAME));
            if (nodeName != null && nodeName.isEmpty()) {
                nodeName = null;
            }

            siteName = config.get("siteName", System.getProperty(InfinispanConnectionProvider.JBOSS_SITE_NAME));
            if (siteName != null && siteName.isEmpty()) {
                siteName = null;
            }

            if (nodeName == null) {
                if (!clustered) {
                    isGeneratedNodeName = true;
                    nodeName = generateNodeName();
                } else {
                    throw new IllegalStateException("You must set jboss.node.name if you use clustered mode for InfinispanConnectionProvider");
                }
            }
        }

        this.myNodeName = nodeName;
        this.mySiteName = siteName;
        this.isGeneratedNodeName = isGeneratedNodeName;
    }

関数詳解

amIOwner()

boolean org.keycloak.connections.infinispan.TopologyInfo.amIOwner ( Cache  cache, Object  key  )

inline

True if I am primary owner of the key in case of distributed caches. In case of local caches, always return true

                                                     {
        Address myAddress = cache.getCacheManager().getAddress();
        Address objectOwnerAddress = getOwnerAddress(cache, key);

        // NOTE: For scattered caches, this will always return true, which may not be correct. Need to review this if we add support for scattered caches
        return Objects.equals(myAddress, objectOwnerAddress);
    }

generateNodeName()

String org.keycloak.connections.infinispan.TopologyInfo.generateNodeName ( )

inlineprivate

                                      {
        return InfinispanConnectionProvider.NODE_PREFIX + new SecureRandom().nextInt(1000000);
    }

getMyNodeName()

String org.keycloak.connections.infinispan.TopologyInfo.getMyNodeName ( )

inline

                                  {
        return myNodeName;
    }

getMySiteName()

String org.keycloak.connections.infinispan.TopologyInfo.getMySiteName ( )

inline

                                  {
        return mySiteName;
    }

getOwnerAddress()

Address org.keycloak.connections.infinispan.TopologyInfo.getOwnerAddress ( Cache  cache, Object  key  )

inlineprivate

                                                             {
        DistributionManager dist = cache.getAdvancedCache().getDistributionManager();
        Address address = (dist != null) && !cache.getCacheConfiguration().clustering().cacheMode().isScattered() ?
                dist.getCacheTopology().getDistribution(key).primary() :
                cache.getCacheManager().getAddress();

        return address;
    }

getRouteName()

String org.keycloak.connections.infinispan.TopologyInfo.getRouteName ( Cache  cache, Object  key  )

inline

Get route to be used as the identifier for sticky session. Return null if I am not able to find the appropriate route (or in case of local mode)

                                                        {
        if (cache.getCacheConfiguration().clustering().cacheMode().isClustered() && isGeneratedNodeName) {
            logger.warn("Clustered configuration used, but node name is not properly set. Make sure to start server with jboss.node.name property identifying cluster node");
        }

        if (isGeneratedNodeName) {
            return null;
        }

        // Impl based on Wildfly sticky session algorithm for generating routes ( org.wildfly.clustering.web.infinispan.session.InfinispanRouteLocator )
        Address address = getOwnerAddress(cache, key);

        // Local mode
        if (address == null ||  (address == LocalModeAddress.INSTANCE)) {
            return myNodeName;
        }

        org.jgroups.Address jgroupsAddress = toJGroupsAddress(address);
        String name = NameCache.get(jgroupsAddress);

        // If no logical name exists, create one using physical address
        if (name == null) {

            Transport transport = cache.getCacheManager().getTransport();
            JChannel jgroupsChannel = ((JGroupsTransport) transport).getChannel();

            IpAddress ipAddress = (IpAddress) jgroupsChannel.down(new Event(Event.GET_PHYSICAL_ADDRESS, jgroupsAddress));
            // Physical address might be null if node is no longer a member of the cluster
            InetSocketAddress socketAddress = (ipAddress != null) ? new InetSocketAddress(ipAddress.getIpAddress(), ipAddress.getPort()) : new InetSocketAddress(0);
            name = String.format("%s:%s", socketAddress.getHostString(), socketAddress.getPort());

            logger.debugf("Address not found in NameCache. Fallback to %s", name);
        }

        return name;
    }

toJGroupsAddress()

static org.jgroups.Address org.keycloak.connections.infinispan.TopologyInfo.toJGroupsAddress ( Address  address )

inlinestaticprivate

                                                                         {
        if ((address == null) || (address == LocalModeAddress.INSTANCE)) return null;
        if (address instanceof JGroupsAddress) {
            JGroupsAddress jgroupsAddress = (JGroupsAddress) address;
            return jgroupsAddress.getJGroupsAddress();
        }
        throw new IllegalArgumentException(address.toString());
    }

toString()

String org.keycloak.connections.infinispan.TopologyInfo.toString ( )

inline

                             {
        return String.format("Node name: %s, Site name: %s", myNodeName, mySiteName);
    }

メンバ詳解

isGeneratedNodeName

final boolean org.keycloak.connections.infinispan.TopologyInfo.isGeneratedNodeName

private

logger

final Logger org.keycloak.connections.infinispan.TopologyInfo.logger = Logger.getLogger(TopologyInfo.class)

staticprivate

myNodeName

final String org.keycloak.connections.infinispan.TopologyInfo.myNodeName

private

mySiteName

final String org.keycloak.connections.infinispan.TopologyInfo.mySiteName

private

---

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

• D:/AppData/doxygen/keycloak/src/keycloak/src/main/java/org/keycloak/connections/infinispan/TopologyInfo.java