3

我们有一个使用 Gemfire 和 spring-data-gemfire 的 Java 大型 Web 应用程序。我们在客户端服务器配置中运行 gemfire。

我们有以下问题: 在启动过程中,在 bean 连线阶段,spring-data-gemfire 想连接 gemfire 的定位器。但是,定位器可能尚未启动。然后应用程序将抛出com.gemstone.gemfire.cache.NoSubscriptionServersAvailableException: Primary discovery failed异​​常。

这会导致我们的服务启动过程缓慢而脆弱,这很不方便,尤其是在我们的自动化测试期间。

有什么好的解决方案让客户端等待并定期轮询直到定位器运行?

4

1 回答 1

3

正如Jens D评论的那样,您可以尝试locator-wait-timeGemFire (System) 属性。但是,正如文档指出的那样......

如果在尝试加入分布式系统时定位器不可用,则成员应等待定位器启动的秒数。当您同时启动定位器和对等点时使用此设置。此超时允许对等方在尝试加入分布式系统之前等待定位器完成启动。

这特别是指加入分布式系统/集群的“对等成员”,因此可能对客户端(缓存)没有任何影响。

在这种情况下,我使用了其他使用 Spring 的技术(特别是在涉及客户端/服务器拓扑的集成测试中),以使客户端阻塞等待服务器(或定位器)可用。在我的测试中,测试分叉了一个单独的 GemFire JVM 进程来运行服务器,而测试 VM 充当缓存客户端。

通过将 GemFire 与Spring Session集成,您可以在我最近的开发工作中看到这方面的示例,特别是在httpsession-gemfire-clientserver示例中。

在这里,我使用了一个BeanPostProcessor导致客户端缓存,特别是 PoolFactoryBean/Pool 的阻塞(in postProcessBeforeInitialization(..))阻止池在服务器可用之前完全初始化(也可以应用于定位器)。

等待只是尝试打开到服务器(或定位器)的 Socket 连接以验证连接。

另一种方法是创建一个,在已CountDownLatch注册的 GemFireClientMembershipListener中使用它,并再次将其与 , 组合BeanPostProcessor,仅在该postProcessAfterInitialization(..)方法中。

从技术上讲,这两种方法中只有一种是必要的。虽然,我将它用于测试目的,但它也可以用于实际应用程序,并且在实际应用程序中并不少见。

但是,理想情况下,您首先要启动定位器,因为形成集群取决于它。

希望这可以帮助。

干杯! 约翰

于 2016-03-04T19:50:28.903 回答