首先,是的,我正在回答我自己的问题。然而,重要的是要注意,如果没有 ajmastrean,我将无处可去。太感谢了!
一: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());
}