KivaKit Clustering 
KivaKit provides built-in support for clustering of microservices using Apache Zookeeper. It supplies a cluster model that is updated as members join and leave the cluster, and an implementation of the SettingsStore interface that stores settings in Zookeeper.
Joining and Leaving a KivaKit Microservice Cluster
To use KivaKit in a cluster, Apache Zookeeper must be running according to the instructions. The default port for Zookeeper is 2181.
The source code for a clustered microservice should be organized like this:
├── deployments │ └── mycluster │ ├── ZookeeperConnection.properties │ └── MyMicroserviceSettings.properties └── MyMicroservice
The ZookeeperConnection.properties file here configures ZookeeperConnection as specified by kivakit-configuration:
class = com.telenav.kivakit.settings.stores.zookeeper.ZookeeperConnection$Settings ports = 127.0.0.1:2181 timeout = 5m create-mode = PERSISTENT
The Microservice subclass, MyMicroservice, is then parameterized on a class that holds information about cluster members. Each cluster member will have its own instance of this object, describing that particular member. An instance of this object is created during initialization by the onNewMember() method:
public class MyMicroservice extends Microservice<MyMicroserviceSettings>
{
[...]
protected MicroserviceClusterMember<MyMicroserviceSettings> onNewMember()
{
return new MicroserviceClusterMember<>(require(MyMicroserviceSettings.class));
}
}
Here, the MicroserviceClusterMember model returned by this method references an instance of the MyMicroserviceSettings, which is created and registered during initialization, typically by a settings file in the deployment like MyMicroserviceSettings:
class = myapp.MyMicroserviceSettings port = 8081 grpcPort = 8082 server = true
Once the MicroserviceClusterMember model object has been created, it is stored in Zookeeper. Other microservice instances in the cluster then receive a notification that a new member has joined through this Microservice method:
protected void onJoin(MicroserviceClusterMember<MyMicroserviceSettings> member)
{
announce("Joined cluster: $", member.identifier());
}
When a member leaves the cluster, its model object will disappear from Zookeeper, and the remaining cluster members will be notified with a call to:
protected void onLeave(MicroserviceClusterMember<MyMicroserviceSettings> member)
{
announce("Left cluster: $", member.identifier());
}
Cluster Elections
A cluster has an elected leader at any given time. Each time a member joins or leaves the cluster, an election is held to determine which member should lead the cluster. The election takes place automatically and the elected member will have the first MicroserviceClusterMember.identifier() value alphabetically. This identifier is currently the DNS name of the host and the process number, but is only guaranteed to be unique and is subject to change in the future.
To determine if a cluster member is the elected leader:
if (member.isLeader())
{
[...]
}
Zookeeper Settings Stores 
Although some applications may require only the settings object provided by MicroserviceClusterMember, others may need to store settings for other components in Zookeeper. This can be accomplished by registering a ZookeeperSettingsStore instance in Microservice.onInitialize():
var store = listenTo(register(new ZookeeperSettingsStore(PERSISTENT)));
Settings can be loaded from this store with
registerSettingsIn(store);
and settings can be saved to this store with:
saveSettingsTo(store, settings);
Because settings are retrieved in KivaKit using a pull model, any changes to settings objects will be automatically available when the desired object is next retrieved with require(Class).
A typical idiom is to read any existing settings from the store, and if the desired settings object is not present, save a default value. Other members will then read that value using the same logic:
registerSettingsIn(store);
if (!hasSettings(MyMicroserviceSettings.class))
{
store.save(new MyMicroserviceSettings());
registerSettingsIn(store);
}
Manually modifying the GSON value in Zookeeper will have the identical effect to saving a value with saveSettingsTo().
Code
The code discussed above is available on GitHub:
The KivaKit Microservice API is available on Maven Central at these coordinates:
<dependency>
<groupId>com.telenav.kivakit</groupId>
<artifactId>kivakit-microservice</artifactId>
<version>1.2.0</version>
</dependency>
The KivaKit Zookeeper settings store API is at these coordinates:
<dependency>
<groupId>com.telenav.kivakit</groupId>
<artifactId>kivakit-settings-stores-zookeeper</artifactId>
<version>1.2.0</version>
</dependency>
|
Published on Java Code Geeks with permission by Jonathan Locke, partner at our JCG program. See the original article here: KivaKit Clustering Opinions expressed by Java Code Geeks contributors are their own. |
