转载

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 客户端支持使用各种算法进行负载平衡。负载均衡确保s 负载在成员之间共享，并且集群中没有单个成员过载。默认负载平衡机制设置为循环。可以通过使用配置中的 loadBalancer 标记来更改相同的内容。

我们可以使用配置中的负载均衡器标签来指定负载均衡器的类型。这是一个选择随机选取节点的策略的示例。

<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>

即使机器 1 出现故障，客户端也可以使用机器 2 访问集群的其他成员。

正文到此结束