У Telegram есть ограничение по отправке сообщений за секунду. допустим,

Question

У Telegram есть ограничение по отправке сообщений за секунду. допустим,

есть основной поток, который обрабатывает сообщения от пользователей, и другой, который только отправляет сообщения. так как эти потоки работают независимо, то они не знают, как много сообщений было отправлено за секунду, поэтому можно привысить лимиты. решение очевидно — сделать очередь, в которую будут складываться все сообщения, которые нужно отправить, но возникает пару вопросов:
1) как реализовать эту очередь? стоит ли прибегать ко всяким RabbitMQ?
2) стоит ли делать два отдельных бинарника или можно всё оставить в одном бинарном файле? (условно, один поток наблюдает за изменениями на сайте и если они есть, то он присылает сообщение, а второй отвечает за непосредственное взаимодействие с теми, кто пользуется ботом)

#haskell #programming #russian

0

20.06.2021

11 ответов

19 просмотров

Ilya Kos

Берёшь TQueue и делаешь отдельный поток

0

20.06.2021

Воинствующий Безбожник Автор вопроса

Nick Ivanych
Для лимитирования скорости очередь не обязательна.

почему же? как тогда понять, что лимит превышен? глобальное состояние?

0

20.06.2021

Nick Ivanych

Воинствующий Безбожник
почему же? как тогда понять, что лимит превышен? г...

Очередь достаточно из циферок, а не самих сообщений.

0

20.06.2021

Воинствующий Безбожник Автор вопроса

Nick Ivanych
Очередь достаточно из циферок, а не самих сообщени...

извините, но я вас не понял. я попробую объяснить, почему без очереди нельзя обойтись. очевидно, отправкой сообщений надо заниматься в отдельном потоке. надо передавать данные в этот самый поток, сообщения могут накапливаться, поэтому нужно такое хранилище, которые сможет хранить более одного сообщения. что делает этот поток? он достаёт сообщение, далее проверяет по времени, можно ли его отправить, иначе либо ждёт, либо переходит к следующему сообщению (тут надо подумать над алгоритмом) и так, пока не закончатся сообщения в очереди. вот моя задумка. может быть, можно проще, но, честно, я не знаю как

0

20.06.2021

Nick Ivanych

Воинствующий Безбожник
извините, но я вас не понял. я попробую объяснить,...

Можно про текущее сообщение решать, насколько его задержать, исходя из текущей вычисленной скорости.

0

20.06.2021

Воинствующий Безбожник Автор вопроса

Nick Ivanych
Можно про текущее сообщение решать, насколько его ...

а. понял. т.е. сразу же планировать отправку сообщения, а не усыплять поток. интересно... спасибо

0

20.06.2021

Nutritional Rabbit

Воинствующий Безбожник
извините, но я вас не понял. я попробую объяснить,...

делай батчи и отправляй за раз все нужные сообщения, не?

0

20.06.2021

Воинствующий Безбожник Автор вопроса

Nutritional Rabbit
делай батчи и отправляй за раз все нужные сообщени...

так не получится, потому что с помощью sendMessage можно отправить только одно сообщение за раз. и смысла собирать сообщения в группу нет, всё равно лучше их отправку лучше запланировать

0

20.06.2021

Alexey Raga

Воинствующий Безбожник
так не получится, потому что с помощью sendMessage...

А я бы не планировал ничего (сложно это), а использовал бы Rate Limited queue consumption. То есть, вот у меня сам "сервис", который читает очередь и делает sednMessage был бы ограничен определённым количеством операций в секунду. Может быть даже https://hackage.haskell.org/package/rate-limit-1.4.2 подощёл бы.

0

21.06.2021

Воинствующий Безбожник Автор вопроса

Alexey Raga
А я бы не планировал ничего (сложно это), а исполь...

спасибо, я почитаю. скорее всего придётся свой велосипед изобретать всё равно, хаха. а то там не так просто, что сообщения можно отправлять n сообщений за секунду, там чуть больше правил

0

21.06.2021

Nick Ivanych · Accepted Answer

Nick Ivanych

Для лимитирования скорости очередь не обязательна.

0

20.06.2021

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

У Telegram есть ограничение по отправке сообщений за секунду. допустим,

11 ответов

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