A Hazelcast member discovery strategy for Amazon ECS. While hazelcast-aws provides basic support for Hazelcast clustering on ECS, this strategy makes it possible to cluster multiple nodes (ECS tasks) running on the same container instance in an ECS cluster. It uses a combination of the ECS Agent Introspection, ECS, and EC2 APIs to identify the IP addresses of the container instances that are hosting the tasks in the ECS service the current task belongs to, and the port numbers on those container instances that are mapped to the port Hazelcast listens on inside each container (which may have been dynamically mapped by ECS).
Configure Hazelcast to use the AmazonECSDiscoveryStrategy:
import com.amazonaws.services.ec2.AmazonEC2ClientBuilder;
import com.amazonaws.services.ecs.AmazonECS;
import com.amazonaws.services.ecs.AmazonECSClientBuilder;
import com.commercehub.hazelcast.spi.discovery.AmazonECSDiscoveryException;
import com.commercehub.hazelcast.spi.discovery.AmazonECSDiscoveryStrategyFactory;
import com.commercehub.hazelcast.spi.discovery.AmazonECSDiscoveryUtils;
import com.hazelcast.config.Config;
import com.hazelcast.config.DiscoveryStrategyConfig;
import com.hazelcast.config.JoinConfig;
import com.hazelcast.config.NetworkConfig;
import com.hazelcast.core.Hazelcast;
import com.hazelcast.core.HazelcastInstance;
import com.hazelcast.spi.properties.GroupProperty;
Config hazelcastConfig = new Config();
hazelcastConfig.setProperty(GroupProperty.DISCOVERY_SPI_ENABLED.getName(), String.valueOf(true));
NetworkConfig hazelcastNetworkConfig = hazelcastConfig.getNetworkConfig();
AmazonECS amazonECS = AmazonECSClientBuilder.defaultClient();
AmazonECSDiscoveryUtils amazonECSDiscoveryUtils = new AmazonECSDiscoveryUtils(amazonECS);
try {
hazelcastNetworkConfig.setPublicAddress(
amazonECSDiscoveryUtils.discoverPublicHazelcastAddress(hazelcastNetworkConfig.getPort()));
} catch (AmazonECSDiscoveryException e) {
log.error("Failed to set public address on Hazelcast network config", e);
}
JoinConfig hazelcastJoinConfig = hazelcastNetworkConfig.getJoin();
hazelcastJoinConfig.getMulticastConfig().setEnabled(false);
hazelcastJoinConfig.getTcpIpConfig().setEnabled(false);
hazelcastJoinConfig.getAwsConfig().setEnabled(false);
hazelcastJoinConfig.getDiscoveryConfig().addDiscoveryStrategyConfig(
new DiscoveryStrategyConfig(new AmazonECSDiscoveryStrategyFactory(
amazonECS,
AmazonEC2ClientBuilder.defaultClient(),
hazelcastNetworkConfig.getPort())));
HazelcastInstance hazelcastInstance = Hazelcast.newHazelcastInstance(hazelcastConfig);This library is available under the Apache License, Version 2.0.
Copyright © 2017 Commerce Technologies, LLC