跨站点复制的数据网格指南

站点 master 是 Data Grid 集群中的节点，它负责从备份位置发送和接收请求。

如果节点不是站点 master，则必须将备份请求转发到本地站点 master。只有站点 master 才能向备份位置发送请求。

为获得最佳性能，您应该将所有节点配置为站点 master。这提高了备份请求的速度，因为集群中的每个节点可以直接备份到远程站点，而无需将备份请求转发到站点 master。

当 Data Grid 将数据复制到备份位置时，它会在写入本地缓存前等待操作完成。

如果备份操作失败，您可以控制 Data Grid 如何处理对本地缓存的写入。例如，您可以配置 Data Grid 来尝试中止本地写入，并在备份到远程站点时抛出异常。

同步备份还支持两阶段提交，带有参与最佳事务的缓存。备份的第一个阶段会获得锁定。第二个阶段将提交修改。

当 Data Grid 将数据复制到备份位置时，在写入本地缓存前，它不会等待操作完成。

异步备份操作和写入本地缓存相互独立。如果备份操作失败，对本地缓存的写入操作将继续，且不会发生异常。

同步备份提供了跨站点的数据一致性的最强保证。如果 strategy=sync，当 cache.put （） 调用返回时，您知道值是本地缓存和备份位置的最新状态。

这种一致性的权衡是性能。与异步备份相比，同步备份具有更大的延迟。

另一方面，异步备份不会给客户端请求添加延迟，使其不会影响性能。但是，如果 strategy=async，当 cache.put （） 调用返回时，您不能确保备份位置中的值与本地缓存中的值相同。

如果客户端同时写入同一条目，但在不同的站点上，可能会发生冲突的条目，并带有 Active/Active 站点配置。

例如，当客户端 B 写入 NYC 中的 "k1" 时，客户端 A 写入 LON 中的 "k1"。在这种情况下，"k1" 在 LON 中与 NYC 中的值不同。在进行复制后，不能保证哪个站点存在"k1"的值。

为确保数据一致性，Data Grid 使用向量时钟算法在备份操作过程中检测冲突的条目，如下例所示：

            LON       NYC

k1=(n/a)    0,0       0,0

k1=2        1,0  -->  1,0   k1=2

k1=3        1,1  <--  1,1   k1=3

k1=5        2,1       1,2   k1=8

                 -->  2,1 (conflict)
(conflict)  1,2  <--

向量时钟是与每个写入条目递增的时间戳元数据。在前面的示例中，0 代表 "k1" 上向量时钟的初始值。

客户端将 "k1=2" 置于 LON 中，向量时钟为 1,0，数据网格复制到 NYC。然后，客户端将 "k1=3" 置于 NYC 中，并将向量时钟更新为 1,1，后者的数据网格复制到 LON。

但是，如果客户端同时将"k1=5"置于 LON 中，则客户端会将 "k1=8" 置于 NYC 中，则数据网格检测到冲突条目，因为 "k1" 的向量值在 LON 和 NYC 之间不严格更大或更少。

当找到冲突的条目时，Data Grid 使用 Java compareTo (String anotherString) 方法来比较站点名称。要确定哪个键具有优先级，Data Grid 选择不适合其他的站点名称。名为 AAA 的站点的键优先于名为 AAB 的站点的密钥，以此类推。

在同一示例后，为了解决"k1"的冲突，Data Grid 使用源自 LON 的 "k1" 的值。这会在 Data Grid 解析冲突并复制值后，在 LON 和 NYC 中都生成 "k1=5"。

Data Grid 集群使用 JGroups RELAY2 进行集群内部发现和通信。

<jgroups>
   <stack name="xsite" 

          extends="udp"> 

      <relay.RELAY2 xmlns="urn:org:jgroups" 

                    site="LON" 

                    max_site_masters="1000"/> 

      <remote-sites default-stack="tcp"> 

         <remote-site name="LON"/> 

         <remote-site name="NYC"/>
      </remote-sites>
   </stack>
</jgroups>

<jgroups>
   <stack name="relay-global" extends="tcp"> 

         <MPING stack.combine="REMOVE"/>
         <TCPPING initial_hosts="192.0.2.0[7800]" stack.combine="INSERT_AFTER" stack.position="TCP"/>
    </stack>
   <stack name="xsite" extends="udp">
      <relay.RELAY2 site="LON" xmlns="urn:org:jgroups"
                    max_site_masters="10" 

                    can_become_site_master="true"/>
      <remote-sites default-stack="relay-global">
         <remote-site name="LON"/>
         <remote-site name="NYC"/>
      </remote-sites>
   </stack>
</jgroups>

您还可以引用外部定义的 JGroups 堆栈文件，如下所示：

<stack-file name="relay-global" path="jgroups-relay.xml"/>

在前面的配置 jgroups-relay.xml 中，提供了一个 JGroups 堆栈，例如：

