юзер)
Как это лучше всего сделать?
Есть идея выгружать сообщения в Redis,
сделать отдельный сервис, который будет каждую секунду вытягивать записи из Redis, и отправлять их
Хорошая ли это затея?
Посмотри в сторону очередей, например на редисе bullmq есть
Плохая. Redis хранит все в памяти. Когда сообщений станет настолько много, что памяти не хватит, будет усё.
А как это можно по человечески реализовать?
В базе храни обычной. Напиши запрос который вытаскивает минимальное по времени неотправленное сообщение.
setInterval( async ()=> { let time = Math.round( Date.now() / 1000 ); let messages = await mysql.query('SELECT * FROM ... WHERE `time` > ?', [time]); let sendedids = []; for (let message of messages) { await send... sendedids.push(id) } await mysql.query('DELETE FROM ... WHERE id IN (' + sendedids.join(',') + ')'); }, 10000)
А из обычной базы тянуть нормально?
А почему нет?
Лучше по одному удалять сразу после отправки. В этом случае если отправка сломается в последнем из 100 сообщений, они все повторно отправлены не будут.
Какая точность нужна? Системный крон не подойдёт?
А ещё тут проблема в том, что если функция в setInterval занимает больше времени чем секунда начнется ад и Израиль. Сообщения будут отправляться многократно.
Лучше отловить те которые удались и юзнуть in [success_ids]
А там 10 секунд))
пример да, додумать нужно, асинхронные действия такие асинхронные)
Ну чаще чем раз в 10 секунд
Самый простой способ решить это, это сделать флаг isProcessing, который в начале внутренней функции выставляется в true, в конце в fasle. Если в начале он уже был true, просто выходим из функции
Душно как-то становится)
Обсуждают сегодня