akka

0зной

1ответ

Как ограничить актер в кластерный Akka actorsystem выполнить только в одном узле

У меня есть actorsystem, который имеет 3 актеров и перечислены ниже RMQreaderActor - Это актер, который читает сообщения из RMQ и говорит ниже двух актеров, чтобы преобразовать сообщение и процесс его

1зной

3ответ

производитель Akka поток TCP + Akka поток Кафка не останавливаясь не публиковать сообщения, а не ошибка-ки из

У меня есть следующий поток: Source(IndexedSeq(ByteString.empty)) .via( Tcp().outgoingConnection(bsAddress, bsPort) .via(Framing.delimiter(ByteString("\n"), 256, allowTruncation = true))

1зной

2ответ

Как создать раковину для чтения всех байтов из источника?

У меня есть метод, который принимает SCALA этого источника в соответствии с моими требованиями def func(data : Source[ByteString,Any]) { ... } все, что я хочу сделать, сейчас, чтобы прочитать все ба

3зной

1ответ

Поток файлов с сервера на клиент с помощью Akka

В принципе, я хочу разрешить пользователю загружать csv-файл с сервера. Предположим, что файл CSV уже существует на сервере. Конечная точка API открывается через GET/export. Как я могу передать файл с

1зной

2ответ

Какая польза от создания реквизита для создания актера в Акке?

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

2зной

2ответ

Почему поведение Akka Actor по умолчанию обрабатывает сообщения один за другим?

Я читал, что акк-акер обрабатывает сообщения один за другим. Почему это? Что мне не удалось обернуть вокруг: «Почему синхронизированное выполнение сообщений по умолчанию?». Я понимаю, что для параллел

5зной

1ответ

akka http compile error

Я новичок в каркасе akka и теперь пытаюсь установить простой веб-сервис с этой структурой. написать простую Акку-HTTP приложение: import akka.actor.ActorSystem import akka.http.scaladsl.Http import