Что мне нужно сделать, чтобы конвертировать мою текущую систему, которая использует cron для использования RabbitMQ?

Question

мой текущий скрипт, использующий CRON для обработки проверки в БД и выполнения запросов

так будет вызываться каждый монетный двор CRON и проверять, какое действие должно быть выполнено в соответствии с записью в таблице расписания, так что теперь самое время отправить электронное письмо / опубликовать сообщение и т. Д. *

и эта запись становится все больше и больше со временем, и со многими пользователями теперь мой CRON занимает около 20-50 монет поэтому, если мне нужно отправить электронное письмо в 10:00, оно отправляется с 10:20 до 10:50

после поиска я обнаружил RabbitMQ и Redis и другие системы и выбрал RabbitMQ

так что дальше, что мне нужно делать дальше, так как по своему опыту я никогда не работаю с такой системой, как Redis и т. Д., Поэтому это что-то совершенно новое, так что если у кого-то есть и ресурсы для проверки, прочитайте или посмотрите и помогите мне с миграцией всей системы из CRON в RabbitMQ.

небольшая заметка, текущий скрипт построен поверх пользовательской среды PHP только для этого скрипта и не имеет API.

Answer 1

1. Напишите скрипт оболочки php для создания linux pid в бесконечном цикле и вызовите метод от cron.
2. Каждое задание отправляется в rabbitMq basic_publish с набором данных.
3. этот метод создать basic_consume с rabbitMq для выполнения очереди с набором данных очереди.