расписанию, при этом время старта задач у всех разное и может быть достаточно много, для этого как я понял можно использовать плагин в rabbitmq (для отложенных сообщений), редис или условно просто делать sleep в горутинах на отправку сообщения в нужное время(как я понимаю вариант не очень если у нас может быть условно больше 10000 сообщений например). Может кто-то сталкивался с подобными задачами и как решали?
ну 10000 горутин это ж надо такое придумать гггг. Можно список задач отсортированый по времени отправки хранить в slice и оттуда их обрабатывать (добавлять, забирать и высылать)
nsq попробуй
а nsq может в расписание?
я понял, спасибо, посмтрю )
проект прикольный, я его юзал. довольно стабилен
Создаёшь персистентную табличку вида Time:Task:Status (выполнено не выполнено) Пускаешь 1 горутину, которая: 1. Забирает ближайшую по времени, не выполненную запись 2. Засыпает до её выполнения 3. Просыпается, передаёт задачу(или задачи) на выполнение 4. По своей бизнес логике метит её как выполненую 5. Выбирает следующую невыполненную задачу и идёт спать до её выполнения Как-то так. Табличку можно хранить хоть в плоском файле, хоть в болте, хоть в Гугл-доксах. П1 можно модифицировать и выбирать пул задач по аппроксимированному промежутку + невыполненные задачи. Вобщем тут простор для фантазий. Единственное но, не стоит делать эту горутину исполнителем, только шедулером, а работу вынести в пул воркеров.
Да, думаю это выглядит подходяще. Спасибо!
Обсуждают сегодня