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

Question

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

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

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

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

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

0

19.09.2023

16 ответов

5 просмотров

Feanorx

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

0

7 месяцев назад

_nikita Автор вопроса

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

0

7 месяцев назад

Feanorx

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

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

0

7 месяцев назад

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

7 месяцев назад

_nikita Автор вопроса

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

0

7 месяцев назад

Feanorx

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

А почему нет?

0

7 месяцев назад

Feanorx

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

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

0

7 месяцев назад

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

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

0

7 месяцев назад

Feanorx

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

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

0

7 месяцев назад

саша2007

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

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

0

7 месяцев назад

саша2007

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

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

0

7 месяцев назад

Agent-G

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

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

0

7 месяцев назад

Feanorx

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

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

0

7 месяцев назад

Feanorx

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

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

0

7 месяцев назад

Feanorx

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

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

0

7 месяцев назад

Ruslan · Accepted Answer

Ruslan

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

0

7 месяцев назад

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

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

16 ответов

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