AE
На самом деле можно будет просто сделать колбэк на откат в транзакции и снести из редиса данные
Size: a a a
2020 April 07
МК
На самом деле можно будет просто сделать колбэк на откат в транзакции и снести из редиса данные
ну так это весьма вероятно единственный путь, как это сэмулировать. Ну или делать временную вставку с каким-то временем жизни. Но! А если перед выполнением этого колбэка контейнер с приложением упадет?
AE
за чем этим?
Вообще в редисе есть транзакции и даже менеджер транзакций, гуглится на раз два https://dzone.com/articles/how-to-manage-transactions-in-redis-on-java
AE
ну так это весьма вероятно единственный путь, как это сэмулировать. Ну или делать временную вставку с каким-то временем жизни. Но! А если перед выполнением этого колбэка контейнер с приложением упадет?
Для этого делают журнал транзакций
МК
ну я редис просто так назвал. Пусть не редис, а какая-нить DynamoDB. Кемелу же должно быть пофиг, у него должно быть какое-то универсальное решение внутри
МК
Вообще в редисе есть транзакции и даже менеджер транзакций, гуглится на раз два https://dzone.com/articles/how-to-manage-transactions-in-redis-on-java
ну ты все сводишь к тому, что надо делать XA транзакции, так?
AE
ну ты все сводишь к тому, что надо делать XA транзакции, так?
да. либо пытаться cqrs
AE
ну я редис просто так назвал. Пусть не редис, а какая-нить DynamoDB. Кемелу же должно быть пофиг, у него должно быть какое-то универсальное решение внутри
почему у камела то?
AE
у спринга что ли фишка транзакций?
AE
или акки?
AE
вертекса?
AE
они все берут готовые ТМ и используют через стандартные интерфейсы
AE
и тут я бы взял спринг, а не верблюда
AE
какой сейчас у вас стек?
МК
амазоновский полностью :)
МК
ну про верблюда понятно, просто у нас нет транзакшен менеджера, который работал бы например с SNS, так как SNS/SQS - это не JMS
AE
тогда ищите решения именно под них
AK
Подскажите, рассматриваем возможность иcпользования apache camel в проекте. Но не могу понять, если делать простой роутинг аля rest -> какая-то логика -> публикация сообщения, то как camel гарантирует консистентность? Там XA транзакции под капотом или он как-то еще умеет?
а в чем проблема? возвращаете http 200 на запрос в конце роута, после того как получили подтверждение что отправили сообщение куда надо. если вопрос в том, а что будет если кемел принял запрос, отправил сообщение куда-то и упал, не ответив http 200 - так это из коробки просто так почти нигде не работает, нужны приседания.
AE
а в чем проблема? возвращаете http 200 на запрос в конце роута, после того как получили подтверждение что отправили сообщение куда надо. если вопрос в том, а что будет если кемел принял запрос, отправил сообщение куда-то и упал, не ответив http 200 - так это из коробки просто так почти нигде не работает, нужны приседания.
хотят очередь с состоянием кеша синкать
МК
а в чем проблема? возвращаете http 200 на запрос в конце роута, после того как получили подтверждение что отправили сообщение куда надо. если вопрос в том, а что будет если кемел принял запрос, отправил сообщение куда-то и упал, не ответив http 200 - так это из коробки просто так почти нигде не работает, нужны приседания.
тут скорее про то, что если мы в ходе обработки сохранили куда-нить в БД, а потом не опубликовали сообщение, то будет больно. Надо как-то гарантировать, что сообщение мы eventually опубликуем