Повторное подключение при отказе TIBCO EMS для C # (TIBCO.EMS.dll)

Этот пост должен суммировать мои текущие комментарии и более подробно объяснить мой подход ...

Типы TIBCO «ConnectionFactory» и «Connection» - это тяжелые, ориентированные на потоки типы. TIBCO рекомендует использовать одну фабрику соединений (для каждого сервера, настроенную на заводе) и одно соединение для каждой фабрики.

Сервер также кажется ответственным за аварийное переключение и повторное подключение на месте, поэтому давайте подтвердим, что он выполняет свою работу, а затем положимся на эту функцию.

Создание решения на стороне клиента будет немного сложнее, чем устранение проблемы с настройкой сервера или клиента. Все сеансы, которые вы создали из-за неудачного подключения, необходимо воссоздать (не говоря уже о производителях, потребителях и местах назначения). Ни для одного из этих типов нет методов «повторного подключения» или «обновления». Сеансы также не поддерживают ссылку на свое родительское соединение.

Вам придется управлять поиском объектов соединения / сеанса и сходить с ума, повторно инициализируя всех! или реализовать какой-то обработчик событий сбоя сеанса, который может получить новое соединение и переподключить их.

Итак, пока давайте углубимся и посмотрим, настроен ли клиент для получения уведомлений о переключении при отказе (руководство пользователя tib ems, стр. 292). И убедитесь, что возникшее исключение перехвачено, содержит URL-адрес отработки отказа и правильно обрабатывается.

Во-первых, да, я отвечаю на свой вопрос. Однако важно отметить, что без аджмастриана я был бы никуда. большое спасибо!

ОДИН: ConnectionFactory.SetReconnAttemptCount, SetReconnAttemptDelay, SetReconnAttemptTimeout должны быть установлены соответствующим образом. Я думаю, что значения по умолчанию повторяются слишком быстро (порядка 1/2 секунды между повторными попытками). Нашим серверам EMS может потребоваться много времени для переключения при отказе из-за сетевого хранилища и т. Д., Поэтому 5 попыток с интервалом в 1/2 секунды - это далеко не достаточно.

ВТОРОЙ: Я считаю важным включить тактовые импульсы клиент-сервер и сервер-клиент. Не удалось проверить, но без них клиент может не получить уведомление о том, что сервер отключен или переключается в режим аварийного переключения. Это, конечно, настройка 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());
}

Клиентские приложения могут получать уведомление об отказе, задав системное свойство tibco.tibjms.ft.switch.exception

Возможно, это нужно библиотеке для работы?