Gossip protocol is a method for a group of nodes to discover and check the liveliness of a cluster. More information can be found at http://en.wikipedia.org/wiki/Gossip_protocol.
<dependency>
<groupId>net.lvsq</groupId>
<artifactId>jgossip</artifactId>
<version>1.5.0</version>
</dependency>List<SeedMember> seedNodes = new ArrayLis<>();
SeedMember seed = new SeedMember();
seed.setCluster(cluster);
seed.setIpAddress(ipAddress);
seed.setPort(port);
seedNodes.add(seed);GossipService gossipService = new GossipService(cluster,ipAddress, port, id, seedNodes, new GossipSettings(), (member, state) -> {
//Do anything what you want
});gossipService.start();gossipService.shutdown();gossipService.getGossipManager().getDeadMembers();gossipService.getGossipManager().getLiveMembers();- gossipInterval - How often (in milliseconds) to gossip list of members to other node(s). Default is 1000ms
- networkDelay - Network delay in ms. Default is 200ms
- msgService - Which message sync implementation. Default is UDPMsgService.class use UDP protocol to send message, certainly you can extand it.
- deleteThreshold - Delete the deadth node when the sync message is not received more than [deleteThreshold] times. Default is 3
Currently, jgossip has four events
GossipState.UP;
GossipState.DOWN;
GossipState.JOIN;
GossipState.RCV;int gossip_port = 60001;
String cluster = "gossip_cluster";
GossipSettings settings = new GossipSettings();
settings.setGossipInterval(1000);
try {
String myIpAddress = InetAddress.getLocalHost().getHostAddress();
List<SeedMember> seedNodes = new ArrayList<>();
SeedMember seed = new SeedMember();
seed.setCluster(cluster);
seed.setIpAddress(myIpAddress);
seed.setPort(60001);
seedNodes.add(seed);
gossipService = new GossipService(cluster, myIpAddress, gossip_port, null, seedNodes, settings, (member, state, payload) -> {
if (state == GossipState.RCV) {
System.out.println("member:" + member + " state: " + state + " payload: " + payload);
}
if (state == GossipState.DOWN) {
System.out.println("[[[[[[[[[member:" + member + " was down!!! ]]]]]]]]]");
}});
} catch (Exception e) {
e.printStackTrace();
}
gossipService.start();
Run the above code in each application to create a cluster based on the Gossip protocol. You can provide a meaningful GossipListener as the last parameter of GossipService. When state of a node changes, you can capture this change and make some responses.
If you want to send messages to gossip cluster:
gossipService.getGossipManager().publish("Hello World");If a node in cluster received messages, it will trigger the GossipState.RCV event, and handler predefined by GossipListener can consume these messages, such as "Hello World" above.
The type of message is arbitrary, but only if it can be serialized. jgossip will try its best to deliver to every node. By default, messages will stay in memory for a while, and then jgossip will automatically delete them. So the best scenario for this feature is to send some simple messages regularly.
Please pay attention, if you need to send mass messages in a short time, which will consume a lot of resources, this requires you to weigh the actual situation.
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot]")
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent