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

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

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

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

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

16 ответов

19 просмотров

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

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

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

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

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

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

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)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Обсуждают сегодня

#include <stdio.h> #include <stdlib.h> #include <time.h> void mass_first_generate(int mass[5][7]) {     for (int N = 0; N < 5; N++) {         for (int A = 0; A < 7; A++) {   ...
Чувак
6
https://www.linkedin.com/posts/ugama-benedicta-kelechi-codergirl-103041300_mobiledevelopment-fluttertraining-handsonlearning-activity-7263445699227254784-IdHB?utm_source=share...
CoderGirl
16
Всем привет! Имеется функция: function IsValidChar(ch: UTF8Char): Boolean; var i: Integer; ValidChars: AnsiString; begin ValidChars := 'abcdefghijklmnopqrstuvwxyzABCDE...
Евгений
44
Помогите пожалуйста. Делаю систему плагинов. Проблема сейчас в такая: плагины загружаются в основном потоке. FLibHandle := SafeLoadLibrary(FFileName) Но нужно еще выполнить фу...
Илья 🤣
10
Ну вот просто даже давайте вот как. Какой нибудь конкретный кейс, можете в пример привести, где бч работает и приносит прикладную пользу, а не просто что бы было? Не крипту.
Alexander Andreev
22
объясните пожалуйста, почему функция не работает должным образом? вроде должно брать активное окно сравнивать его размер с размером экрана, и если есть совпадение = true прове...
JF
12
лучше скажите, причём тут паскаль?
Alexey Kulakov
36
Гляньте, че бывает: Сегодня по одному проекту одной вебстудии делал проект небольшой, на их хостинге. На Modx revo. В определенный момент , работая в админке, вдруг перестал р...
Artem
7
Но, может, есть уже проверенная? Наши требования такие: 1. Сообщения должны приходить из Инста в CRM оду 2. Должна быть возможность подключить несколько экаунтов Инстаграм. Р...
Alexander Sharoiko MSE / Александр Шаройко
12
> Копаем глубже > Следующий момент был, когда я спросил его, знает ли он JavaScript. Он ответил, что его учили работать с C#. Я тоже в университете писал на C#, но даже там мн...
Oleg Volkov
4
Карта сайта