Всем привет. Стоит задача, отправлять сообщения через некоторое время (которое укажет

Question

Всем привет. Стоит задача, отправлять сообщения через некоторое время (которое укажет

юзер)
Как это лучше всего сделать?

Есть идея выгружать сообщения в Redis,
сделать отдельный сервис, который будет каждую секунду вытягивать записи из Redis, и отправлять их

Хорошая ли это затея?

#backend #javascript #node.js #programming #russian

0

19.09.2023

16 ответов

24 просмотра

Feanorx

Плохая. Redis хранит все в памяти. Когда сообщений станет настолько много, что памяти не хватит, будет усё.

0

19.09.2023

_nikitå Автор вопроса

А как это можно по человечески реализовать?

0

19.09.2023

Feanorx

_nikitå
А как это можно по человечески реализовать?

В базе храни обычной. Напиши запрос который вытаскивает минимальное по времени неотправленное сообщение.

0

19.09.2023

Agent-G

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)

0

19.09.2023

_nikitå Автор вопроса

А из обычной базы тянуть нормально?

0

19.09.2023

Feanorx

_nikitå
А из обычной базы тянуть нормально?

А почему нет?

0

19.09.2023

Feanorx

Agent-G
setInterval( async ()=> { let time = Math.round...

Лучше по одному удалять сразу после отправки. В этом случае если отправка сломается в последнем из 100 сообщений, они все повторно отправлены не будут.

0

19.09.2023

Алексей Попов

Какая точность нужна? Системный крон не подойдёт?

0

19.09.2023

Feanorx

Agent-G
setInterval( async ()=> { let time = Math.round...

А ещё тут проблема в том, что если функция в setInterval занимает больше времени чем секунда начнется ад и Израиль. Сообщения будут отправляться многократно.

0

19.09.2023

саша2007

Feanorx
Лучше по одному удалять сразу после отправки. В эт...

Лучше отловить те которые удались и юзнуть in [success_ids]

0

19.09.2023

саша2007

Feanorx
А ещё тут проблема в том, что если функция в setIn...

А там 10 секунд))

0

19.09.2023

Agent-G

Feanorx
А ещё тут проблема в том, что если функция в setIn...

пример да, додумать нужно, асинхронные действия такие асинхронные)

0

19.09.2023

Feanorx

саша2007
А там 10 секунд))

Ну чаще чем раз в 10 секунд

0

19.09.2023

Feanorx

Feanorx
А ещё тут проблема в том, что если функция в setIn...

Самый простой способ решить это, это сделать флаг isProcessing, который в начале внутренней функции выставляется в true, в конце в fasle. Если в начале он уже был true, просто выходим из функции

0

19.09.2023

Feanorx

саша2007
А там 10 секунд))

Душно как-то становится)

0

19.09.2023

Ruslan · Accepted Answer

Ruslan

Посмотри в сторону очередей, например на редисе bullmq есть

0

19.09.2023

170 похожих чатов

Всем привет. Стоит задача, отправлять сообщения через некоторое время (которое укажет

16 ответов

Похожие вопросы