Ребят, ситуация такая. по вебсокету подряд приходит куча пакетов - до

Question

Ребят, ситуация такая. по вебсокету подряд приходит куча пакетов - до

99
каждый раз надо тащить с бд один объект - проверить значение его поля - при выполнении условия обновить это поле и обновить запись в бд. И надо учитывать, что выполнение условия при текущем пакете зависит от обновленного значения при предыдущем пакете.
Что происходит на деле
1. приходит первый пакет - тащит с бд объект
2. обновляет значение поля - отправляет на апдейт в бд
3. в этот момент приходит след пакет и тащит с бд объект, который еще не успел обновиться после первого пакета - то есть значение там еще старое и получается несостыковка значений
предполагаю, что полученные пакеты нужно кещировать - дальше запускать метод, который по одному будет брать пакет из кеща - подождет пока обновится в бд и только потом из кеща брать след пакет.
Что-то внутри подсказывает, что мне тут надо использовать async await - channels - actor - в одном наборе.
В правильном направлении иду? и если знаете какой-то похожий пример или статью в этом духе - подскажите пожалуйста

#kotlin #programming #russian

0

07.10.2020

5 ответов

16 просмотров

Kozimjon Vakhobov Автор вопроса

Ruslan Ibragimov
Все сложно (c) Стоит задача синхронизации, котора...

😁 я один момент не указал, ссори. это все на андроиде - инстанс один, спасибо за наводку, пойду копаться

0

07.10.2020

Mike (деньги не клянчу)

Kozimjon Vakhobov
😁 я один момент не указал, ссори. это все на андро...

телеграм подобным образом накатывает обновления в базу

0

07.10.2020

Yuriy Timofeev

Имхо. Кэширование записи из бд в памяти и получить из вебсокета flow, чтобы обрабатывать в порядке очереди. Не подойдёт, если пакеты идут кучей постоянно, и в этом случае придется все равно часть отбрасывать.

0

08.10.2020

Dmitriy Startsev

Я бы начал с обычной пессимистичной блокировки. Если есть нужда освободить поток чтения из сокета, тогда через очередь.

0

08.10.2020

Ruslan Ibragimov · Accepted Answer

Все сложно (c) Стоит задача синхронизации, которая в общем случае не очень хорошо решается. Но решается неплохо в частном случае, например: 0. Несколько инстансов, база без локов - распределенный консенсус - отдельная система типо etcd/zookeeper которая будет отвечать за локи 1. Несколько инстансов приложения, один postgres - лок на запись aka select for update 2. Один инстанс - actor отлично подойдет, вот тут про опции можно прочитать https://kotlinlang.org/docs/reference/coroutines/shared-mutable-state-and-concurrency.html

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

Ребят, ситуация такая. по вебсокету подряд приходит куча пакетов - до

5 ответов

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