Маршрутизация сообщений
Узел вида МаршрутизаторПоСодержимому предназначен для того, чтобы определять, в какие узлы из тех, что идут непосредственно за этим узлом, должны попасть сообщения. Для этого у узла есть событие ОбработчикОпределенияПолучателей, в котором вы на встроенном языке можете сформировать набор таких узлов. Если этот обработчик отсутствует, то сообщение будет отправлено во все узлы, которые идут сразу после этого узла.
У обработчика есть два параметра. Первый — это Контекст, он описывает, в каком узле происходит вызов. Второй — это Сообщение, которое нужно маршрутизировать. Его нельзя изменить, также как нельзя модифицировать параметры его заголовка.
Если этот обработчик вернет пустую коллекцию узлов, то сообщение никуда не будет доставлено.
Если в возвращаемом массиве будет хотя бы один неправильный получатель, сообщение продублируется в канал недоставленных сообщений, но будет отправлено всем правильным получателям.
Если при выполнении обработчика возникает неперехваченная ошибка, сообщение отправляется в канал недоставленных сообщений.
Отправка всем
Есть следующий процесс интеграции: сообщение генерируется таймером и попадает в узел ОтправкаВсем. Это маршрутизатор по содержимому, из которого сообщение попадает в узлы HTTP и RabbitMQНазначение. ОбработчикОпределенияПолучателей узла ОтправкаВсем оставим пустым.
Так как в узле ОтправкаВсем обработчик события ОбработчикОпределенияПолучателей отсутствует, сообщение будет параллельно и независимо отправлено в узлы HTTP и RabbitMQНазначение.
Такой способ маршрутизации нужен тогда, когда одно и то же сообщение надо отправить сразу по нескольким независимым веткам, чтобы в каждой из них оно обрабатывалось независимо.
В данном случае мы независимо обращаемся к двум разным информационным системам (передаем им сообщение), пытаемся получить от них ответ и обработать его (эта часть схемы здесь не показана).
Выбор получателя
Есть следующий процесс интеграции: Вход — это программный источник, при помощи которого можно отправить сообщение в этот процесс интеграции программно. Например, из обработчика HTTP-сервиса.
Из программного источника сообщение попадает в маршрутизатор по содержимому ОпределениеВерсии. В зависимости от того, какое значение имеет параметр сообщения Формат, маршрутизатор направляет его либо на трансформацию, либо сразу в канал V2.
Обработчик события ОбработчикОпределенияПолучателей выглядит следующим образом:
метод ТрансформироватьИлиНет(Контекст: КонтекстВызоваИнтеграции,
Сообщение: МаршрутизаторПример2.Сообщение): Коллекция<УзелСхемыИнтеграции>
пер СледующийУзел = Сообщение.ПолучитьПараметр("Формат") == 1
? Схема.Узлы.Трансформация
: Схема.Узлы.V2
возврат [СледующийУзел]
;
Если формат равен 1, то сообщение отправляется в узел Трансформация, иначе — в узел V2.
Балансировка нагрузки
Например, существует интенсивный поток сообщений, которые приходят в Канал1СНазначение. Схема процесса выглядит следующим образом:
Но информационная система, которая получает сообщения через этот канал, не способна обрабатывать их достаточно быстро. При этом все входящие сообщения независимы друг от друга, и мы заинтересованы в том, чтобы распараллелить их обработку.
Тогда мы можем направить сообщения примерно равномерно в Канал1СНазначение1 и Канал1СНазначение2, а в информационной системе получать и обрабатывать сообщения из этих каналов параллельно. В таком случае процесс интеграции будет выглядеть следующим образом:
Сообщения приходят и попадают в узел БалансировкаНагрузкиНазначений. В нем в соответствии с генератором случайных чисел выбирается один из двух узлов Канал1СНазначение1 или Канал1СНазначение2, в которые сообщение отправляется.
В результате сообщения попадают в разные каналы и обрабатываются независимо в системах получателей.
Обработчик события ОбработчикОпределенияПолучателей выглядит следующим образом:
метод Балансировка(Контекст: КонтекстВызоваИнтеграции,
Сообщение: МаршрутизаторПример3.Сообщение): Коллекция<УзелСхемыИнтеграции>
пер Генератор = новый СлучайныйГенератор()
пер СледующийУзел = Генератор.СлучайноеЧисло(0, 1) > 0.5
? Схема.Узлы.Канал1СНазначение1
: Схема.Узлы.Канал1СНазначение2
возврат [СледующийУзел]
;