Публикации по теме 'akka'
Выпуск скубов 0.9.0
squbs 0.9 обеспечивает прочную основу для перехода squbs на версию 1.0. Мы не ожидаем серьезных изменений API в будущем. Ниже приведены самые большие ожидаемые изменения между squbs 0.9.0 и 1.0.0:
Обновите Akka 2.4.x до Akka 2.5.x. Это повлияет на варианты использования актеров Java, переходящие в окончательный API AbstractActor в Akka 2.5.x. Обновление со Scala 2.11.x до Scala 2.12.x
Почему сквибы?
squbs — это комплексная асинхронная реактивная архитектура для создания..
Реализовать шину событий с помощью Akka
Вы, наверное, много раз читали такие сообщения и хотите знать, что еще я могу рассказать вам по этой теме. Может быть, немного, но моя идея для этого поста была вдохновлена реальным сценарием, который я реализовал в своем проекте. Я начну с событий, входящих / исходящих с помощью веб-сокетов, которые затем распространяются на актеров Akka. В следующем посте я добавлю RabbitMQ для поддержки нескольких модулей / экземпляров приложения.
Задний план
В проекте, над которым я..
Контроль и обработка ошибок в ZIO, Akka и Monix (часть 3) + обзор серии
В предыдущих частях мы видели:
как реализовать асинхронный процесс с отслеживанием состояния , сравнивая реализации Akka Actors , Akka Typed Actors , Monix и ZIO (Scalaz 8 IO). как можно смоделировать коммуникацию между асинхронными процессами
В этой последней части мы рассмотрим последнюю особенность, которая выделяет акторов: обработка ошибок , контроль и иерархия акторов .
О чем это все? Что-то постоянно терпит неудачу . Всякий раз, когда вы общаетесь с внешней..
Вопросы по теме 'akka'
Akka управляет потоками пула потоков
Потенциально очень глупый вопрос...
Можно ли настроить акторы Akka/Scala таким образом, чтобы вы могли управлять потоками, которые используются акторами? например можете ли вы инициализировать свой собственный набор потоков для использования в...
1690 просмотров
schedule
28.02.2024
Несогласованное поведение между локальным и удаленным акторами
Это своего рода продолжение предыдущего вопроса в привязка переменных Scala при использовании с Актеры
Вопреки советам других, я решил сделать сообщение, содержащее закрытие, и изменить переменную, в которой закрытие закрывается между...
169 просмотров
schedule
17.11.2022
Akka: появление актеров против заполнения почтовых ящиков
Если вы хотите выполнять длительные вычисления одновременно (на одной машине), акторы Akka могут помочь.
Один из подходов - создавать нового актера для каждой части работы. Что-то типа
while(true) {
val actor =...
835 просмотров
schedule
30.01.2024
В Scala Futures.awaitAll завершает поток по тайм-ауту?
Итак, я пишу мини-библиотеку тайм-аута в scala, она очень похожа на код здесь: Как получить исключения, выброшенные в Scala Future?
Функция, которую я выполняю, либо будет успешно завершена, либо заблокирована навсегда, поэтому мне нужно...
1231 просмотров
schedule
18.10.2023
Почему Akka Actor не принимает подканалы?
У меня есть Akka ActorEventBus (ссылка https://github.com/akka/akka/blob/master/akka-actor/src/main/scala/akka/event/EventBus.scala#L70 ), который обрабатывает множество сообщений передается разным актерам.
Я настроил Актера для подписки на...
433 просмотров
schedule
02.03.2024
реализация сериализации с Play 2 и удаленным кластером Akka
У меня есть игровая платформа 2, которая подключена к удаленной кластерной системе Akka, обе системы находятся в java. У меня есть структура данных, которая завернута в класс, и я реализовал сериализуемый класс-оболочку. Я хочу использовать...
821 просмотров
schedule
20.01.2024
Akka 2.1 Remote: совместное использование актера в разных системах
Я изучаю удаленные акторы в Akka 2.1 и пытаюсь адаптировать контрпример от Typesafe . Я реализовал быстрый и грязный пользовательский интерфейс из консоли для отправки тиков. И выйти с запросом (и показом результата) текущего счета.
Идея состоит...
614 просмотров
schedule
15.01.2024
Scala Future mapTo не скомпилируется из-за отсутствия ClassTag
Простой вопрос, у меня проблема, когда использование mapTo в результате запроса приводит к ошибке компилятора в следующем виде:
not found: value ClassTag
Например:
(job ? "Run").mapTo[Result]
^
Я не понимаю, зачем...
2283 просмотров
schedule
30.10.2022
Неявная передача контекста запроса в системе акторов
Я хотел бы неявно распространять контекст запроса в системе взаимодействующих субъектов.
Чтобы упростить и представить ситуацию, моя система имеет несколько субъектов, и сообщения, передаваемые этим субъектам, должны включать этот объект...
3031 просмотров
schedule
25.03.2024
Создайте актера Akka удаленно без новой ActorSystem
Я уже несколько раз просматривал документацию ( http://doc.akka.io/docs/akka/2.1.4/scala/remoting.html ) и в примере здесь ( https://github.com/akka/akka/tree/master/akka-samples/akka-sample-remote ) и через других, и я до сих пор не могу понять, как...
1476 просмотров
schedule
08.09.2022
Как мне лучше всего разделить поведение между актерами Akka?
У меня есть два актора Akka, которые реагируют на одни сообщения одинаково, а на другие — по-разному. Они оба отвечают на один и тот же набор сообщений. Хотите знать, как спроектировать двух моих актеров с их методами приема, через наследование,...
5264 просмотров
schedule
29.03.2024
Есть ли в Акке легкие актеры?
Мой вариант использования очень прост — для обмена несколькими (‹ 100) сообщениями между двумя объектами акторы Scala отлично подходили для этой цели (легкий вес, несложное управление жизненным циклом, запуск/завершение в любое время).
Теперь я...
1230 просмотров
schedule
10.10.2023
Akka: Актеры, использующие BalancingDispatcher, перестают получать ReceiveTimeouts
Мы обнаружили проблему, из-за которой группа Актеров, совместно использующих BalancingDispatcher, перестает получать сообщения ReceiveTimeout, если они не получают другие сообщения. Сначала каждый актер в группе получает ReceiveTimeout, как и...
866 просмотров
schedule
23.12.2023
как отправить сообщение каждому актеру (или ActorRef) в массиве в Akka?
Я работаю над eclipse под Ubuntu 12.04 со scala 2.10 и Akka 2.2.1.
// A and B are derived from Node
val algorithm = if(args(0) > 1)()=> new A else ()=> new B
/* alternative:
val algorithm =...
1147 просмотров
schedule
21.01.2024
Определение маршрута akka-camel 2.2.1 с использованием Spring XML
Я использую akka-camel 2.2.1, и мне нужно настроить маршруты к и от актеров Consumer и Producer соответственно. В настоящее время я определяю маршруты и программно добавляю их во внутренний контекст Camel в CamelExtension следующим образом:...
974 просмотров
schedule
07.07.2022
Инъекция зависимостей Scaldi и актеры Akka
В настоящее время я изучаю использование Scaldi для внедрения зависимостей в приложении Play2.2.
Я прочитал документацию на веб-сайте Scaldi, но мне непонятно, как использовать ее с Akka.
Что у меня есть на данный момент в моем проекте:...
1689 просмотров
schedule
16.12.2023
Akka TypedActor — как правильно обрабатывать асинхронные ответы с контекстом
Я начал работать с TypedActors в Scala и столкнулся с проблемой, делая что-то довольно простое: я хочу, чтобы Актер A вызывал метод для Актера B и обрабатывал результат в анонимной функции для Актера A, но гарантируя, что:
My response-handling...
1106 просмотров
schedule
19.01.2024
Следует ли использовать такую инфраструктуру, как Akka, для переноса блокирующих вызовов (в реляционную БД)?
Я много читал о программировании, управляемом событиями, на стороне сервера, в основном о Akka и Play. Я понимаю потенциальные преимущества сокращения количества активных потоков. Тем не менее, я не могу обдумать конкретный сценарий:
Представьте,...
191 просмотров
schedule
11.08.2022
Разница между forward и tell в акках акка
В чем разница между tell и forward, если я отправлю то же сообщение:
case msg: Message =>
otherActor tell (msg,sender)
и
case msg: Message =>
otherActor forward msg
16727 просмотров
schedule
06.01.2024
Утвердить порядок сообщений, полученных с помощью Akka TestProbe
У нас есть актор, для которого мы пишем модульные тесты, и в рамках тестов мы хотим утверждать, что определенные сообщения отправляются другому актору в определенном порядке. В наших модульных тестах актор, получающий сообщения, представлен Akka...
1997 просмотров
schedule
21.09.2022
