RabbitMQ нативно в 1С:
без компонент, прокси и шины

Как заставить 1С напрямую общаться с RabbitMQ, получив outbox/inbox «из коробки» без сторонних библиотек и прокси-сервисов

Существующие подходы и их компромиссы

На данный момент мне известно несколько способов прикрутить RabbitMQ к 1С, разной степени боли и жести

Немного теории: как платформа работает с 1С:Шиной

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

Как платформа получает список каналов

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

Платформа отправляет запрос на /auth/oidc/token с заголовком Authorization: Basic <login:password в base64> и ожидает ответ такого вида:

{
  "id_token": "<ваш токен>",
  "token_type": "Bearer",
  "access_token": "Not implemented"
}

Шаг 2 — Получение списка каналов

Получив токен, платформа запрашивает GET /sys/esb/metadata/channels уже с заголовком Authorization: Bearer <токен>. В ответ она ожидает список каналов:

[
  {
    "process": "Основной::Обмен",
    "processDescription": "",
    "channel": "toShop",
    "channelDescription": "",
    "access": "WRITE_ONLY"
  },
  {
    "process": "Основной::Обмен",
    "processDescription": "",
    "channel": "fromShop",
    "channelDescription": "",
    "access": "READ_ONLY"
  }
]

Наша ягодка — поле destination

Когда платформа начинает фактически отправлять сообщение, она делает ещё один запрос для получения токена, и ещё один для получения списка каналов, но уже на GET /sys/esb/runtime/channels. Однако она получает не просто список каналов, а адреса и порт для переключения на AMQP 1.0:

{
  "items": [
    {
      "process": "e1c::ТестовыйПроект::Основной::OfficeToShop",
      "channel": "toShop",
      "destination": "PUBLIC.VGVzdEFwcA==.-1.d34871...toShop.shop"
    }
  ],
  "port": 6698
}

destination — это адрес, по которому платформа будет адресовать сообщения после переключения на AMQP. В случае шины там закодированная base64 + md5 строка с внутренними идентификаторами. Но нас это не смущает, ведь мы можем указать там любой адрес— а именно тот, который понимает RabbitMQ.

А как RabbitMQ маппит адреса AMQP 1.0 на свои собственные?

Ты, дорогой читатель, удивишься, но RabbitMQ при включённом плагине amqp 1.0 имеет специальные форматы адресации которые, вот ведь неожиданность, очень удобно использовать:

// Отправка на обменник с routing key
/exchanges/<exchange_name>/<routing_key>

// Чтение из очереди напрямую
/queues/<queue_name>

{
  "items": [
    {
      "process": "rabbitmq",
      "channel": "write_channel",
      "destination": "/exchanges/1c_exchange/some.external.service"
    },
    {
      "process": "rabbitmq",
      "channel": "read_channel",
      "destination": "/queues/read.queue"
    }
  ],
  "port": 5672
}

Практика

Мы поняли, как общаться с RabbitMQ из 1С. Осталось реализовать это на практике.
Вариантов может быть множество — от нормальной реализации с OAuth провайдерами, отдельным сервисом раздачи каналов, настроенной авторизацией на RabbitMQ до раздачи статики вебсервером.

Но я же обещал максимально нативно — поэтому мы реализуем HTTP-сервисы, так ещё и без OAuth (хотя платформа позволяет настроить авторизацию с токеном).

Шаг 1. Поднимаем RabbitMQ

Поднимаем RabbitMQ с плагином management UI. Если версия брокера ниже 4.0 — включаем плагин AMQP 1.0 командой:

rabbitmq-plugins enable rabbitmq_amqp1_0

В панели управления создаём обменник, я назову его 1c_exchange.

Создаём очередь test и привязываем её к обменнику. Для каждой очереди важно создавать привязки — именно это позволяет отправителю не знать о получателе, а получателю использовать, например, заголовок replyTo.

Вообще, как правило, point-to-point обмен, когда отправитель знает детали адреса получателя (имя базы) — плохая затея. Назначайте роуты по ИНН организаций, скажем, и вычисляйте в процессе работы.