<config xmlns="urn:org:jgroups"
        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xsi:schemaLocation="urn:org:jgroups http://www.jgroups.org/schema/jgroups-4.2.xsd">

    <!-- Use TCP for inter-cluster transport. -->
    <TCP bind_addr="127.0.0.1"
         bind_port="7200"
         port_range="30"

         thread_pool.min_threads="0"
         thread_pool.max_threads="8"
         thread_pool.keep_alive_time="5000"
    />

    <!-- Use TCPPING for inter-cluster discovery. -->
    <TCPPING timeout="3000"
             initial_hosts="127.0.0.1[7200]"
             port_range="3"
             ergonomics="false"/>

    <!-- Provide other JGroups stack configuration as required. -->
</config>

手动使备份位置离线，并使它们重新上线。

如需更多信息和示例，请运行 help site 命令。

将缓存状态传输到远程备份位置。

如需更多信息和示例，请运行 help site 命令。

使用 GET 请求检索所有备份位置的状态。

GET /v2/caches/{cacheName}/x-site/backups/

Data Grid 以 JSON 格式为每个备份位置的状态响应，如下例所示：

{
  "NYC": "online",
  "LON": "offline"
}

使用 GET 请求检索备份位置的状态。

GET /v2/caches/{cacheName}/x-site/backups/{siteName}

Data Grid 以 JSON 格式通过站点中的每个节点状态进行响应，如下例所示：

{
  "NodeA":"offline",
  "NodeB":"online"
}

通过 POST 请求和 ?action=take-offline 参数使备份位置离线。

POST /v2/caches/{cacheName}/x-site/backups/{siteName}?action=take-offline

使用 ?action=bring-online 参数在线启动备份位置。

POST /v2/caches/{cacheName}/x-site/backups/{siteName}?action=bring-online

使用 ?action=start-push-state 参数将缓存状态推送到备份位置。

POST /v2/caches/{cacheName}/x-site/backups/{siteName}?action=start-push-state

使用 ?action=cancel-push-state 参数取消状态传输操作。

POST /v2/caches/{cacheName}/x-site/backups/{siteName}?action=cancel-push-state

使用 ?action=push-state-status 参数检索状态传输操作的状态。

GET /v2/caches/{cacheName}/x-site/backups?action=push-state-status

Data Grid 以 JSON 格式为每个备份位置的状态进行响应，如下例所示：

{
   "NYC":"CANCELED",
   "LON":"OK"
}

使用 ?action=clear-push-state-status 参数发送站点的清除状态传输状态。

POST /v2/caches/{cacheName}/x-site/local?action=clear-push-state-status

如果满足某些条件，站点将处于离线状态。修改离线参数，以控制备份位置自动离线的时间。

如果两个备份位置之间的连接中断，您可以在接收推送的站点上取消状态传输。

从远程站点取消状态传输，并使用 ?action=cancel-receive-state 参数保留本地缓存的当前状态。

POST /v2/caches/{cacheName}/x-site/backups/{siteName}?action=cancel-receive-state

使用 GET 请求，从缓存管理器检索所有备份位置的状态。

GET /rest/v2/cache-managers/{cacheManagerName}/x-site/backups/

Data Grid 以 JSON 格式的状态响应，如下例所示：

{
   "SFO-3":{
      "status":"online"
   },
   "NYC-2":{
      "status":"mixed",
      "online":[
         "CACHE_1"
      ],
      "offline":[
         "CACHE_2"
      ]
   }
}

使用 ?action=take-offline 参数使备份位置离线。

POST /rest/v2/cache-managers/{cacheManagerName}/x-site/backups/{siteName}?action=take-offline

使用 ?action=bring-online 参数在线启动备份位置。

POST /rest/v2/cache-managers/{cacheManagerName}/x-site/backups/{siteName}?action=bring-online

使用 ?action=start-push-state 参数将所有缓存的状态推送到远程站点。

POST /rest/v2/cache-managers/{cacheManagerName}/x-site/backups/{siteName}?action=start-push-state

使用 ?action=cancel-push-state 参数取消持续状态传输操作。

POST /rest/v2/cache-managers/{cacheManagerName}/x-site/backups/{siteName}?action=cancel-push-state

Data Grid 可以注册可以用来收集统计信息并执行管理操作的 JMX MBeans。但是，您必须将统计信息单独启用到 JMX，否则 Data Grid 都为所有统计属性提供 0 值。

<cache-container>
  <jmx enabled="true" /> 

</cache-container>

GlobalConfiguration globalConfig = new GlobalConfigurationBuilder()
  .jmx().enable() 

  .build();

通过 JMX 客户端执行跨站点操作。

有关可用跨站点操作的详情，请查看 Data Grid JMX 组件 文档。

使用 Prometheus 等监控工具来收集数据网格指标。

static_configs:
    - targets: ['localhost:11222']

Data Grid 为跨站点复制提供 JMX MBeans，允许您收集统计信息并执行远程操作。

org.infinispan:type=Cache 组件提供以下 JMX MBeans：

org.infinispan:type=CacheManager 组件包括以下 JMX MBean：

有关 JMX MBeans 以及可用操作和统计的描述的详情，请查看 Data Grid JMX 组件 文档。

查找与跨站点复制相关的日志消息的用户操作。