При интеграции 1С с очередями RabbitMQ возникают следующие проблемы:

• Потеря сообщений при перезапуске брокера или аварийном падении обработчиков 1С.
• Зависание фонового консьюмера (Consumer) 1С в вечном цикле опроса очереди (High CPU / memory leak).
• Переполнение очереди сообщений (Queue Overflow) из-за низкой скорости обработки воркерами 1С.
• Ошибки авторизации и обрывы AMQP/REST соединений по сетевым таймаутам.

1. Архитектура интеграции: Выбор протокола (Native AMQP vs HTTP API)

Для взаимодействия 1С с RabbitMQ используются два подхода:

• RabbitMQ Management HTTP API: работа через стандартный объект платформы HTTPСоединение (простота реализации, не требует внешних компонент).
• Native AMQP Protocol: работа через внешнюю компоненту Native API (минимальные задержки, поддержка постоянных сокетов и Push-уведомлений).

2. Надежная отправка сообщений (Producer) через HTTP API

Соединение = Новый HTTPСоединение("rabbitmq.corp.local", 15672, "admin", "StrongPassword", , 10, Новый ЗащищенноеСоединениеOpenSSL());
Запрос = Новый HTTPЗапрос("/api/exchanges/%2F/amq.default/publish");
Запрос.Заголовки.Вставить("Content-Type", "application/json");

// Тело сообщения с подтверждением сохранения на диск (delivery_mode=2)
ТелоJSON = Новый Структура;
ТелоJSON.Вставить("properties", Новый Структура("delivery_mode", 2));
ТелоJSON.Вставить("routing_key", "1c_orders_queue");
ТелоJSON.Вставить("payload", Base64Строка(ДвоичныеДанныеXML));
ТелоJSON.Вставить("payload_encoding", "base64");

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

Ответ = Соединение.ОтправитьДляОбработки(Запрос);

3. Обработка очереди (Consumer) с подтверждением доставки (ACK)

Никогда не используйте автоматическое подтверждение (auto_ack=true). Сообщение должно подтверждаться только после успешной фиксации транзакции в базе данных 1С:

1. Получить сообщение из очереди (/api/queues/%2F/my_queue/get с параметром ackmode=ack_requeue_false).
2. Начать транзакцию 1С (НачатьТранзакцию()).
3. Создать и записать документ.
4. Зафиксировать транзакцию (ЗафиксироватьТранзакцию()).
5. Отправить подтверждение успешной обработки (ACK) в RabbitMQ. При ошибке — отправить NACK с возвратом в очередь (requeue).