Если все сделано правильно, то список привязок будет выглядеть вот так:

Для получения сообщений создаём отдельную очередь read.queue и также привязываем её к тому же обменнику с маршрутом some.internal.service - другие системы будут писать именно через него:

Шаг 2. HTTP-сервис на стороне 1С

Нам нужен HTTP-сервис с тремя маршрутами:

Решаем проблему авторизации

Здесь есть нюанс: при загрузке каналов платформа сначала авторизуется через Basic (логин и пароль в Base64), а потом переходит на Bearer <токен>. HTTP-сервис 1С без дополнительной настройки для авторизации по токену вернёт ошибку на Bearer-запрос.

Но нас это не пугает — в ответе /auth/oidc/token возвращаем token_type: "Basic" и кладём в id_token ту же Base64-строку логина и пароля, которую получили в заголовке запроса. Тогда все дальнейшие запросы платформа будет подписывать Authorization: Basic <base64> — и сервис их примет, и RabbitMQ в дальнейшем не обидится.

Подготовка пользователя:

1. 1 Создаем пользователя в 1С, например: логин Admin, пароль test.
2. 2 Закодируем строку Admin:test в Base64 — получится QWRtaW46dGVzdA==.
3. 3 Создаем пользователя в RabbitMQ с именем QWRtaW46dGVzdA== и паролем QWRtaW46dGVzdA== — они одинаковые.

Код HTTP-сервиса (1С)

Создаём три обработчика — по одному на каждый маршрут:

И добавляем в обработчики следующий код:

Функция АвторизацияЗапросТокена(Запрос)
    Ответ = Новый HTTPСервисОтвет(200);

    // Берём Base64-строку прямо из заголовка запроса
    СтрокаАвторизации = Запрос.Заголовки.Получить("Authorization");
    СтрокаАвторизации = СтрЗаменить(СтрокаАвторизации, "Basic ", "");

    Ответ.УстановитьТелоИзСтроки(
    "{
    |  ""id_token"": """ + СтрокаАвторизации + """,
    |  ""token_type"": ""Basic"",
    |  ""access_token"": ""Not implemented""
    |}");

    Возврат Ответ;
КонецФункции

Функция КаналыМетаданныеЗапросКаналов(Запрос)
    Ответ = Новый HTTPСервисОтвет(200);
    Ответ.Заголовки.Вставить("Content-type", "application/json; charset=utf-8");

    Ответ.УстановитьТелоИзСтроки(
    "[
    |  {
    |    ""process"": ""RabbitMQ"",
    |    ""processDescription"": """",
    |    ""channel"": ""write_channel"",
    |    ""channelDescription"": """",
    |    ""access"": ""WRITE_ONLY""
    |  },
    |  {
    |    ""process"": ""RabbitMQ"",
    |    ""processDescription"": """",
    |    ""channel"": ""read_channel"",
    |    ""channelDescription"": """",
    |    ""access"": ""READ_ONLY""
    |  }
    |]");

    Возврат Ответ;
КонецФункции

Функция КаналыРантаймЗапросКаналов(Запрос)
    Ответ = Новый HTTPСервисОтвет(200);

    Ответ.УстановитьТелоИзСтроки(
    "{
    |  ""items"": [
    |    {
    |      ""process"": ""RabbitMQ"",
    |      ""channel"": ""write_channel"",
    |      ""destination"": ""/exchanges/1c_exchange/some.external.service""
    |    },
    |    {
    |      ""process"": ""RabbitMQ"",
    |      ""channel"": ""read_channel"",
    |      ""destination"": ""/queues/read.queue""
    |    }
    |  ],
    |  ""port"": 5672
    |}");

    Возврат Ответ;
КонецФункции

Публикуем HTTP-сервис на веб-сервере.

Шаг 3. Настройка обратного прокси (Apache)

