Обмен данными между базами 1С посредством передачи сообщений

Разбор примера демо-реализации группового чата с использованием стороннего сервиса.
Цель, — знакомство с некоторыми функциями платформы DESP. Вопросы эффективности и безопасности не затрагиваются.
Исполняемый код серверной части платформы не представлен в данной публикации, но выполняется в «облаке», в демо-режиме.

Категория: Разработки 1С

Подробнее

Описание
Подробнее

Описание

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

Реализован групповой "чат", имеющий минимальный функционал:

— просмотр последних сообщений и имена их авторов;

— отправку новых сообщений;

Для демонстрации результатов можно запустить несколько экземпляров ИБ одновременно, наблюдая передачу данных между ними.

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

Реализация

Демонстрационная база содержит основную конфигурацию, собственно где и реализована общая форма "чат", в которой описана вся его специфичная логика, взаимодействуя с библиотечными функции платформы DESP, для отправки и получения сообщений.

Платформа DESP состоит из ядра сервиса (brake), написано на Go. Реализует такие механизмы как:

— Получение, хранение, отдачу сообщений посредством вызова RPC-методов ядра платформы (JSON-RPC 2.0);

— Вызов удаленных процедур (RPC), реализованных на JavaScript, расположенных на сервере;

— Вызов удаленных процедур (RPC), реализованных в "подключенных" к DESP базах 1С (на языке 1С, при этом публиковать http- или web-сервисы не требуется);

— Доступ к хранилищу ключ-значение;

— Контроль доступа к RPC и очередям сообщений, посредством ключа авторизации;

— Параметризация "длинны" очереди сообщений (по двум характеристикам: максимальный размер в байтах и максимальная длительность хранения сообщения, задается на стороне конфигурации сервера desp);

— Регистрация измененных объектов в очереди для дальнейшей сериализации и отправки в одну из очередей, правила "конвертации" описываются программным кодом ("алгоритмом", программный код 1С);

— Чтение очереди и десериализация объектов по правилам ("алгоритмам", программный код 1С);

— Минимальный мониторинг состояния очередей, рабочих потоков 1С исполнения PRC-методов;

(в этой статье разбираются только возможности из первого пункта, и косвенно задействованы механизмы, перечисленные в пунктах, выделенные жирным шрифтом)

Та часть подсистемы DESP, которая реализуется на стороне базы 1С представлена:

"Библиотечным" расширением "DESP" (минимальная требуемая версия платформы 1С — 8.3.17, не предполагает изменений при реализации бизнес-задач), содержит процедуры/функции для простого использования основных возможностей платформы;
Дополнительным расширением "DESP_config", содержащим:
1. Параметры подключения к серверу brake (ядро платформы DESP): адрес, порт, ключ авторизации;
2. Программный код и конфигурацию реализованных методов RPC в базе 1С;
3. Программный код для интерпретации сообщений чтения сообщений.

Чат

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

Логика взаимодействия:

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

&НаКлиенте
Перем idКрайнегоСообщения;

&НаКлиенте
Процедура ПриОткрытии(Отказ)
    ГСЧ = Новый ГенераторСлучайныхЧисел();
    МоеИмя = "Аноним_"+ГСЧ.СлучайноеЧисло(1,999);
    ОбновитьIdПервогоСообщенияДляЧтения();
    ПрочитатьНовыеСообщения();
    ПодключитьОбработчикОжидания("ПрочитатьНовыеСообщения", 1, Ложь);
КонецПроцедуры

Код процедуры получения номера сообщения, с которого нужно будет начать отображение на форму:

&НаКлиенте
Процедура ОбновитьIdПервогоСообщенияДляЧтения()
	idКрайнегоСообщения = 0;
	П = Новый Структура();
	П.Вставить("topic", "chat");
	П.Вставить("limit", 1);
	Результат = desp_УдаленныйВызовПроцедур.ВызватьМетод("brake_pull_messages", П);
	Если Результат<>Неопределено Тогда
		Для Каждого ЭлементРезультата Из Результат Цикл
			idКрайнегоСообщения = ЭлементРезультата.id;
		КонецЦикла;
	КонецЕсли;
	idКрайнегоСообщения = Макс(1, idКрайнегоСообщения-10);
КонецПроцедуры

Далее, код процедуры вычитывания и отображения новых сообщений, за один раз не более 50 штук:

&НаКлиенте
Процедура ПрочитатьНовыеСообщения()
	Перем НоваяСтрокаТаблицы;
	П = Новый Структура();
	П.Вставить("topic", "chat");
	П.Вставить("off", idКрайнегоСообщения);
	П.Вставить("limit", 50);
	Результат = desp_УдаленныйВызовПроцедур.ВызватьМетод("brake_pull_messages", П);
	Если Результат<>Неопределено Тогда
		Для Каждого ЭлементРезультата Из Результат Цикл
			Попытка
				ЧтениеJSON = Новый ЧтениеJSON();
				ЧтениеJSON.УстановитьСтроку(ЭлементРезультата.payload);
				РезультатВыполнения = ПрочитатьJSON(ЧтениеJSON);
				Если Переписка.Количество()>50 Тогда
					Переписка.Удалить(0);
				КонецЕсли;
				НоваяСтрокаТаблицы = Переписка.Добавить();
				НоваяСтрокаТаблицы.Автор = РезультатВыполнения.user;
				НоваяСтрокаТаблицы.Сообщение = РезультатВыполнения.message;
				НоваяСтрокаТаблицы.МоеСообщение = Истина;
			Исключение
			КонецПопытки;
			idКрайнегоСообщения = ЭлементРезультата.id + 1;
		КонецЦикла;
		Элементы.Переписка.ТекущаяСтрока = Переписка.Индекс(НоваяСтрокаТаблицы);
	КонецЕсли;
КонецПроцедуры

И в заключении, код процедуры отправки новых сообщений:

&НаКлиенте
Процедура КомандаОтправить(Команда)
	СтруктураСДанными = Новый Структура();
	СтруктураСДанными.Вставить("user", МоеИмя);
	СтруктураСДанными.Вставить("message", Сообщение);
	ЗаписьJSON = Новый ЗаписьJSON();
	ЗаписьJSON.УстановитьСтроку();
	ЗаписатьJSON(ЗаписьJSON, СтруктураСДанными);
	Сообщения = Новый Массив();
	Сообщения.Добавить(ЗаписьJSON.Закрыть());
	П = Новый Структура();
	П.Вставить("topic", "chat");
	П.Вставить("messages", Сообщения);
	desp_УдаленныйВызовПроцедур.ВызватьМетод("brake_push_messages", П);	
	Сообщение = "";
КонецПроцедуры

В данном примере взаимодействие с сервисом происходит исключительно синхронно, поэтому, такие моменты, как медленное соединение с "сервисом" и/или большой объем сообщений могут "замораживать" интерфейс, а его сетевая недоступность останавливает интерфейс Предприятия и сообщает об ошибке…

(Скорей всего хорошим решением для получения и отправки сообщений чата было бы не прямое (рилтайм) взаимодействие с методами сервера — brake, но взаимодействие с ними со стороны сервера 1C, в фоновых заданиях, и DESP это предусматривает! Однако, в данной статье рассмотрен не будет).

Как видите, технически всё достаточно просто. Из "необычного" в коде нужно обратить внимание на вызовы функции вида "desp_УдаленныйВызовПроцедур.ВызватьМетод()", — это обертка для обращения к сервису, где первый параметр, это имя вызываемого метода, второй, — именованные параметры, передаваемые для вызываемого метода. Т.е. все обращения к сервису осуществляются исключительно через эту функцию, и соответственно по стандарту (JSON-RPC 2.0), что дает возможность использовать сервис из кода других ЯП, скриптов.

Ответы на некоторые вопросы:

— Зачем оно мне, если у нас есть работающий "1С:Сервер взаимодействия" / Kafka / RabbitMQ?

— Тогда незачем.

— Сообщения сжимаются/шифруются?

— Передача и получение сообщений происходит по https. Сообщение на дисках сервера brake "лежат" в незашифрованном виде.

— Что такое DESP, а что такое brake?

— DESP — комплексное решение, состоящие из ядра (brake) + расширений для платформы 1С. brake — сервис, написанный на Go, реализующий функции, требующие максимальной производительности, потребляя минимальное количество ресурсов, там же располагаются данные очередей, JS-скрипты, конфигурационный файл сервиса.

— На что больше похож DESP в части работы с очередями?

— Идеология работы с очередями была подсмотрена у Kafka.

— Данные реплицируются с целью повышения доступности и/или увеличения производительности?

— Не реализовано на данный момент.

— Будет работать только через "Облако"?

— Для реальных проектов предполагается развертывание сервера в локальной сети.

— Можно ли программно создавать новые очереди?

— Нет, очереди задаются в конфигурационном файле сервиса, вместе с параметрами ротации (удаления устаревших данных), правами доступа и т.д.

— Нужно ли публиковать базу в web, чтобы она могла взаимодействовать с платформой?

— Нет, это не требуется. Всё взаимодействие происходит через запросы к платформе, никаких webhook не предусмотрено и не планируется.

Каталог решений - Обмен данными между базами 1С посредством передачи сообщений