Очереди сообщений в Bitrix Framework

В сфере искусственного интеллекта произошло заметное событие. bitrix24 10 минут назад Очереди сообщений в Bitrix Framework Средний 8 мин 232 Блог компании Битрикс24 Подготовка технической документации * Туториал В статье вместе с Ильей Рупасовым@rpsv, Григорием Бычеком@gbychek и Мариной Павловой @MarinaPav разбираем один такой сценарий: после изменения события в календаре Битрикс24 нужно синхронизировать его с Google Calendar. Вынесем эту операцию в очередь, создадим сообщение и обработчик, настроим очередь и проверим результат в логе. ❗️ Механизм очередей доступен с версии 25.

300 главного модуля Как работают очередиОчереди нужны, когда какую-то операцию нужно выполнить отдельно от основного действия пользователя. Вот пример: сотрудник изменил событие в календаре Битрикс24, а его нужно синхронизировать с Google Calendar. При обычной синхронной обработке запрос будет ждать, пока Битрикс24 обратится к Google и получит ответ.

Технические детали

Если внешний сервис отвечает медленно, пользователь тоже будет ждать. Если сервис временно недоступен, ошибка может повлиять и на основной запрос. При асинхронной обработке эти действия разделяются.

Битрикс24 сохраняет изменение события и завершает текущий запрос, а задачу синхронизации передаёт в очередь. Она будет выполнена отдельно, когда обработчик получит сообщение. Для этого механизм очередей использует несколько элементов.

Сообщение содержит данные, которые понадобятся для фоновой операции — например, ID события и внешнего календаря. Очередь определяет, какой обработчик должен получить сообщение и с какими настройками оно будет обрабатываться. Брокер сохраняет сообщения до момента обработки.

Отраслевые последствия

В текущей версии Bitrix Framework поддерживается брокер типа db, поэтому сообщения хранятся в базе данных. Воркер получает доступные сообщения из брокера и передаёт их обработчику. Обработчик выполняет саму фоновую работу.

В нашей статье реальную синхронизацию с Google Calendar заменим записью в лог. Весь путь выглядит так:изменение события → сообщение → очередь → брокер → воркер → обработчик → логОчереди могут работать в режимах web и cli. В режиме web обработка запускается через фоновые задачи после завершения веб-запроса.

В режиме cli сообщения получает отдельный консольный воркер. Дальше воспользуемся cli, чтобы явно запустить обработку и проверить результат в логе. Создаём сообщениеНачнём с сообщения — объекта, в котором хранятся данные для фоновой обработки.

Этот прогресс даёт важные сигналы о будущем отрасли, и технологический мир внимательно наблюдает.