Stability fixes phases 1-4: errors, I/O sync, connection loss, quorum

[bafgion]

Summary

Комплексные исправления стабильности и API (фазы 1–4, v2.3→v2.6). Протестировано в форке: CI Entry (28 матриц Linux/Windows), релизы v2.4.0.11 / v2.5.0.15 / v2.6.0.17.

Закрываемые issues (27): #12, #15, #24, #26, #49, #51, #54, #58, #64, #65, #77, #79, #82, #83, #88, #89, #90, #93, #94, #95, #98, #99, #100, #101, #103, #104, #105 + метод BatchPublish (#106).

Базовые улучшения (v2.3)

• Устранён busy-wait в event loop (Windows/Linux) (#105).
• AMQP heartbeat на Windows и Linux (#49).
• BasicCancel (#15, #58): отмена consumer на брокере, сброс consume-канала.
• BasicReject (#64): необязательный параметр requeue.
• BasicPublish / BatchPublish (#12, #106): publisher confirms, корректная длина тела (message.size()), большие сообщения (#103, #104).
• GetHeaders (#101), GetQueueMessageCount (#83).
• Connect: таймаут из параметра API (по умолчанию 5 с).
• CI: workflow Entry (Linux + Windows + RabbitMQ service).

Фаза 1 — ошибки без падений (v2.4)

• BasicConsume: проверка существования очереди (#107).
• BasicPublish/BatchPublish: проверка exchange, mandatory, returned messages (#12).
• BasicConsumeMessage: Ложь + GetLastError вместо исключений (#54, #98).

Фаза 2 — стабильность и I/O (v2.4)

• Синхронизация AMQP I/O (ioMutex / withIoLock) (#51, #103, #104).
• Безопасный shutdown / clear() (#95, #79, #94).
• Валидация типа порта в Connect (#24).

Фаза 3 — обрыв связи (v2.5)

• Детекция потери TCP/AMQP (notifyLost), разблокировка loop(), ошибка в BasicConsumeMessage (#88).
• Linux: AMQP heartbeat в event-loop (#49).
• Прогрев каналов в Connect — гонка Connect→DeclareExchange (#65).
• Graceful shutdown: ожидание AMQP close handshake (#26).
• Windows: однократная инициализация SSL (#89), снижение CPU в idle read-loop (#105).

Фаза 4 — v2.6

• Quorum-очереди: QoS без global, per-consumer при selectSize > 0 (#90).
• Убрана задержка после Ack/Reject (#99).
• LoopCallbackGuard после AMQP timeout — соединение не помечается потерянным (#77).
• BasicConsumeMessage: таймаут / пустая очередь / большие тела — Ложь + GetLastError (#93, #98).
• Валидация длины routing key / exchange / queue (255 байт) (#82).
• Linux: ioMutex вокруг TcpConnection::process() (#51).
• CI: сборка в debian:bullseye-slim (glibc 2.31) на ubuntu-22.04 runner (#100).
• Повторный Connect и переоткрытие канала после NOT_FOUND (#79, #65, #12).

Не входит в PR (enhancement / вопросы)

#1, #4, #10, #20, #23, #46, #70, #75 — новый API; #5, #18, #39, #44, #66, #68, #78, #81, #84, #87, #92 — требуют уточнения или документации.

Test plan

• CI Entry: 45 passed, 2 skipped (Linux debian:bullseye-slim + Windows, 28 платформ 1С)
• Тесты: quorum, reconnect, immediate Declare*, publish+consume, missing exchange (×2), large message 500KB
• Ручная проверка на Windows Server 2022
• Docker debian:bullseye-slim / ubuntu:20.04 — сборка и pytest локально
• CentOS 7.9 / прод rphost — ожидает проверки (#79)

Fork

Разработка и релизы: bafgion/PinkRabbitMQ · CHANGELOG