import org.keycloak.adapters.KeycloakDeploymentBuilder; //导入依赖的package包/类
@Bean
@ConditionalOnProperty(name="shiny.proxy.authentication", havingValue="keycloak")
protected AdapterDeploymentContext adapterDeploymentContext() throws Exception {
	AdapterConfig cfg = new AdapterConfig();
	cfg.setRealm(environment.getProperty("shiny.proxy.keycloak.realm"));
	cfg.setAuthServerUrl(environment.getProperty("shiny.proxy.keycloak.auth-server-url"));
	cfg.setResource(environment.getProperty("shiny.proxy.keycloak.resource"));
	Map<String,Object> credentials = new HashMap<>();
	credentials.put("secret", environment.getProperty("shiny.proxy.keycloak.credentials-secret"));
	cfg.setCredentials(credentials);
	KeycloakDeployment dep = KeycloakDeploymentBuilder.build(cfg);
	AdapterDeploymentContextFactoryBean factoryBean = new AdapterDeploymentContextFactoryBean(new KeycloakConfigResolver() {
		@Override
		public KeycloakDeployment resolve(Request facade) {
			return dep;
		}
	});
	factoryBean.afterPropertiesSet();
	return factoryBean.getObject();
}
 

import org.keycloak.adapters.KeycloakDeploymentBuilder; //导入依赖的package包/类
@Override
public void setup(Config config) {
    String configFile = "classpath:conf/keycloak.json";
    if (config.hasPath("file")) {
        configFile = config.getString("file");
    }

    keycloakConfig = parseKeycloakConfig(configFile);
    keycloakDeployment = KeycloakDeploymentBuilder.build(keycloakConfig);

    realmName = keycloakConfig.getRealm() + "/" + keycloakConfig.getResource();
    if (config.hasPath("name")) {
        realmName = config.getString("name");
    }

    definedRoles.clear();
    definedRoles.putAll(parseDefinedRoles(config));
}
 

import org.keycloak.adapters.KeycloakDeploymentBuilder; //导入依赖的package包/类
public KeycloakDeployment resolve(final HttpFacade.Request request) {
    Assert.requireNonNull(request, "request");

    final String realmName = Optional.ofNullable(request.getHeader(REALM_NAME_HEADER)).
            orElse(configuration.getRealmName());
    final String applicationName = Optional.ofNullable(request.getHeader(APPLICATION_NAME_HEADER)).
            orElse(configuration.getApplicationName());
    final String authEndPoint = configuration.getAuthEndpoint();

    Optional.ofNullable(realmName).orElseThrow(() -> new SecurityException("Realm name for security check is not configured!"));
    Optional.ofNullable(applicationName).orElseThrow(() -> new SecurityException("Application name for security check is not configured!"));
    Optional.ofNullable(authEndPoint).orElseThrow(() -> new SecurityException("Auth endpoint for security check is not configured!"));

    final AdapterConfig adapterConfig = new AdapterConfig();
    adapterConfig.setRealm(realmName);
    adapterConfig.setResource(applicationName);
    adapterConfig.setAuthServerUrl(authEndPoint);
    Optional.ofNullable(request.getHeader(BEARER_ONLY_HEADER)).
            ifPresent(v -> adapterConfig.setBearerOnly(true));
    return KeycloakDeploymentBuilder.build(adapterConfig);
}
 

import org.keycloak.adapters.KeycloakDeploymentBuilder; //导入依赖的package包/类
@Override
public void run(LotteryConfiguration configuration, Environment environment)
        throws ClassNotFoundException, IOException {

    // tag::keycloak[]
    KeycloakDeployment keycloakDeployment = KeycloakDeploymentBuilder.build(configuration.getKeycloakConfiguration());
    JaxrsBearerTokenFilterImpl filter = new DropwizardBearerTokenFilterImpl(keycloakDeployment);
    environment.jersey().register(filter);
    // end::keycloak[]

    environment.jersey().register(new DrawRessource());

    // support annotation @RolesAllowed
    // tag::roles[]
    environment.jersey().register(RolesAllowedDynamicFeature.class);
    // end::roles[]

}
 

import org.keycloak.adapters.KeycloakDeploymentBuilder; //导入依赖的package包/类
private synchronized KeycloakDeployment getKeycloakDeployment() throws IOException {
	if (keycloakDeployment == null || keycloakDeployment.getClient() == null) {
		AdapterConfig adapterConfig = JsonSerialization.readValue(getKeycloakJson(), AdapterConfig.class);
		keycloakDeployment = KeycloakDeploymentBuilder.build(adapterConfig);
	}
	return keycloakDeployment;
}
 

import org.keycloak.adapters.KeycloakDeploymentBuilder; //导入依赖的package包/类
public KeycloakDeployment resolve(String uri) {
    String dbId = databaseId(uri);
    KeycloakDeployment deployment = cacheByDb.get(dbId);
    if (deployment == null) {
        // Find the realm name and its deployment ...
        String realmName = realmName(dbId);
        if (realmName == null) {
            // There is no realm for this database ..
            logger.error("Failed to find realm for database '{}'", dbId);
            throw new DebeziumAuthorizationException();
        }
        deployment = cacheByRealm.get(realmName);
        if (deployment == null) {
            // We have to read in the deployment ...
            try (InputStream stream = loadRealmConfiguration(realmName)) {
                if (stream == null) {
                    logger.error("Failed to find configuration for realm '{}' for database '{}'", realmName, dbId);
                    throw new DebeziumAuthorizationException();
                }
                realmLoads.incrementAndGet();
                deployment = KeycloakDeploymentBuilder.build(stream);
                cacheByRealm.put(realmName, deployment);
            } catch (IOException e) {
                throw new IllegalStateException("Unable to read the configuration for realm '" + realmName + "'");
            }
        }
        cacheByDb.put(dbId, deployment);
    }
    return deployment;
}
 

import org.keycloak.adapters.KeycloakDeploymentBuilder; //导入依赖的package包/类
private KeycloakDeployment loadKeycloakDeployment() {
    if(!UNSET.equals(keycloakConfigFile)) {
        return KeycloakDeploymentBuilder.build(loadConfigFile());
    }
    else {
        return KeycloakDeploymentBuilder.build(getAdapterConfig());
    }
}
 

import org.keycloak.adapters.KeycloakDeploymentBuilder; //导入依赖的package包/类
private void init() {
	this.keycloakDeployment = KeycloakDeploymentBuilder.build(new BufferedInputStream(new ByteArrayInputStream(getKeycloakJson().getBytes())));
}
 

import org.keycloak.adapters.KeycloakDeploymentBuilder; //导入依赖的package包/类
@Bean
KeycloakDeployment keycloakDeployment(@Value("${keycloak.configurationFile:WEB-INF/keycloak.json}") Resource keycloakConfigFileResource) throws IOException
{
    return KeycloakDeploymentBuilder.build(keycloakConfigFileResource.getInputStream());
}
 

import org.keycloak.adapters.KeycloakDeploymentBuilder; //导入依赖的package包/类
public void initializeKeycloak() {
    KeycloakDeployment kd = KeycloakDeploymentBuilder.build(adapterConfig);
    deploymentContext = new AdapterDeploymentContext(kd);
}