第 1 章 热 Rod Java 客户端

热 Rod 客户端使用智能机制将请求高效地发送到 Data Grid Server 集群。

要接收集群拓扑，客户端在启动时需要至少一个 Hot Rod 服务器的网络位置(IP 地址或主机名)。客户端连接后，Data Grid 服务器会将拓扑传输到客户端。当 Data Grid Server 节点加入或离开集群时，Data Grid 会将更新的拓扑传输到客户端。

例如，考虑一个 put (k,v) 操作。客户端计算键的哈希值，以便它可以找到数据所在的确切的 Data Grid Server 节点。然后，客户端可以直接连接到该节点来执行读写操作。

HASH_DISTRIBUTION_AWARE 智能的好处是，数据网格服务器不需要根据密钥哈希查找值，这使用较少的服务器端资源。另一个好处是数据网格服务器可以更快地响应客户端请求，因为它们不需要创建额外的网络往返。

配置

ConfigurationBuilder builder = new ConfigurationBuilder();
builder.clientIntelligence(ClientIntelligence.BASIC);

infinispan.client.hotrod.client_intelligence=BASIC

热 Rod Java 客户端平衡对数据平面集群的请求，以便读取和写入操作分散到节点上。

使用 BASIC 或 TOPOLOGY_AWARE 智能的客户端为所有请求使用请求平衡。使用 HASH_DISTRIBUTION_AWARE 智能的客户端将请求直接发送到存储所需密钥的节点。如果节点没有响应，客户端会返回请求均衡。

默认平衡策略是循环的，因此 Hot Rod 客户端执行请求平衡，如下例所示，s1、s 2、s3 是 Data Grid 集群中的节点：

// Connect to the Data Grid cluster
RemoteCacheManager cacheManager = new RemoteCacheManager(builder.build());
// Obtain the remote cache
RemoteCache<String, String> cache = cacheManager.getCache("test");

//Hot Rod client sends a request to the "s1" node
cache.put("key1", "aValue");
//Hot Rod client sends a request to the "s2" node
cache.put("key2", "aValue");
//Hot Rod client sends a request to the "s3" node
String value = cache.get("key1");
//Hot Rod client sends the next request to the "s1" node again
cache.remove("key2");

ConfigurationBuilder builder = new ConfigurationBuilder();
builder.addServer()
         .host("127.0.0.1")
         .port(11222)
         .balancingStrategy(new MyCustomBalancingStrategy());

infinispan.client.hotrod.request_balancing_strategy=my.package.MyCustomBalancingStrategy

当 Data Grid 集群拓扑更改时，热 Rod 客户端可以自动进行故障转移。例如，具有拓扑感知的 Hot Rod 客户端可以检测一个或多个数据网格服务器何时失败。

除了集群数据网格服务器之间故障转移外，Hot Rod 客户端还可在 Data Grid 集群之间进行故障转移。

例如，您有一个 Data Grid 集群在 New York (NYC)中运行，另一个集群在伦敦(LON)中运行。向 NYC 发送请求的客户端检测到没有可用的节点，以便它们在 LON 中切换到集群。然后，客户端会维护到 LON 的连接，直到您手动切换集群或故障转移再次发生。

虽然 Hot Rod 客户端可以故障转移，但您应该使用事务缓存来确保操作不会部分完成，并在不同的节点上保留冲突的条目。