private final ComputeService computeService;

private final int numServers;

/**

* To get a username and API key see

* http://jclouds.apache.org/guides/rackspace/

*

* The first argument (args[0]) must be your username

* The second argument (args[1]) must be your API key

* The optional third argument (args[2]) is the number of Cloud Servers to start

*/

public static void main(String[] args) throws IOException {

getPublishedCloudServers(Arrays.asList(args));

}

public static Set<? extends NodeMetadata> getPublishedCloudServers(List<String> args) throws IOException {

CloudServersPublish cloudServersPublish = new CloudServersPublish(args);

Set<? extends NodeMetadata> nodes = null;

try {

nodes = cloudServersPublish.createServer();

cloudServersPublish.configureAndStartWebserver(nodes);

return nodes;

}

catch (Exception e) {

e.printStackTrace();

}

finally {

cloudServersPublish.close();

}

return nodes;

}

public CloudServersPublish(List<String> args) {

String username = args.get(0);

String apiKey = args.get(1);

numServers = args.size() == 3 ? Integer.valueOf(args.get(2)) : 1;

Iterable<Module> modules = ImmutableSet.<Module> of(new SshjSshClientModule());

// These properties control how often jclouds polls for a status update

Properties overrides = new Properties();

overrides.setProperty(POLL_INITIAL_PERIOD, POLL_PERIOD_TWENTY_SECONDS);

overrides.setProperty(POLL_MAX_PERIOD, POLL_PERIOD_TWENTY_SECONDS);

ComputeServiceContext context = ContextBuilder.newBuilder(PROVIDER)

.credentials(username, apiKey)

.overrides(overrides)

.modules(modules)

.buildView(ComputeServiceContext.class);

computeService = context.getComputeService();

}

private Set<? extends NodeMetadata> createServer() throws RunNodesException, TimeoutException {

System.out.format("Create Server%n");

RegionAndId regionAndId = RegionAndId.fromRegionAndId(REGION, "performance1-1");

Template template = computeService.templateBuilder()

.locationId(REGION)

.osDescriptionMatches(".*Ubuntu 14.04.*")

.hardwareId(regionAndId.slashEncode())

.build();

// This method will continue to poll for the server status and won't return until this server is ACTIVE

// If you want to know what's happening during the polling, enable logging.

// See /jclouds-example/rackspace/src/main/java/org/jclouds/examples/rackspace/Logging.java

Set<? extends NodeMetadata> nodes = computeService.createNodesInGroup(NAME, numServers, template);

for (NodeMetadata nodeMetadata: nodes) {

System.out.format(" %s%n", nodeMetadata);

}

return nodes;

}

private void configureAndStartWebserver(Set<? extends NodeMetadata> nodes) throws TimeoutException {

for (NodeMetadata nodeMetadata: nodes) {

String publicAddress = nodeMetadata.getPublicAddresses().iterator().next();

String privateAddress = nodeMetadata.getPrivateAddresses().iterator().next();

System.out.format(" Configure And Start Webserver%n");

awaitSsh(publicAddress);

String message = new StringBuilder()

.append("Hello from ").append(nodeMetadata.getHostname())

.append(" @ ").append(publicAddress).append("/").append(privateAddress)

.append(" in ").append(nodeMetadata.getLocation().getParent().getId())

.toString();

String script = new ScriptBuilder()

.addStatement(exec("apt-get -q -y update"))

.addStatement(exec("apt-get -q -y install apache2"))

.addStatement(exec("echo '" + message + "' > /var/www/index.html"))

.render(OsFamily.UNIX);

RunScriptOptions options = RunScriptOptions.Builder.blockOnComplete(true);

computeService.runScriptOnNode(nodeMetadata.getId(), script, options);

System.out.format(" Login: ssh %s@%s%n", nodeMetadata.getCredentials().getUser(), publicAddress);

System.out.format(" Password: %s%n", nodeMetadata.getCredentials().getOptionalPassword().get());

System.out.format(" Go to http://%s%n", publicAddress);

}

}

private void awaitSsh(String ip) throws TimeoutException {

SocketOpen socketOpen = computeService.getContext().utils().injector().getInstance(SocketOpen.class);

Predicate<HostAndPort> socketTester = retry(socketOpen, 300, 5, 5, SECONDS);

socketTester.apply(HostAndPort.fromParts(ip, 22));

}

/**

* Always close your service when you're done with it.

*/

public void close() throws IOException {

Closeables.close(computeService.getContext(), true);

}