Платформа обращается к маршрутам напрямую от адреса сервера, то есть без наших base/hs/etc. Нам нужно перенаправить запросы на эти адреса на наш HTTP-сервис.

Для Apache в файле conf/extra/httpd-vhosts.conf добавляем виртуальный хост с обратным прокси:

<VirtualHost *:80>
    ServerName localhost

    ProxyPass        /auth/oidc/token
                     http://localhost/test/hs/channels/auth/oidc/token
    ProxyPassReverse /auth/oidc/token
                     http://localhost/test/hs/channels/auth/oidc/token

    ProxyPass        /sys/esb/metadata/channels
                     http://localhost/test/hs/channels/sys/esb/metadata/channels
    ProxyPassReverse /sys/esb/metadata/channels
                     http://localhost/test/hs/channels/sys/esb/metadata/channels

    ProxyPass        /sys/esb/runtime/channels
                     http://localhost/test/hs/channels/sys/esb/runtime/channels
    ProxyPassReverse /sys/esb/runtime/channels
                     http://localhost/test/hs/channels/sys/esb/runtime/channels
</VirtualHost>

В основном httpd.conf раскомментируйте нужные строки:

LoadModule proxy_module      modules/mod_proxy.so
LoadModule proxy_http_module modules/mod_proxy_http.so
Include    conf/extra/httpd-vhosts.conf

Шаг 4. Загрузка каналов

Открываем форму загрузки каналов, указываем адрес нашего сервера, логин и пароль пользователя 1С. Нажимаем «Получить каналы» — каналы появятся в дереве метаданных конфигурации.

Для канала чтения добавляем обработчик входящих сообщений:

Процедура RabbitMQ_read_channelОбработкаПолученияСообщения(Сообщение, Отказ)
    Поток = Сообщение.ПолучитьТелоКакПоток();

    Буфер = Новый БуферДвоичныхДанных(Сообщение.РазмерТела);
    Поток.Прочитать(Буфер, 0, Сообщение.РазмерТела);

    Сообщить(ПолучитьСтрокуИзБуфераДвоичныхДанных(Буфер, КодировкаТекста.UTF8));
КонецПроцедуры

Обновляем конфигурацию, переходим в управление сервисами интеграции, активируем сервис и указываем логин/пароль пользователя — того же, которого мы создали, именно его base64 строка будет передана в RabbitMQ.

Шаг 5. Отправка сообщения из 1С → RabbitMQ

Итак, мы на финишной прямой, пора попробовать отправить сообщение — создайте обработку, на форме добавьте поле «Сообщение», команду «Отправить» и в обработчик вставьте этот код:

Процедура ОтправитьНаСервере()
    БуферСообщения = ПолучитьБуферДвоичныхДанныхИзСтроки(ЭтотОбъект.Сообщение);

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

    ПотокСообщения = СообщениеИнтеграции.ПолучитьТелоКакПоток();
    ПотокСообщения.Записать(БуферСообщения, 0, БуферСообщения.Размер);
    ПотокСообщения.Закрыть();

    // Сохраняет сообщение в БД (Outbox-паттерн)
    СервисыИнтеграции.RabbitMQ.proc_write_channel.ОтправитьСообщение(СообщениеИнтеграции);

    // Запускает фоновое задание отправки
    // какое-то время оно будет обрабатывать входящие и исходящие сообщения
    СервисыИнтеграции.ВыполнитьОбработку();
КонецПроцедуры

Жмем на заветную кнопку

и... 

Соединение установлено! Отлично, а что у нас в очереди some.external.service?

Получилось! В очереди хранится сообщение, в payload - отправленный нами текст, закодированный в формате base64. Осталось только получить сообщение ИЗ очереди.

Шаг 6. Получение сообщения из RabbitMQ → 1С

Переходим в панель RabbitMQ, открываем очередь read.queue и публикуем тестовое сообщение прямо в неё.

Любым способом вызовите метод СервисыИнтеграции.ВыполнитьОбработку(), можно через ту же обработку, и...

Поздравляю! Вы великолепны.