Вопросы по теме 'akka-persistence'
Примеры использования Akka Cluster, Cluster Sharding и Cluster singleton
Я пишу приложение Akka и хочу использовать функцию кластера Akka, которую предоставляет Typsafe. Я пытаюсь понять основное различие между Akka Cluster, Akka Cluster Singleton и Akka Cluster Sharding. Мне кажется, что они предоставляют похожие вещи....
2686 просмотров
schedule
26.04.2022
Пользовательский Java-плагин Akka Persistence
В настоящее время я пишу свой собственный плагин для Akka SyncWriteJournal API для реализации соединения с HSQLDB .
Проблема в том, что я не понимаю требований к методу doAsyncReplayMessages . В нем говорится, что ему нужно вернуть будущее и...
468 просмотров
schedule
13.06.2023
Что может быть самой легкой комбинацией плагина моментальных снимков и хранилища событий с точки зрения памяти и процессора?
Мы используем Akka Persistence для POC в качестве серверного решения для сбора внутренних показателей. В настоящее время мы хотим оставаться как можно более легкими (в отношении памяти и процессора). Мы используем журнал в памяти и моментальные...
194 просмотров
schedule
10.04.2023
Обработка сбоев персистентности akka
Я создаю приложение с постоянством Akka.
Я должен правильно обнаруживать и обрабатывать сбои сохранения. Как это возможно? Будет ли это вызывать какое-либо исключение сохранения?
Вот что у меня есть до сих пор
override def receiveRecover:...
1204 просмотров
schedule
03.12.2022
Не удается подключиться к контейнеру cassandra через haproxy
Я пытаюсь подключить внешнее приложение к Cassandra, которое работает в докеризованном состоянии в кластере mesos.
Вот приложения, которые я использую на mesos:
CONTAINER ID IMAGE COMMAND CREATED...
1381 просмотров
schedule
12.10.2022
Akka Persistence Cassandra: метка времени != смещение. Или как обрабатывать события только один раз?
В настоящее время я создаю приложение, основанное на событиях, с Akka Persistence и плагином Cassandra Journal. У меня есть несколько представлений, которым необходимо фиксировать события нескольких идентификаторов сохраняемости, поэтому я использую...
527 просмотров
schedule
24.01.2024
Странное поведение теста Scala с глобальными переменными: включение задержки делает его успешным
Во-первых, весь код находится в https://github.com/JJ/spray-test . Я использую глобальный объект (я не знаю, является ли это правильным поведением Scala) для совместного использования состояния в приложении Spray. put добавляет к карте, get...
348 просмотров
schedule
27.06.2023
Akka Persistence и Mongodb: сбой сохранения при воспроизведении событий для persistenceId
Я использую akka-persistence с mongodb, используя этот https://github.com/ironfish/akka-persistence-mongo/ плагины mongodb. когда я запускаю свой код, я получаю следующую ошибку:
[ERROR] [11/19/2016 16:47:29.355]...
2496 просмотров
schedule
22.12.2022
Поток Akka: использование очередей сохранения или источников событий
В потоковом приложении Akka, если приложение дает сбой/узел выходит из строя, я рискую потерять сообщения в процессе.
Что можно сделать, чтобы убедиться, что мы не теряем сообщения, и они воспроизводятся после возврата приложения.
В моем...
647 просмотров
schedule
11.03.2023
Какие актеры должны быть постоянными?
Давайте представим типичное приложение Akka с древовидной структурой Актеров, т. е. небольшим (2-3) количеством актеров верхнего уровня, которые потенциально управляют тысячами мелких актеров в нижней части иерархии. Кажется, есть два подхода к...
187 просмотров
schedule
26.02.2023
Другой вариант использования для маршрутизатора с поддержкой кластера akka и шардинга кластера akka?
Маршрутизатор с поддержкой кластера:
val router = system.actorOf(ClusterRouterPool(
RoundRobinPool(0),
ClusterRouterPoolSettings(
totalInstances = 20,
maxInstancesPerNode = 1,
allowLocalRoutees = false,
useRole = None
)...
1142 просмотров
schedule
25.03.2022
Каков типичный вариант использования PersistentView в Akka?
Здесь http://doc.akka.io/docs/akka/current/scala/persistence.html написано:
PersistentView: представление - это постоянный субъект с отслеживанием состояния, который получает журналируемые сообщения, написанные другим постоянным субъектом....
149 просмотров
schedule
14.06.2022
akka постоянство, возобновление после сбоя, хотя бы один раз семантика
У меня в голове небольшой беспорядок Избегайте заражения почтового ящика http://doc.akka.io/docs/akka/2.4.2/general/supervision.html
Затем новый субъект возобновляет обработку своего почтового ящика, а это означает, что перезапуск не виден...
295 просмотров
schedule
05.06.2022
Базовая акка - поиск акторов и их состояния
Это пара очень простых вопросов, касающихся akka. Я полностью зеленый на akka, поэтому любые советы приветствуются.
Скажем, у меня есть приложение с тысячами пользователей, а не с миллионами.
Модель домена представляет собой иерархию, в которой...
155 просмотров
schedule
13.04.2023
Обратное давление для Akka Sharding с настойчивыми актерами
Существует ли модель обратного давления потока Akka или что-то для использования осколков akka с постоянным актером?
Поскольку у меня есть проблема, у меня есть шардинговый кластер akka с постоянными акторами. (используя cassandra в качестве...
369 просмотров
schedule
20.03.2023
Постоянство Akka: удаление старых сообщений в журнале
Очистить старые снимки в хранилище снимков очень просто: после каждого успешного снимка актор получает saveSnapshotSuccess с метаданными, указывающими его порядковый номер, эту информацию можно использовать для создания снимка...
1089 просмотров
schedule
26.07.2023
Как подключить akka(java) к СУБД
Я новичок в Akka и хочу создать приложение CRUD с помощью любой СУБД. Я прошел через акка-настойчивость, которая меня сбивает с толку. Но в нем отсутствует какой-либо код реализации. Может ли кто-нибудь указать мне относительные ссылки / репозиторий...
953 просмотров
schedule
04.01.2023
akka сгенерированы постоянные события тестирования акторов
По определению CQRS команда может / должна быть проверена и в конце даже отклонена (если проверка не прошла). В рамках проверки моей команды я проверяю, действительно ли необходим переход состояния. Итак, давайте рассмотрим простой фиктивный пример:...
353 просмотров
schedule
06.04.2022
Akka Persistence: ReadJournal.runFold никогда не возвращается
Я впервые экспериментирую с Akka, а точнее с Akka Persistence. В конечном итоге я пытаюсь реализовать небольшую игрушечную программу, чтобы воспроизвести использование Akka в приложении, основанном на событиях. У меня был успех до того момента,...
122 просмотров
schedule
05.09.2022
Все ли постоянные акторы находятся в памяти?
У меня есть порядок, представленный постоянным Актёром Ордена в Акке (скажем, сохраняется в Кассандре)
У меня много заказов в моей системе.
В любой момент времени все акторы порядка находятся в памяти? или некоторые ** актеры порядка будут...
84 просмотров
schedule
07.09.2022
