4

我们在 HornetQ 中遇到了以下异常（HornetQ 2.2.5 GA 和 JBoss 4.3.3，带有 InVM 连接器。客户端和服务器都在同一台机器上）：

hornetq-failure-check-thread，检测到连接失败：没有从invm：0接收数据。 错误代码为 3（即 HornetQException.CONNECTION_TIMEDOUT）。

这会导致 RemotingServiceImpl.FailureCheckAndFlushThread 运行，它会多次写入以下日志：

客户端连接失败，正在清理会话 95406085-7b3a-11e2-86d3-005056b14e26 的资源

请注意，在我们的应用程序中，我们重用了 ClientSessions。我们每个连接都有一个 ClientSession 实例（我们打开多个连接，每个客户端一个），上述问题导致其中一个会话被关闭。

阅读这篇文章后：连接超时问题 - 检测到连接失败

我知道我们需要在我们的 ServerLocator 实例上配置以下内容（用于创建创建 ClientSessions 的 ClientSessionFactory）：

ServerLocator locator = HornetQClient.createServerLocatorWithoutHA(connectorConfig);
locator.setClientFailureCheckPeriod(Long.MAX_VALUE);
locator.setConnectionTTL(-1);

这个配置解决了问题，上面的错误没有重现。

我们的问题如下——如果会话将因其他原因被 HornetQ 再次关闭，我们如何创建新会话而不是关闭的会话？

我问这个是因为在我们发现会话关闭之后（并且在我们设置 clientFailure 和 clientTTL 值之前），我们尝试通过调用ClientSessionFactory实例上的createSession(false, true, true)方法来创建一个新会话（我们仅在系统启动时创建该实例一次并从那时起重新启动它）并且失败并出现以下错误：

HornetQException[errorCode=0 message=创建会话失败]

所以我们没有成功创建新会话，唯一的解决方案是重新启动 JBoss。

请注意，我们无法在客户端站点上重新启动我们的应用程序，因此我们需要找到一种方法来创建新会话，以防旧会话因某种原因而关闭。

4

1 回答 1

2

而不是这样做，您可能应该配置重试并使用适当的值，这样您的连接将被重新连接。

但是由于您使用的是 inVM，并且只要您不停止服务器，您就可以使用该配置。但是，如果您打算仅重新启动服务器，则可以使用 reconnectionRetry (-1) 并且会话将被重新连接或重新创建给您。

无论如何，我建议您使用 2.2.5 之后的更新版本。

于 2013-02-20T16:45:16.783 回答