Что такое 1С:Шина и как устроен асинхронный обмен данными в 1С:Предприятии?

Введение: Что такое 1С:Шина и зачем она появилась?

В мире современных корпоративных информационных систем ручной или файловый обмен данными давно стал пережитком прошлого. Ранее разработчикам на платформе 1С:Предприятие приходилось самостоятельно конструировать «велосипеды» для связывания баз данных: использовать FTP-серверы, обмениваться XML-файлами через электронную почту или интегрировать сторонние брокеры сообщений, такие как RabbitMQ и Apache Kafka. Каждый такой проект требовал написания сотен строк кода и постоянной поддержки со стороны системных администраторов.

С выходом нового решения «1С:Шина» экосистема получила собственный промышленный класс систем интеграции уровня предприятия (Enterprise Service Bus — ESB). Мы подробно разберем, что представляет собой этот продукт, как он взаимодействует с классическими механизмами платформы и решает ли он проблемы, озвученные разработчиками на форумах.

Архитектурные основы: На каких технологиях построена 1С:Шина?

Проанализируем технологический стек нового решения. Вопреки распространенному мнению, что «1С:Шина» — это просто очередная конфигурация, написанная на встроенном языке 1С, архитектура продукта принципиально иная:

Технология 1С:Предприятие.Элемент: Продукт полностью спроектирован на базе новой перспективной технологии «1С:Предприятие.Элемент». Это обеспечивает невероятную легкость работы веб-интерфейсов и высокую масштабируемость системы.
Новый декларативно-скриптовый язык: Написание сценариев трансформации и маршрутизации сообщений происходит не на классическом языке 1С, а на встроенном языке технологии «Элемент». Этот язык ориентирован на асинхронное выполнение и быструю обработку структурированных типов данных.
Собственная среда разработки (IDE): Для настройки процессов интеграции используется отдельная визуальная среда. В ней разработчик может собирать маршруты доставки данных в виде графических блок-схем, перетаскивая узлы («Каналы», «Трансляторы», «Группы») мышкой и настраивая их свойства.
Независимый кроссплатформенный сервер: Сервер шины устанавливается как отдельная служба. Он может работать как под управлением ОС Windows, так и на различных дистрибутивах Linux (Astra Linux, Ubuntu, РЕД ОС, Alpine), что критически важно в рамках импортозамещения.

Как устроен процесс передачи сообщений: Разбираемся по шагам

Рассмотрим детально, как сообщение проходит путь от базы-источника до базы-получателя через «1С:Шину». Выясним причину, почему этот механизм называют гарантированной доставкой.

Формирование сообщения в источнике: В информационной базе 1С:Предприятие (например, 1С:ERP) при проведении документа срабатывает событие. Платформа формирует сообщение обмена.
Буферизация в локальной ИБ: Перед отправкой сообщение сохраняется в специальной служебной таблице ИБ источника. Платформа пытается отправить его на сервер шины. Если сервер шины в этот момент недоступен (упал канал связи, проводятся техработы), сообщение будет храниться в базе-источнике неограниченно долго (или пока не истечет его срок годности).
Подтверждение получения шиной: Как только связь восстанавливается, платформа передает сообщение в «1С:Шину». Сервер шины сохраняет сообщение в своей внутренней базе данных и отправляет ИБ-источнику подтверждение: «Сообщение принято». Только после этого сообщение удаляется из локального буфера ИБ-источника.
Маршрутизация и трансформация: Сервер шины анализирует заголовок сообщения, при необходимости преобразует его формат (например, из XML в JSON) с помощью написанных скриптов-трансляторов и помещает в нужную очередь для получателей.
Доставка получателю: Шина пытается доставить сообщение получателю. Если получатель временно отключен, шина хранит данные у себя. Как только база-получатель подтверждает успешную запись сообщения в свою буферную таблицу, шина удаляет сообщение из своей очереди.

Взаимодействие с планами обмена: Замена или партнерство?

В процессе обсуждения на форумах часто возникает вопрос: заменяет ли «1С:Шина» классический механизм планов обмена с их таблицами регистрации изменений? Разберем эту ситуацию подробно.

План обмена и Интеграционная шина выполняют абсолютно разные, но взаимодополняющие задачи:

План обмена отвечает за определение состава измененных данных. Он фиксирует факт того, что объект (например, карточка Контрагента или Номенклатуры) изменился в транзакции базы данных, и его нужно отправить. Он обеспечивает выборку данных.
«1С:Шина» берет на себя всю транспортную логику и гарантированную доставку. Раньше разработчику приходилось писать регламентные задания, которые выбирали зарегистрированные изменения, упаковывали их в файлы, отправляли по FTP, следили за успешностью отправки и снимали регистрацию. Теперь всю эту рутину берет на себя платформа и шина.

Таким образом, мы не отказываемся от планов обмена. Мы используем их для фиксации изменений, но саму отправку делегируем встроенному в платформу объекту СервисИнтеграции, который передает пакеты напрямую в шину.

Пример реализации отправки сообщений

Давайте посмотрим на практический пример того, как программист может программно отправить сообщение в настроенный канал интеграции. Для этого в платформу версии 8.3.17 был добавлен объект СервисыИнтеграции.

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


// Инициализируем соединение с сервисом интеграции
ИмяСервиса = "УправлениеПродажами";
Сервис = СервисыИнтеграции[ИмяСервиса];

// Создаем новое интеграционное сообщение
НовоеСообщение = Сервис.СоздатьСообщение();

