Конвейеры обработки сообщений

Очень часто код обработки сообщений, например, обмена данными располагается в каком-то одном или нескольких общих модулях конфигурации. Как правило такой модуль может насчитывать десятки или сотни процедур и тысячи строк кода. Упрощённо такой код выглядит следующим образом:

Процедура ОбработатьВходящееСообщение(Сообщение)

	Если Условие1 Тогда
		ОбработатьПоАлгоритму1(Сообщение);
	Иначе
		ОбработатьПоАлгоритму2(Сообщение);
	КонецЕсли;

	Если Условие2 Тогда
		ПрерватьОбработкуСообщения();
	КонецЕсли;

	ОбъектДанных = КонвертироватьСообщение(Сообщение);

	Если Условие3 Тогда
		ОбработатьПоАлгоритму3(ОбъектДанных);
	Иначе
		ОбработатьПоАлгоритму4(ОбъектДанных);
	КонецЕсли;

	// И так далее ещё сотни строк кода … =)

КонецПроцедуры

Проблемы такого кода общеизвестны. Суть проблемы - ограничения процедурного программирования и соответствующего образа мышления. Очень часто (почти всегда) это приводит к монолитному, порой невероятно сложному в сопровождении, коду.

1. Использование справочников или регистров сведений для организации и хранения кода обработчиков. Подобные решения часто предполагают возможность редактированием исходного кода обработчиков непосредственно в пользовательском режиме.

2. То же самое, что и в пункте выше, но с использованием внешних обработок.

3. Конвертация данных и правила обмена данными. По сути - вариация первого пункта.

Все подобные решения пытаются так или иначе выполнить декомпозицию сложного кода, структурировать и организовать управление им. Часто используют оператор языка 1С Выполнить.

В контексте предлагаемого подхода будут использоваться следующие понятия:

Сообщение — структура или объект данных, который нужно последовательно обработать при помощи одного или группы взаимно связанных алгоритмов.

Обработчик — обособленный алгоритм обработки сообщения.

Конвейер — группа обработчиков, объединённых между собой для решения задачи обработки сообщений или объектов данных.

Графически конвейер обработки сообщений может выглядеть, например, следующим образом:

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

Пример реализации функции "ВыполнитьОбработку" для транзакционного конвейера:

// Модуль объекта "Обработка" - КОНВЕЙЕР

Функция ВыполнитьОбработку(Сообщение = Неопределено) Экспорт

	Параметры = Новый Структура("Результат", "Поехали!");

	НачатьТранзакцию();
	Попытка		
		// Все обработчики будут выполнены в одной транзакции
		_ПервыйОбработчик.Обработать(Сообщение, Параметры);

		Параметры.Результат = "Приехали...";

		ЗафиксироватьТранзакцию();		
	Исключение		
		ОтменитьТранзакцию();

		Параметры.Результат = ОписаниеОшибки();		
	КонецПопытки;
	
	Возврат Результат;
	
КонецФункции

В случаях, когда конвейер создаётся из внешних обработок, имеет смысл кэшировать уже готовый объект конвейера для его повторного использования. Это положительно скажется на производительности, а также на расходе оперативной памяти приложением.

Следует учитывать контекст выполнения конвейера. Конвейер это экземпляр обработки, размещаемый в оперативной памяти. Доступ к этому объекту может осуществляться одновременно несколькими потоками выполнения, например, фоновыми заданиями. Таким образом все внутренние переменные в модуле объекта (конвейера) рекомендуется использовать в режиме "только для чтения".

Другими словами их нужно инициализировать один раз при создании конвейера. Для этого можно расширить интерфейс конвейера, например, процедурой "Настроить" и вызывать её один раз в коде фабрики конвейеров.

• Разработчики могут захватывать обработчики в хранилище конфигурации независимо друг от друга.
• Конвейеры и обработчики можно структурировать при помощи объекта конфигурации "Подсистема".
• Появляется возможность управлять правами доступа на конвейеры.

• Каждый обработчик можно тестировать отдельно от остальных.
• Легко организовать автоматизированное тестирование конвейеров и их обработчиков.

При помощи подсистемы настроек, реализованной, например, при помощи справочников, как это было упомянуто выше, можно включать и выключать использование тех или иных обработчиков непосредственно в процессе выполнения конвейеров в производственной среде. Таким образом можно оперативно откатить или добавить необходимый код.