2

我们正在使用 Gemfire WAN 拓扑并且在设置网关发送器时遇到问题。

几个假设： - 复制区域 - 串行网关发件人 - 手动启动对于所有网关发件人都是错误的

假设我们有 2 个集群，在每个集群中，我们有 2 个成员（成员 A 和成员 B）

成员 A 的 cache.xml

<gfe:gateway-sender id="gateway-sender-A" parallel="false" remote-distributed-system-id="2" manual-start="false" /> 
<gfe:replicated-region name="data" scope="DISTRIBUTED_NO_ACK"> 
<gfe:replicated-region name="subData" data-policy="REPLICATE" scope="DISTRIBUTED_ACK"> 
<gfe:gateway-sender-ref bean="gateway-sender-A"/> 
</gfe:replicated-region> 
</gfe:replicated-region>

成员 B 的 cache.xml

<gfe:gateway-sender id="gateway-sender-B" parallel="false" remote-distributed-system-id="2" manual-start="false" /> 
<gfe:replicated-region name="data" scope="DISTRIBUTED_NO_ACK"> 
<gfe:replicated-region name="subData" data-policy="REPLICATE" scope="DISTRIBUTED_ACK"> 
<gfe:gateway-sender-ref bean="gateway-sender-B"/> 
</gfe:replicated-region> 
</gfe:replicated-region>

当我们在一个集群中运行启动两个成员时会出现问题。它引发了这个错误：

java.lang.IllegalStateException：无法使用 [gateway-sender-A] 网关发件人 ID 创建区域/数据，因为另一个缓存具有使用 [gateway-sender-B] 网关发件人 ID 定义的相同区域

查看“网关发送者的高可用性”文档，我们的理解是我们可以创建 2 个网关发送者，其中只有一个将在给定的时间点进行发送。最终，我们希望一个缓存区域有 2 个网关发送者（每个成员一个），一个作为主要发送者，另一个作为辅助发送者。

谢谢

4

2 回答 2

0

从Geode 文档中，它说

对于串行 Sender，Queue HA 是通过在多个成员中配置相同的串行 Sender 来实现的。队列在成员之间复制。

因此，如果成员 A 和 B 中的两个网关发送者正在执行相同的工作（除了他们的主要/次要角色），您应该使用“相同”设置。

在网关发送者中，会有一个设法获得特定的分布式锁并成为主要发送者，通常是第一个出现。我没有看到一个属性来强迫一个人成为主要的。

如果您想知道 Geode 是 Gemfire 的开源版本。

于 2016-12-18T08:46:52.757 回答
0

将两个成员的 sender-ids 更改为相同后，我们遇到了另一个问题：

java.lang.IllegalStateException：无法使用手动启动“false”创建网关发件人“some-gateway-sender-id”，因为另一个缓存具有使用手动启动“true”定义的相同网关发件人

看来我们的问题是格式不一致。

成员 A 使用XML格式

<?xml version="1.0"?> <!DOCTYPE cache PUBLIC "-//GemStone Systems, Inc.//GemFire Declarative Caching 8.0//EN" "http://www.gemstone.com/dtd/cache8_0.dtd">

成员 B 使用Spring Gemfire 数据格式

xmlns:gfe="http://www.springframework.org/schema/gemfire" xsi:schemaLocation="http://www.springframework.org/schema/gemfire http://www.springframework.org/schema/gemfire/spring-gemfire.xsd"> <gfe:gateway-sender ...>

我们切换到对两个成员都使用 Spring Gemfire 数据格式，它解决了这两个问题。

TL;DR，如果网关发送者在同一个集群中并且使用一致的缓存 xml 格式，则它们需要具有相同的 id。

于 2016-12-20T18:31:05.500 回答