commit | 4506fe4a79b6272f3080473cfcba9d100dd8a16e | [log] [tgz] |
---|---|---|
author | Edward Capriolo <edlinuxguru@gmail.com> | Sat Jan 17 18:17:38 2015 -0500 |
committer | Edward Capriolo <edlinuxguru@gmail.com> | Sat Jan 17 18:17:38 2015 -0500 |
tree | 27f12445ab46d512ac41ed8178a007b99d139c79 | |
parent | 6d70b28e82772803aa9bb698b8b619421be80439 [diff] |
Format
Gossip protocol is a method for a group of nodes to discover and check the livelyness of a cluster. More information can be found at http://en.wikipedia.org/wiki/Gossip_protocol.
The original implementation was forked from https://code.google.com/p/java-gossip/. Several bug fixes and changes have already been added.
To gossip you need one or more seed nodes. Seed is just a list of places to initially connect to.
GossipSettings settings = new GossipSettings(); int seedNodes = 3; ArrayList<GossipMember> startupMembers = new ArrayList<GossipMember>(); for (int i = 1; i < seedNodes+1; ++i) { startupMembers.add(new RemoteGossipMember("127.0.0." + i, 2000, i + "")); }
Here we start five gossip processes and check that they discover each other. (Normally these are on different hosts but here we give each process a distinct local ip.
ArrayList<GossipService> clients = new ArrayList<GossipService>(); int clusterMembers = 5; for (int i = 1; i < clusterMembers+1; ++i) { GossipService gossipService = new GossipService("127.0.0." + i, 2000, i + "", LogLevel.DEBUG, startupMembers, settings); clients.add(gossipService); gossipService.start(); }
Later we can check that the nodes discover each other
Thread.sleep(10000); for (int i = 0; i < clusterMembers; ++i) { Assert.assertEquals(4, clients.get(i).get_gossipManager().getMemberList().size()); }
You can get this software from maven central.
<dependency> <groupId>io.teknek</groupId> <artifactId>gossip</artifactId> <version>${pick_the_latest_version}</version> </dependency>