Содержание:

1. Установка внешней компоненты и настройка соединения с RabbitMQ

2. Создание канала, объявление очереди и подписка в RabbitMQ 1С

3. Обработка входящих сообщений

4. Обработка ошибок и закрытие соединения

RabbitMQ — это популярный брокер сообщений, который позволяет различным приложениям асинхронно обмениваться данными. Если отправка сообщений из 1С (publisher) решает задачу выгрузки данных, то получение (consumer) позволяет 1С реагировать на внешние события в реальном времени. В этой статье мы рассмотрим, как реализовать получение данных в 1С из RabbitMQ, то есть как настроить consumer (потребителя) на встроенном языке 1С: Предприятие.

Установка внешней компоненты и настройка соединения с RabbitMQ

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

Установление соединения с RabbitMQ

После подключения компоненты необходимо установить соединение с сервером RabbitMQ. Для этого вызывается соответствующий метод, в который передаются параметры: адрес сервера, порт, виртуальный хост, логин и пароль. Успешное соединение является основой для дальнейшего взаимодействия.

Создание канала, объявление очереди и подписка в RabbitMQ 1С

В RabbitMQ 1С вся работа с сообщениями происходит через каналы — легковесные соединения внутри основного TCP-подключения. После установления соединения необходимо открыть канал, который будет использован для подписки на очередь и получения сообщений. “Считается хорошей практикой использовать отдельные каналы для разных логических задач”.

Объявление очереди

Перед тем как начать слушать сообщения, нужно убедиться в существовании очереди. Для этого используется метод объявления очереди, где указывается её имя и параметры. Если очередь с заданным именем уже существует, этот вызов просто подтвердит её наличие.

Начало прослушивания очереди (подписка)

Вы даёте команду RabbitMQ 1С начать присылать вам сообщения из конкретной очереди, как только они там появятся. Этот процесс и называется подпиской.

Для этого используется ключевой метод внешней компоненты, чаще всего называемый BasicConsume. При вызове этого метода вы он начинает отправку из очереди.

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

Как только consumer подписывается на очередь, внешняя компонента начинает инициировать внешние события в 1С при поступлении новых сообщений. В коде 1С создается процедура-обработчик этого события, которая принимает данные сообщения. Основные данные — это тело сообщения (как правило, строка в формате JSON или XML) и его тег доставки, уникальный идентификатор для подтверждения.

Обработка ошибок и закрытие соединения

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

Специалист компании ООО “Кодерлайн”,

Хрулев Иван