import org.cloudfoundry.reactor.uaa.ReactorUaaClient; //导入依赖的package包/类
private CloudFoundryOperations doCreateOperations(CloudFoundryClient cloudFoundryClient,
														 ConnectionContext connectionContext,
														 TokenProvider tokenProvider,
														 String org,
														 String space) {
	ReactorDopplerClient dopplerClient = ReactorDopplerClient.builder()
			.connectionContext(connectionContext)
			.tokenProvider(tokenProvider)
			.build();

	ReactorUaaClient uaaClient = ReactorUaaClient.builder()
			.connectionContext(connectionContext)
			.tokenProvider(tokenProvider)
			.build();

	return DefaultCloudFoundryOperations.builder()
			.cloudFoundryClient(cloudFoundryClient)
			.dopplerClient(dopplerClient)
			.uaaClient(uaaClient)
			.organization(org)
			.space(space)
			.build();
}
 

import org.cloudfoundry.reactor.uaa.ReactorUaaClient; //导入依赖的package包/类
@Before
public void setup()
{
	String host = System.getenv("CF_HOST");
	String username = System.getenv("CF_USERNAME");
	String password = System.getenv("CF_PASSWORD");

	if(host == null || username == null || password == null)
	{
		throw new RuntimeException("CF_HOST, CF_USERNAME and CF_PASSWORD must be set");
	}

	ConnectionContext connectionContext = DefaultConnectionContext.builder().apiHost(host).skipSslValidation(true).build();
	TokenProvider tokenProvider = PasswordGrantTokenProvider.builder().username(username).password(password).build();

	ReactorUaaClient uaaClient = ReactorUaaClient.builder().connectionContext(connectionContext).tokenProvider(tokenProvider).build();
	uaa = new ReactorUaaClientFacade(uaaClient);
}
 

import org.cloudfoundry.reactor.uaa.ReactorUaaClient; //导入依赖的package包/类
@Bean
public CloudFoundryOperations cloudFoundryOperations(CloudFoundryClient cloudFoundryClient,
													 ConnectionContext connectionContext,
													 TokenProvider tokenProvider,
													 CloudFoundryConnectionProperties properties) {
	ReactorDopplerClient.builder()
		.connectionContext(connectionContext)
		.tokenProvider(tokenProvider)
		.build();

	ReactorUaaClient.builder()
		.connectionContext(connectionContext)
		.tokenProvider(tokenProvider)
		.build();

	return DefaultCloudFoundryOperations.builder()
		.cloudFoundryClient(cloudFoundryClient)
		.organization(properties.getOrg())
		.space(properties.getSpace())
		.build();
}
 

import org.cloudfoundry.reactor.uaa.ReactorUaaClient; //导入依赖的package包/类
@Test
public void producesAllBeans() {

	Assume.assumeTrue(configExists());

	ApplicationContext ctx = new SpringApplicationBuilder()
			.sources(MyConfig.class)
			.properties(defaultConfig())
			.run();

	Class[] tags = {ReactorCloudFoundryClient.class, DefaultCloudFoundryOperations.class,
			DefaultConnectionContext.class, DopplerClient.class, RoutingClient.class, PasswordGrantTokenProvider.class,
			ReactorUaaClient.class};
	for (Class<?> c : tags) {
		Assertions.assertThat(ctx.getBean(c)).isNotNull();
	}
}
 

import org.cloudfoundry.reactor.uaa.ReactorUaaClient; //导入依赖的package包/类
@Bean
ReactorUaaClient uaaClient(ConnectionContext ctx, TokenProvider tokenProvider) {
    return ReactorUaaClient
            .builder()
            .connectionContext(ctx)
            .tokenProvider(tokenProvider)
            .build();
}
 

import org.cloudfoundry.reactor.uaa.ReactorUaaClient; //导入依赖的package包/类
@Bean
public DefaultCloudFoundryOperations cloudFoundryOperations(
        CloudFoundryClient cfc,
        ReactorDopplerClient dopplerClient,
        ReactorUaaClient uaaClient,
        @Value("${cf.org}") String organization,
        @Value("${cf.space}") String space) {
    return DefaultCloudFoundryOperations.builder()
            .cloudFoundryClient(cfc)
            .dopplerClient(dopplerClient)
            .uaaClient(uaaClient)
            .organization(organization)
            .space(space)
            .build();
}
 

import org.cloudfoundry.reactor.uaa.ReactorUaaClient; //导入依赖的package包/类
@Bean
UaaClient uaaClient(ConnectionContext connectionContext, TokenProvider tokenProvider) {
	return ReactorUaaClient.builder()
			.connectionContext(connectionContext)
			.tokenProvider(tokenProvider)
			.build();
}
 

import org.cloudfoundry.reactor.uaa.ReactorUaaClient; //导入依赖的package包/类
protected CloudFoundryOperations getV2Operations() throws CoreException {

		if (this.v2Operations == null) {
			try {

				boolean keepAlive = keepAlive();
				DefaultConnectionContext connection = DefaultConnectionContext.builder()
						.proxyConfiguration(Optional.ofNullable(getProxyConfiguration())).apiHost(getHost())
						// SSL handshake timeout may need to be increased, for
						// log streaming
						.sslHandshakeTimeout(Duration.ofSeconds(cloudServer.getSslHandshakeTimeout()))
						.keepAlive(keepAlive).skipSslValidation(skipSsl()).build();

				PasswordGrantTokenProvider tokenProvider = PasswordGrantTokenProvider.builder()
						.username(credentials.getUser()).password(credentials.getPassword()).build();

				ReactorUaaClient uaaClient = ReactorUaaClient.builder().connectionContext(connection)
						.tokenProvider(tokenProvider).build();

				ReactorDopplerClient dopplerClient = ReactorDopplerClient.builder().connectionContext(connection)
						.tokenProvider(tokenProvider).build();

				this.v2Client = ReactorCloudFoundryClient.builder().connectionContext(connection)
						.tokenProvider(tokenProvider).build();

				this.v2Operations = DefaultCloudFoundryOperations.builder().cloudFoundryClient(v2Client)
						.dopplerClient(dopplerClient).uaaClient(uaaClient).organization(orgName).space(spaceName)
						.build();

			} catch (Throwable e) {
				throw CloudErrorUtil.toCoreException(e);
			}
		}
		return this.v2Operations;
	}
 

import org.cloudfoundry.reactor.uaa.ReactorUaaClient; //导入依赖的package包/类
@Bean
@Lazy
@ConditionalOnMissingBean
public ReactorUaaClient uaaClient(ConnectionContext connectionContext, TokenProvider tokenProvider) {
	return ReactorUaaClient.builder()
			.connectionContext(connectionContext)
			.tokenProvider(tokenProvider)
			.build();
}