Прежде всего, да, я отвечаю на свой вопрос. Однако важно отметить, что без ajmastrean я был бы никуда. большое спасибо!
ONE:
ConnectionFactory.SetReconnAttemptCount, SetReconnAttemptDelay, SetReconnAttemptTimeout должны быть установлены соответствующим образом. Я думаю, что значения по умолчанию повторяются слишком быстро (порядка 1/2 секунды между повторными попытками). Наши серверы EMS могут долго переходить на аварийное переключение из-за сетевого хранилища и т. Д., Поэтому 5 повторных попыток с интервалом в 1/2 секунды еще далеко не достаточно.
TWO:
Я считаю, что важно активировать тактовые импульсы клиент-сервер и сервер-клиент. Не удалось проверить, но без них клиент может не получить уведомление о том, что сервер находится в автономном режиме или переключается в режим отработки отказа. Это, конечно, настройка сервера для 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());
}