DDMQ Chronos

Chronos — это модуль отложенных сообщений DDMQ, который обеспечивает надёжное хранение большого объёма отложенных сообщений. Chronos использует RocksDB в качестве движка для хранения отложенных сообщений.

Особенности

• Разнообразие типов сообщений: отложенные сообщения, циклические отложенные сообщения и транзакционные сообщения (для решения проблем с транзакциями между подсистемами или между базами данных).
• Высокая доступность и надёжность: автоматическое переключение между основным и резервным серверами и несколько копий данных.
• Простота подключения: глубокая интеграция с DDMQ и использование одной и той же производственной потребительской SDK и одной и той же пользовательской консоли управления.
• Большой объём: данные хранятся на жёстком диске.

Архитектура

Разработчики, использующие производственный SDK DDMQ, отправляют отложенные сообщения в PProxy, после чего PProxy записывает их во внутреннюю тему, настроенную заранее. Затем Chronos обрабатывает сообщения из внутренней темы и сохраняет их в встроенном движке хранения RocksDB. Встроенный сервис временных циклов Chronos повторно отправляет просроченные сообщения в DDMQ для обработки бизнес-пользователями.

Развёртывание

1. Запросите внутреннюю тему и группу на консоли.
2. Измените конфигурацию chronos.yaml.
3. Выполните скрипт build.sh для создания пакета.
4. Выполните команду control.sh start для запуска.