// Заполняем тело сообщения (например, структура в формате JSON)
ДанныеДляОтправки = Новый Структура;
ДанныеДляОтправки.Вставить("КодПартнера", "П0000432");
ДанныеДляОтправки.Вставить("НовоеНаименование", "ООО Вектор-С");

ЗаписьJSON = Новый ЗаписьJSON;
ЗаписьJSON.УстановитьСтроку();
ЗаписатьJSON(ЗаписьJSON, ДанныеДляОтправки);
СтрокаJSON = ЗаписьJSON.Закрыть();

НовоеСообщение.Тело.УстановитьСтроку(СтрокаJSON);

// Добавляем пользовательские параметры (заголовки) для маршрутизации в шине
НовоеСообщение.Параметры.Вставить("ТипСобытия", "ОбновлениеПартнера");
НовоеСообщение.Параметры.Вставить("ВерсияФормата", "1.0");

// Отправляем сообщение в конкретный канал сервиса интеграции
Сервис.Отправить("КаналПартнеры", НовоеСообщение);

В данном примере сообщение гарантированно попадет в локальный буфер платформы и при первой возможности будет отправлено в «1С:Шину». Обратите внимание, что мы можем задавать любые произвольные параметры сообщения, которые впоследствии помогут шине правильно направить сообщение получателям.

Обработка входящих сообщений на стороне получателя

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

В конфигурации-получателе для соответствующего СервисаИнтеграции настраивается обработчик ожидания или метод обработки. Посмотрим на шаблон такого кода:


// Данная процедура вызывается платформой автоматически при поступлении сообщения в канал
Процедура ПриПолученииСообщения(Сообщение, Отправитель) Экспорт
    
    // Получаем тип события из параметров заголовка
    ТипСобытия = "";
    Если Сообщение.Параметры.Свойство("ТипСобытия", ТипСобытия) Тогда
        
        Если ТипСобытия = "ОбновлениеПартнера" Тогда
            СтрокаДанных = Сообщение.Тело.ПолучитьСтроку();
            
            // Десериализуем и обрабатываем данные
            ЧтениеJSON = Новый ЧтениеJSON;
            ЧтениеJSON.УстановитьСтроку(СтрокаДанных);
            ДанныеПартнера = ПрочитатьJSON(ЧтениеJSON);
            ЧтениеJSON.Закрыть();
            
            // Вызываем процедуру обновления данных в базе
            ОбновитьДанныеКонтрагентаВБазе(ДанныеПартнера);
            
        КонецЕсли;
        
    КонецЕсли;
    
КонецПроцедуры

Этот подход позволяет добиться мгновенной (on-line) синхронизации баз данных с минимальной нагрузкой на СУБД. Нам не нужно постоянно опрашивать таблицы базы данных — платформа сама разбудит фоновый процесс при получении сообщения.

Интеграция с внешними ИТ-системами и поддержка СУБД

Современный ИТ-ландшафт предприятия редко ограничивается только программными продуктами 1С. Важным преимуществом «1С:Шины» является кросс-системная интеграция. Рассмотрим, какие протоколы и интерфейсы поддерживает сервер интеграции:

Apache Kafka: Поддерживается интеграция с распределенными очередями Kafka, что позволяет обмениваться потоковыми данными с внешними веб-платформами и микросервисами.
Подключение к базам данных (JDBC): «1С:Шина» умеет напрямую считывать и записывать данные во внешние СУБД (PostgreSQL, MS SQL, Oracle) через стандартные JDBC-драйверы. Это позволяет легко интегрировать легаси-системы без реализации веб-сервисов.
Интеграция с брокерами сообщений (JMS/AMQP): Полная совместимость со сторонними брокерами корпоративного класса (ActiveMQ, RabbitMQ), что упрощает встраивание шины в существующую ИТ-инфраструктуру крупных предприятий.

Сравнение «1С:Шины» с классическими брокерами (RabbitMQ, Apache Kafka)

Выясним преимущества и недостатки использования специализированного решения от 1С по сравнению с популярными OpenSource-продуктами:

Преимущества «1С:Шины»:

Глубокая нативная интеграция: Поддержка транзакционности на уровне платформы 1С:Предприятие. Сообщение гарантированно будет отправлено в шину только в том случае, если транзакция записи объекта в базе 1С завершилась успешно.
Визуальная разработка: Встроенный графический редактор схем позволяет быстро настраивать сложные цепочки прохождения данных (Splitter, Content-Based Router, Translator) без написания сложных внешних сервисов.
Единая экосистема: Администрирование, мониторинг и программирование осуществляются в рамках концепции продуктов 1С, что снижает порог входа для разработчиков 1С.

Недостатки и особенности:

Лицензирование: В отличие от бесплатного RabbitMQ, «1С:Шина» требует приобретения коммерческих лицензий, стоимость которых зависит от количества пользователей в интегрируемых системах 1С.
Необходимость изучения новых технологий: Разработчикам приходится осваивать среду разработки «1С:Предприятие.Элемент» и специфику синтаксиса нового языка.

Выводы и рекомендации

Подводя итоги нашего детального обзора, можно с уверенностью сказать, что появление «1С:Шины» — это долгожданный качественный скачок в развитии интеграционных технологий фирмы 1С. Это решение идеально подходит для средних и крупных предприятий с разветвленной ИТ-архитектурой, где эксплуатируются десятки баз данных 1С и сторонних информационных систем.

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

← На главную