org.keycloak.adapters.NodesRegistrationManagement クラス

org.keycloak.adapters.NodesRegistrationManagement 連携図

クラス
class	NodeRegistrationContext

公開メンバ関数
void	tryRegister (final KeycloakDeployment resolvedDeployment)
void	stop ()

限定公開メンバ関数
void	sendRegistrationEvent (KeycloakDeployment deployment)
boolean	sendUnregistrationEvent (KeycloakDeployment deployment)

非公開メンバ関数
boolean	needRefreshRegistration (String registrationUri, KeycloakDeployment resolvedDeployment)

非公開変数類
final Map< String, NodeRegistrationContext >	nodeRegistrations = new ConcurrentHashMap<String, NodeRegistrationContext>()
final Executor	executor = Executors.newSingleThreadExecutor()

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

詳解

著者

Marek Posolda

関数詳解

needRefreshRegistration()

boolean org.keycloak.adapters.NodesRegistrationManagement.needRefreshRegistration ( String  registrationUri, KeycloakDeployment  resolvedDeployment  )

inlineprivate

We don't yet have any registration for this node

                                                                                                           {
        NodeRegistrationContext currentRegistration = nodeRegistrations.get(registrationUri);
        if (currentRegistration == null) {
            return true;
        }

        return currentRegistration.lastRegistrationTime + resolvedDeployment.getRegisterNodePeriod() < Time.currentTime();
    }

sendRegistrationEvent()

void org.keycloak.adapters.NodesRegistrationManagement.sendRegistrationEvent ( KeycloakDeployment  deployment )

inlineprotected

                                                                        {
        log.debug("Sending registration event right now");

        String host = HostUtils.getHostName();
        try {
            ServerRequest.invokeRegisterNode(deployment, host);
            NodeRegistrationContext regContext = new NodeRegistrationContext(Time.currentTime(), deployment);
            nodeRegistrations.put(deployment.getRegisterNodeUrl(), regContext);
            log.debugf("Node '%s' successfully registered in Keycloak", host);
        } catch (ServerRequest.HttpFailure failure) {
            log.error("failed to register node to keycloak");
            log.error("status from server: " + failure.getStatus());
            if (failure.getError() != null) {
                log.error("   " + failure.getError());
            }
        } catch (IOException e) {
            log.error("failed to register node to keycloak", e);
        }
    }

sendUnregistrationEvent()

boolean org.keycloak.adapters.NodesRegistrationManagement.sendUnregistrationEvent ( KeycloakDeployment  deployment )

inlineprotected

                                                                             {
        log.debug("Sending Unregistration event right now");

        String host = HostUtils.getHostName();
        try {
            ServerRequest.invokeUnregisterNode(deployment, host);
            log.debugf("Node '%s' successfully unregistered from Keycloak", host);
            return true;
        } catch (ServerRequest.HttpFailure failure) {
            log.error("failed to unregister node from keycloak");
            log.error("status from server: " + failure.getStatus());
            if (failure.getError() != null) {
                log.error("   " + failure.getError());
            }
            return false;
        } catch (IOException e) {
            log.error("failed to unregister node from keycloak", e);
            return false;
        }
    }

stop()

void org.keycloak.adapters.NodesRegistrationManagement.stop ( )

inline

Called during undeployment or server stop. De-register from all previously registered deployments

                       {
        Collection<NodeRegistrationContext> allRegistrations = nodeRegistrations.values();
        for (NodeRegistrationContext registration : allRegistrations) {
            sendUnregistrationEvent(registration.resolvedDeployment);
        }
    }

tryRegister()

void org.keycloak.adapters.NodesRegistrationManagement.tryRegister ( final KeycloakDeployment  resolvedDeployment )

inline

                                                                         {
        if (resolvedDeployment.isRegisterNodeAtStartup()) {
            final String registrationUri = resolvedDeployment.getRegisterNodeUrl();
            if (needRefreshRegistration(registrationUri, resolvedDeployment)) {
                Runnable runnable = new Runnable() {

                    @Override
                    public void run() {
                        // Need to check it again in case that executor triggered by other thread already finished computation in the meantime
                        if (needRefreshRegistration(registrationUri, resolvedDeployment)) {
                            sendRegistrationEvent(resolvedDeployment);
                        }
                    }
                };
                executor.execute(runnable);
            }
        }
    }

メンバ詳解

executor

final Executor org.keycloak.adapters.NodesRegistrationManagement.executor = Executors.newSingleThreadExecutor()

private

log

final Logger org.keycloak.adapters.NodesRegistrationManagement.log = Logger.getLogger(NodesRegistrationManagement.class)

staticprivate

nodeRegistrations

final Map<String, NodeRegistrationContext> org.keycloak.adapters.NodesRegistrationManagement.nodeRegistrations = new ConcurrentHashMap<String, NodeRegistrationContext>()

private

---

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

• D:/AppData/OpenId/keycloak/doxygen/src/adapters/oidc/adapter-core/src/main/java/org/keycloak/adapters/NodesRegistrationManagement.java