Hazelcast - 客户端
Hazelcast 客户端是 Hazelcast 成员的轻量级客户端。Hazelcast 成员负责存储数据和分区。它们的作用类似于传统客户端-服务器模型中的服务器。
Hazelcast 客户端仅用于访问集群 Hazelcast 成员存储的数据。他们不负责存储数据,也不拥有存储数据的任何所有权。
客户端有自己的生命周期,不会影响 Hazelcast 成员实例。
我们首先创建 Server.java 并运行它。
import java.util.Map; import com.hazelcast.core.Hazelcast; import com.hazelcast.core.HazelcastInstance; public class Server { public static void main(String... args){ //initialize hazelcast server/instance HazelcastInstance hazelcast = Hazelcast.newHazelcastInstance(); //create a simple map Map<String, String> vehicleOwners = hazelcast.getMap("vehicleOwnerMap"); // add key-value to map vehicleOwners.put("John", "Honda-9235"); // do not shutdown, let the server run //hazelcast.shutdown(); } }
现在,运行上面的类。
java -cp .\target\demo-0.0.1-SNAPSHOT.jar com.example.demo.Server
为了设置客户端,我们还需要添加客户端 jar。
<dependency> <groupId>com.hazelcast</groupId> <artifactId>hazelcast-client</artifactId> <version>3.12.12</version> </dependency>
现在让我们创建 Client.java。请注意,与 Hazelcast 成员类似,客户端也可以通过编程方式或通过 XML 配置(即通过 -Dhazelcast.client.config 或 hazelcast-client.xml)进行配置。
例子
让我们使用默认配置,这意味着我们的客户端将能够连接到本地实例。
import java.util.Map; import com.hazelcast.client.HazelcastClient; import com.hazelcast.core.HazelcastInstance; public class Client { public static void main(String... args){ //initialize hazelcast client HazelcastInstance hzClient = HazelcastClient.newHazelcastClient(); //read from map Map<String, String> vehicleOwners = hzClient.getMap("vehicleOwnerMap"); System.out.println(vehicleOwners.get("John")); System.out.println("Member of cluster: " + hzClient.getCluster().getMembers()); // perform shutdown hzClient.getLifecycleService().shutdown(); } }
现在,运行上面的类。
java -cp .\target\demo-0.0.1-SNAPSHOT.jar com.example.demo.Client
输出
它将产生以下输出 -
Honda-9235 Member of cluster: [Member [localhost]:5701 - a47ec375-3105-42cd-96c7-fc5eb382e1b0]
从输出中可以看出 -
该集群仅包含 1 个来自 Server.java 的成员。
客户端能够访问存储在服务器内的地图。
负载均衡
Hazelcast Client 支持使用各种算法进行负载平衡。负载平衡确保负载在成员之间分担,并且集群中没有任何一个成员过载。默认负载平衡机制设置为循环。可以通过在配置中使用 loadBalancer 标签来更改相同的内容。
我们可以在配置中使用 load-balancer 标签指定负载均衡器的类型。这是选择随机选取节点的策略的示例。
<hazelcast-client xmlns="http://www.hazelcast.com/schema/client-config" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.hazelcast.com/schema/client-config http://www.hazelcast.com/schema/client-config/hazelcastclient-config-4.2.xsd"> <load-balancer type="random"/> </hazelcast-client>
故障转移
在分布式环境中,成员可能会任意失败。为了支持故障转移,建议提供多个成员的地址。如果客户端可以访问任何一个成员,则足以将其发送给其他成员。参数addressList可以在客户端配置中指定。
例如,如果我们使用以下配置 -
<hazelcast-client xmlns="http://www.hazelcast.com/schema/client-config" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.hazelcast.com/schema/client-config http://www.hazelcast.com/schema/client-config/hazelcastclient-config-4.2.xsd"> <address-list>machine1, machine2</address-list> </hazelcast-client>
即使 machine1 出现故障,客户端也可以使用 machine2 来访问集群中的其他成员。