C# 的 TIBCO EMS 故障转移重新连接 (TIBCO.EMS.dll)

发布于 2024-07-07 04:52:48 字数 517 浏览 7 评论 0原文

我们有一个 TIBCO EMS 解决方案，该解决方案在 2-4 个服务器环境中使用内置服务器故障转移。如果 TIBCO 管理将服务从一台 EMS 服务器故障转移到另一台服务器，则连接应在 EMS 服务级别自动转移到新服务器。对于我们使用 EMS 服务的 C# 应用程序，这种情况不会发生 - 我们的用户连接在故障转移后没有转移到新服务器，我们不确定原因。

我们的应用程序仅在启动时连接到 EMS，因此如果 TIBCO 管理员在用户启动我们的应用程序后进行故障转移，则用户需要重新启动应用程序才能重新连接到新服务器（我们的 EMS 连接使用包括所有 4 个生产 EMS 服务器的服务器字符串） - 如果第一次尝试失败，它将移动到字符串中的下一个服务器并重试）。

我正在寻找一种自动化方法，如果检测到连接已断开，它将定期尝试重新连接到 EMS，但我不确定如何最好地做到这一点。

有任何想法吗？我们正在使用 TIBCO.EMS.dll 版本 4.4.2 和 .Net 2.x（SmartClient 应用程序）

任何帮助将不胜感激。

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

陌伤浅笑 2024-07-14 04:52:48

首先，是的，我正在回答我自己的问题。然而，值得注意的是，如果没有 ajmasstrean，我将一事无成。太感谢了！

一：
应适当设置 ConnectionFactory.SetReconnAttemptCount、SetReconnAttemptDelay、SetReconnAttemptTimeout。我认为默认值重试太快（重试之间大约 1/2 秒）。由于网络存储等原因，我们的 EMS 服务器可能需要很长时间才能进行故障转移 - 因此以 1/2 秒的间隔重试 5 次是远远不够的。

二：
我相信启用客户端-服务器和服务器-客户端心跳很重要。无法验证，但如果没有这些，客户端可能无法收到服务器离线或切换到故障转移模式的通知。当然，这是 EMS 的服务器端设置。

三：
您可以通过设置 Tibems.SetExceptionOnFTSwitch(true) 来监视故障转移事件；然后连接异常事件处理程序。在单服务器环境中时，您将看到“连接已终止”消息。但是，如果您处于容错多服务器环境中，您将看到以下内容：“连接已执行容错切换到”。您并不严格需要此通知，但它可能很有用（尤其是在测试中）。

四：
显然 EMS 文档中没有明确说明，连接重新连接在单服务器环境中不起作用。您需要处于多服务器、容错环境中。然而，有一个技巧。您可以将同一服务器放入连接列表中两次 - 我知道这很奇怪，但它可以工作，并且可以使内置的重新连接逻辑正常工作。

一些代码：

private void initEMS()
{
    Tibems.SetExceptionOnFTSwitch(true);
    _ConnectionFactory = new TIBCO.EMS.TopicConnectionFactory(<server>);
    _ConnectionFactory.SetReconnAttemptCount(30);       // 30retries
    _ConnectionFactory.SetReconnAttemptDelay(120000);   // 2minutes
    _ConnectionFactory.SetReconnAttemptTimeout(2000);   // 2seconds
_Connection = _ConnectionFactory.CreateTopicConnectionM(<username>, <password>);
    _Connection.ExceptionHandler += new EMSExceptionHandler(_Connection_ExceptionHandler);
}
private void _Connection_ExceptionHandler(object sender, EMSExceptionEventArgs args)
{
    EMSException e = args.Exception;
    // args.Exception = "Connection has been terminated" -- single server failure
    // args.Exception = "Connection has performed fault-tolerant switch to <server url>" -- fault-tolerant multi-server
    MessageBox.Show(e.ToString());
}

First off, yes, I am answering my own question. Its important to note, however, that without ajmastrean, I would be nowhere. thank you so much!

ONE:
ConnectionFactory.SetReconnAttemptCount, SetReconnAttemptDelay, SetReconnAttemptTimeout should be set appropriately. I think the default values re-try too quickly (on the order of 1/2 second between retries). Our EMS servers can take a long time to failover because of network storage, etc - so 5 retries at 1/2s intervals is nowhere near long enough.

TWO:
I believe its important to enable the client-server and server-client heartbeats. Wasn't able to verify but without those in place, the client might not get the notification that the server is offline or switching in failover mode. This, of course, is a server side setting for EMS.

THREE:
you can watch for failover event by setting Tibems.SetExceptionOnFTSwitch(true); and then wiring up a exception event handler. When in a single-server environment, you will see a "Connection has been terminated" message. However, if you are in a fault-tolerant multi-server environment, you will see this: "Connection has performed fault-tolerant switch to ". You don't strictly need this notification, but it can be useful (especially in testing).

FOUR:
Apparently not clear in the EMS documentation, connection reconnect will NOT work in a single-server environment. You need to be in a multi-server, fault tolerant environment. There is a trick, however. You can put the same server in the connection list twice - strange I know, but it works and it enables the built-in reconnect logic to work.

some code:

private void initEMS()
{
    Tibems.SetExceptionOnFTSwitch(true);
    _ConnectionFactory = new TIBCO.EMS.TopicConnectionFactory(<server>);
    _ConnectionFactory.SetReconnAttemptCount(30);       // 30retries
    _ConnectionFactory.SetReconnAttemptDelay(120000);   // 2minutes
    _ConnectionFactory.SetReconnAttemptTimeout(2000);   // 2seconds
_Connection = _ConnectionFactory.CreateTopicConnectionM(<username>, <password>);
    _Connection.ExceptionHandler += new EMSExceptionHandler(_Connection_ExceptionHandler);
}
private void _Connection_ExceptionHandler(object sender, EMSExceptionEventArgs args)
{
    EMSException e = args.Exception;
    // args.Exception = "Connection has been terminated" -- single server failure
    // args.Exception = "Connection has performed fault-tolerant switch to <server url>" -- fault-tolerant multi-server
    MessageBox.Show(e.ToString());
}

回复收藏 0 原文