В рейтинге участвует:

групп:

каналов:

Виртуальный сервер на SSD - недорого!

Аренда выделенных и виртуальных серверов (VDS/VPS), хостинг, аренда IP-адресов, администрирование, круглосуточная поддержка

qwarta.ru подробнее

Резервное копирование с проверкой на вирусы!!!

Удобный сервис создания резервных копий на любой сервер сети интернет. Отслеживайте изменения, проверяйте на вирусы. Надежно защитите свой бизнес!

go.backupland.com

Выбираете сервер? Любая конфигурация на заказ!

Аренда физических серверов любых конфигураций под любые запросы - 1С бухгалтерия, игровые сервера, нагруженные проекты, интернет-магазины!

qwarta.ru подробнее

Size: a a a

Kotlin Community

3214 membersпожаловаться на группу
2020 May 21

IK

Igor Komarov in Kotlin Community
Alexander Nozik
Если я правильно понял, то вам достаточно сделать обычный Flow, но суспендить отправку при получении статуса
Нет. Так делать нельзя, другие сообщения могут отправиться. Статус распространяется на один конкретный Webhook (DiscordId), отсюда и гемор
источник
18:09пожаловаться#1

IO

Iaroslav Orlov in Kotlin Community
Igor Komarov
Я отправляю сообщения в Discord из очереди на отправку. При статусе 429, мне нужно положить сообщение в очередь на отправку, и при этом, чем более старым является сообщение, тем раньше оно должно попытаться отправиться снова (тем ближе оно к началу очереди). Подобный механизм позволит гарантировать доставку сообщений.
рейт-лимит?
источник
18:09пожаловаться#2

IK

Igor Komarov in Kotlin Community
Количество потоков по количеству Webhook делать также нельзя.
источник
18:09пожаловаться#3

IK

Igor Komarov in Kotlin Community
Iaroslav Orlov
рейт-лимит?
Да.
источник
18:09пожаловаться#4

AN

Alexander Nozik in Kotlin Community
Ну так по flow на каждый webhook. Можно сделать отдельный накопительный канал для неотправленный сообщений, конечно, он будет тоже fifo
источник
18:10пожаловаться#5

IO

Iaroslav Orlov in Kotlin Community
я, возможно, предлагаю что-то левое, но вы можете по заголовкам смотреть, сколько у вас еще осталось запросов
источник
18:11пожаловаться#6

AN

Alexander Nozik in Kotlin Community
что-то типа if(429){channel.send()}
источник
18:11пожаловаться#7

IO

Iaroslav Orlov in Kotlin Community
не обязательно падать именно на too many requests
источник
18:11пожаловаться#8

IK

Igor Komarov in Kotlin Community
Iaroslav Orlov
не обязательно падать именно на too many requests
Не уверен, но лишний запрос не критичен. Критичен механизм упорядочивания сообщений.
источник
18:12пожаловаться#9

IK

Igor Komarov in Kotlin Community
Alexander Nozik
что-то типа if(429){channel.send()}
А как это решение будет выглядеть при распараллеливании на N потоков < M Webhook-ов?
источник
18:13пожаловаться#10

AN

Alexander Nozik in Kotlin Community
Igor Komarov
А как это решение будет выглядеть при распараллеливании на N потоков < M Webhook-ов?
Зависит от того, что вы хотите. Можно для каждого свой канал сделать, можно сваливать в один общий.
источник
18:13пожаловаться#11

AN

Alexander Nozik in Kotlin Community
Если на каждый свой flow, то как бы и канал не нужен, просто конкретный флоу засуспендится пока отправка не прочихается
источник
18:14пожаловаться#12

IK

Igor Komarov in Kotlin Community
В таком случае, если у меня 2 потока, 4 канала, до тех пор пока сообщения есть в двух каналах, и их не отрежет 429, сообщения из других двух каналов не будут отправляться, и будут ждать в очереди на выполнение?
источник
18:16пожаловаться#13

IK

Igor Komarov in Kotlin Community
Насколько я понял, вы предлагаете аналогичный механизм, который будет иметь иной принцип работы. Мне же интересно, можно ли на корутинах сделать в точности такое поведение, как в примере выше?
источник
18:18пожаловаться#14

AN

Alexander Nozik in Kotlin Community
Igor Komarov
Насколько я понял, вы предлагаете аналогичный механизм, который будет иметь иной принцип работы. Мне же интересно, можно ли на корутинах сделать в точности такое поведение, как в примере выше?
Там очень много буков. Если бы вы могли в двух предложениях описать, как оно работает, было бы проще ответить
источник
18:19пожаловаться#15

IK

Igor Komarov in Kotlin Community
Давайте попробую выпилить оттуда все ненужное, к сожалению, текстом описать сложно
источник
18:20пожаловаться#16

AN

Alexander Nozik in Kotlin Community
Igor Komarov
Давайте попробую выпилить оттуда все ненужное, к сожалению, текстом описать сложно
У вас там две структуры. Одна - это очередь на все сообщеия вроде. Вторая что делает?
источник
18:21пожаловаться#17

IK

Igor Komarov in Kotlin Community
Alexander Nozik
У вас там две структуры. Одна - это очередь на все сообщеия вроде. Вторая что делает?
Вторая – N параллельно работающих потоков, которые циклично вытягивают из очереди сообщения, для которых на текущий момент доступна отправка (время ожидания после 429 прошло), по одному отправляют, если ловят 429, закидывают обратно в очередь.
источник
18:23пожаловаться#18

IK

Igor Komarov in Kotlin Community
Убрал лишнее, так должно восприниматься лучше

https://gist.github.com/ivkomarov/eb9e8feae7a7a4eb4bbd7115a898b148
Gist
DiscordEngine.kt
GitHub Gist: instantly share code, notes, and snippets.
источник
18:23пожаловаться#19

AN

Alexander Nozik in Kotlin Community
Igor Komarov
Вторая – N параллельно работающих потоков, которые циклично вытягивают из очереди сообщения, для которых на текущий момент доступна отправка (время ожидания после 429 прошло), по одному отправляют, если ловят 429, закидывают обратно в очередь.
Отраженное событие в конец очереди встает?
источник
18:24пожаловаться#20