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 .	arget\demo-0.0.1-SNAPSHOT.jar com.example.demo.Server

For setting up a client, we also need to add client 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 .	arget\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 来访问集群的其他成员。