Atomix源码之业务模型(三)

Properties properties = new Properties();
Address multicastAddress = Address.from("230.0.0.1", 52307);

// 集群列表
Collection<Node> nodes = Arrays.asList(
	Node.builder().withId("1").withAddress(Address.from("localhost:5001")).build(),
	Node.builder().withId("2").withAddress(Address.from("localhost:5002")).build(),
	Node.builder().withId("3").withAddress(Address.from("localhost:5003")).build()
);

Atomix atomixClient1 = Atomix.builder()
	// MemberConfig
	.withClusterId("test")
	.withMemberId("1")
	.withAddress("localhost:5001")
	.withProperties(properties)
	
	// BootstrapDiscoveryConfig
	.withMembershipProvider(!nodes.isEmpty() ? new BootstrapDiscoveryProvider(nodes) : new MulticastDiscoveryProvider())
	
	// ProfileConfig
	.withProfiles(
			ConsensusProfile.builder()
					.withMembers("1", "2", "3")
					.withDataPath(new File(new File(DATA_DIR, "primitive-getters"), "1"))
					.build()
	)
	// MulticastConfig
	.withMulticastEnabled()
	.withMulticastAddress(multicastAddress)
.build();