1С:Шина
25.05.2022
Настройка обмена сообщениями между базой на платформе "1С:Предприятие" и брокером сообщений RabbitMQ с использованием "1С:Шины"
1С:Шина поддерживает обмен данными со сторонними брокерами сообщений:
- Протокол AMQP позволяет обмениваться с RabbitMQ;
- Стандарт JMS позволяет обмениваться с Apache ActiveMQ Artemis.
Далее рассматривается пример настройки обмена данными между базой на платформе "1С:Предприятие" и брокером сообщений RabbitMQ.
В примере выполняется отправка сообщения из RabbitMQ в "1С:Шину", которое поступает в базу, работающую на платформе "1С:Предприятие".
В ходе этого примера вы:
В панели управления брокером сообщений RabbitMQ:
- Создадите очередь сообщений.
В среде разработки "1С:Шины":
- Создадите проект и настроите в нем процесс интеграции;
- Опубликуете проект на сервере и создадите приложение;
- Проверите работоспособность приложения.
На сервере 1С:Шины:
- Заполните параметры для подключения к RabbitMQ;
- Создадите информационную систему;
- Включите её в состав процесса интеграции;
- Запустите процесс интеграции.
Создадите демонстрационную базу 1С:Предприятия:
- Добавите сервис интеграции;
- Загрузите в него информацию о доступных каналах;
- Напишите код обработки полученного сообщения;
- Настроите подключение к серверу "1С:Шины" в режиме "1С:Предприятие".
Проверите обмен сообщениями.
Создание очереди сообщений в RabbitMQ
На этом этапе в брокере сообщений необходимо создать очередь сообщений, через которую мы будем отправлять сообщение.
- Откройте панель управления RabbitMQ;
![](i8105995.files/image001.png?_=00028FB907C6853C-v2)
- Перейдите на вкладку Queues.
- Заполните поле Name, введя название очереди TestChannel1C, и нажмите Add queue.
![](i8105995.files/image002.png?_=0002B860DBD9C3A0-v2)
Создание проекта
На этом этапе вы создадите в среде разработки проект с описанием схемы интеграции и опубликуете его на сервере "1С:Шины", создав приложение.
- Откройте панель управления сервера.
- Нажмите Приложения > + Новое приложение.
- Убедитесь, что выбраны варианты Из проекта и Новый проект.
- Задайте имя проекта — Пример №4 и нажмите Tab. "1С:Шина" заполнит остальные поля и включит режим разработки для создаваемого приложения.
- Выберите тип СУБД (в примере это будет Microsoft SQL Server) и нажмите Создать.
- Новое приложение появится в списке со статусом Создается. Через некоторое время статус приложения изменится на Работает.
- Чтобы открыть проект в среде разработки, нажмите Редактировать... в конце строки.
- "1С:Шина" откроет новую вкладку браузера для среды разработки и запросит пароль. Введите пароль администратора, который вы указали при установке сервера, и нажмите Войти.
"1С:Шина" подготовит рабочую область, построит проект и откроет его в среде разработки.
- Добавьте новый элемент проекта — Процесс интеграции. Для этого в представлении 1C:PROJECT EXPLORER нажмите New > Project Element в контекстном меню подсистемы Основная.
- Задайте имя создаваемого элемента — ОбменСКроликом — и нажмите Ввод.
"1С:Шина" создаст в проекте новый процесс интеграции и откроет редактор для создания его схемы.
- Используя палитру узлов, нарисуйте следующую схему:
![](i8105995.files/image003.png?_=0001754FEE7DBA12-v2)
- Создайте параметры интеграционных процессов:
- ChannelName – название очереди сообщений в RabbitMQ;
- Host – адрес сервера, где располагается RabbitMQ;
- Login – логин для RabbitMQ;
- Password – пароль для RabbitMQ.
- Заполните созданными параметрами настройки Источника RabbitMqИсточник.
![](i8105995.files/image004.png?_=0001E8893E0021CC-v2)
- Чтобы опубликовать проект на сервере, нажмите F9.
- За ходом обновления проекта вы можете наблюдать в левом углу строки состояния среды разработки. Статус updating изменится на статус running. Это говорит о том, что приложение было обновлено и запущено заново.
- Откройте опубликованное приложение, нажав на контекстное меню процесса ОбменСКроликом, и выбрав Open Application.
- После успешной авторизации вы увидите приложение, а в нем список процессов интеграции, существующих в приложении. В примере это будет единственный процесс интеграции ОбменСКроликом.
![](i8105995.files/image005.png?_=0000DBD8AC630B1D-v2)
Настройка приложения в панели управления "1С:Шины"
- Нажмите Инфосистемы > + Добавить систему.
- Задайте код системы — office и наименование — Офис. Нажмите Добавить.
- Теперь для информационной системы нужно получить ключ, который она будет использовать при подключении к серверу 1С:Шины.
- Чтобы получить ключ, нажмите на информационную систему, а затем нажмите Выдать ключ API.
![](i8105995.files/image006.png?_=0000E4E2D0FE5DEB-v2)
- Скопируйте и сохраните идентификатор ключа и секрет клиента. Позднее вы будете использовать его при подключении информационной базы к серверу "1С:Шины".
- Перейдите на вкладку Процессы и нажмите на процесс Основной::ОбменСКроликом.
- Вы увидите схему процесса интеграции и панель, позволяющую задавать свойства узлов этой схемы. В схеме выберите группу ГруппаУчастников, а затем нажмите Состав группы в правом нижнем углу.
- Вы увидите список информационных систем, входящих в группу. Сейчас в группе нет ни одной информационной системы.
- Установите флажок у информационной системы office и нажмите Добавить в группу.
![](i8105995.files/image007.png?_=0000CBC7FC99101E-v2)
- После этого закройте окно Состав группы ГруппаУчастников.
Далее необходимо заполнить параметры у узла RabbitMqИсточник, которые позволят взаимодействовать "1С:Шине" с брокером RabbitMQ.
- На схеме выберите узел RabbitMqИсточник и в правом нижнем углу нажмите Параметры.
- Заполните параметры следующим образом:
- ChannelName – заполните TestChannel1C;
- Host – адрес сервера, где располагается RabbitMQ;
- Login – логин для RabbitMQ;
- Password – пароль для RabbitMQ;
- Нажмите внизу справа Применить, а потом сверху справа Запустить, чтобы запустить процесс интеграции.
Настройка информационной базы "1С:Предприятия"
В информационной базе Офис вы создадите объект конфигурации Сервис интеграции, взаимодействующий с севером "1С:Шины". Под управлением этого сервиса интеграции будет работать один канал. По каналу ОбменСКроликом сообщения от RabbitMQ будут поступать в базу Офис.
В комплект поставки 1С:Шины включены шаблоны конфигураций Офис (office_template.cf) и Магазин (shop_template.cf).
- Создайте пустую информационную базу, используя конфигурацию office_template.
- Запустите конфигуратор информационной базы Офис.
- Добавьте сервис интеграции с именем ОбменСКроликом.
- Нажмите Действия – Загрузить каналы.
- Заполните Адрес сервиса – это адрес вашего приложения из панели управления "1С:Шиной", Пользователь и Пароль – это ключ API, полученный входе создания Инфосистемы.
- Нажмите Получить каналы сервиса, а затем Загрузить.
![](i8105995.files/image008.png?_=0002DE902A7B7374-v2)
После этого перед вами откроется окно обработчика получения сообщения канала Основной_ОбменСКроликом_Канал1СНазначение
- Напишите код обработчика Основной_ОбменСКроликом_Канал1СНазначение:
Копировать в буфер обменаПроцедура Основной_ОбменСКроликом_Канал1СНазначениеОбработкаПолученияСообщения(Сообщение, Отказ)
// Вставить содержимое обработчика.
РазмерСообщения = Сообщение.Параметры.Получить("РазмерСообщения");
Если РазмерСообщения <> Неопределено Тогда
РазмерБуфера = Число(РазмерСообщения);
Иначе
РазмерБуфера = 1024;
КонецЕсли;
Тело = Новый БуферДвоичныхДанных(0);
Буфер = Новый БуферДвоичныхДанных(РазмерБуфера);
Поток = Сообщение.ПолучитьТелоКакПоток();
Пока Истина Цикл
Прочитано = Поток.Прочитать(Буфер, 0, РазмерБуфера);
Если Прочитано > 0 Тогда
Тело = Тело.Соединить(Буфер);
КонецЕсли;
Если Прочитано < РазмерБуфера Тогда
Прервать;
КонецЕсли;
КонецЦикла;
Отчет = ПолучитьСтрокуИзБуфераДвоичныхДанных(Тело);
ПисьмоОбъект = Справочники.ВходящиеПисьма.СоздатьЭлемент();
ПисьмоОбъект.Наименование = "Письмо от Кролика";
ПисьмоОбъект.Дата = ТекущаяДата();
ПисьмоОбъект.ПочтовыйЯщик = "POP3";
ПисьмоОбъект.ВидСодержимого = Перечисления.ВидСодержимогоВходящегоПисьма.HTML;
ПисьмоОбъект.УстановитьСсылкуНового(Справочники.ВходящиеПисьма.ПолучитьСсылку());
ПисьмоОбъект.Текст = "
+ СтрЗаменить(СтрЗаменить(Отчет,
Символ(0),
""), Символы.ПС,
"
") + "
"; НЗ =
РегистрыСведений.СостояниеВходящихПисем.СоздатьНаборЗаписей();
НЗ.Отбор.Письмо.Установить(ПисьмоОбъект.ПолучитьСсылкуНового());
Запись = НЗ.Добавить();
Запись.Письмо = ПисьмоОбъект.ПолучитьСсылкуНового();
Запись.Прочитано =
Ложь; НЗ.Записать();
ПисьмоОбъект.Записать();
КонецПроцедуры
Создайте регламентное задание с именем СервисыИнтеграции.
- Выберите уже имеющийся обработчик СервисыИнтеграцииСервер для регламентного задания.
- Проверьте, что в этом модуле обработчик регламентного задания содержит код:
Копировать в буфер обменаПроцедура ВыполнениеОбработкиСервисовИнтеграции() Экспорт
СервисыИнтеграции.ВыполнитьОбработку();
КонецПроцедуры
- Установите флажки Использование и Предопределенное, чтобы задание в информационной базе создалось автоматически;
- Нажмите Расписание - Открыть и задайте расписание задания — каждый день; каждые 5 секунд.
![](i8105995.files/image009.png?_=00036C49095E5F80-v2)
- Обновите конфигурацию базы данных.
Подключение информационных баз 1С:Предприятия 8 к серверу "1С:Шины"
Вы настроили конфигурации Офис так, что она готова к взаимодействию с использованием сервера "1С:Шины". Непосредственное подключение информационной базы 1С:Предприятия к конкретному серверу выполняется уже в режиме "1С:Предприятие".
- Запустите информационную базу Офис от имени пользователя с административными правами и откройте Функции для технического специалиста:
![](i8105995.files/image010.png?_=000047F9BEC7ACF4-v2)
- Разверните ветку Стандартные и откройте Управление сервисами интеграции:
![](i8105995.files/image011.png?_=0000515197084DB3-v2)
В списке доступных сервисов интеграции вы увидите единственную запись Обмен с кроликом — этот тот самый сервис интеграции, который вы создали в Конфигураторе.
- Чтобы настроить подключение к серверу "1С:Шины"нажмите Редактировать.
- В группе Настройки внешнего сервиса интеграции задайте свойства:
- Имя пользователя — идентификатор ключа, полученный на этапе создания информационной системы Офис в приложении "1С:Шины".
- Пароль пользователя — секрет ключа.
![](i8105995.files/image012.png?_=00011C7485CD5110-v2)
- Нажмите ОК для сохранения настроек.
- Чтобы запустить обмен сообщениями нажмите Установить активность. В результате будет установлен флаг Активность у выбранного сервиса:
![](i8105995.files/image013.png?_=0000293D895FBA77-v2)
На этом создание примера закончено, можно приступать к тестированию обмена сообщениями.
- Откройте панель управления брокером сообщений RabbitMQ и перейдите на вкладку Queues.
- Заполните раздел Publish message и нажмите кнопку Publish message, чтобы отправить сообщение.
![](i8105995.files/image014.png?_=0001874793C2B749-v2)
- Проверьте, что в панели управления "1С:Шины" увеличилось количество входящих и исходящих сообщений.
![](i8105995.files/image015.png?_=0001A9E9EFCA9730-v2)
- Откройте базу Офис и перейдите Предприятие – Входящие письма и увидите сообщение от RabbitMQ
![](i8105995.files/image016.png?_=0001BD70CEC8621A-v2)
![](i8105995.files/image017.png?_=000294951E1A8D74-v2)
На этом пример по отправке сообщения из стороннего брокера сообщений RabbitMQ в базу, работающую на платформе "1С:Предприятие", через "1С:Шину" завершён.