Вопросы по теме 'akka.net'

Модель акторов с Akka.NET: как предотвратить отправку сообщений мертвым акторам
Я использую Akka.NET для реализации системы акторов, в которой некоторые акторы создаются по запросу и удаляются после настраиваемого периода простоя (для этого я использую механизм Akka "ReceiveTimeout"). Каждый из этих субъектов идентифицируется...
2022 просмотров
schedule 06.10.2022

Получение государственных акторов через рабочих акторов в AKKA
У меня есть три актера для обработки сценария CQRS. ProductWorkerActor обрабатывает часть команды, ProductQueryWorkerActor обрабатывает часть запроса, а ProductStateActor обрабатывает часть состояния. Я обрабатываю запрос, используя:...
386 просмотров
schedule 25.01.2023

Akka.net и модульные тесты
Я хотел бы использовать Akka.net TestKit для написания модульных тестов, но у меня есть вопрос. У меня есть класс SubscriptionService, который отвечает за передачу сообщений выбранным акторам. public class SubscriptionService : ReceiveActor {...
973 просмотров
schedule 04.06.2022

Кластер Akka (.net) с удаленными узлами: несвязанное исключение
Используя akka (.net), я пытаюсь реализовать простой вариант использования кластера. Кластер - для событий подъема / опускания узлов. Удаленный - для отправки сообщения определенному узлу. Есть два участника: главный узел, который...
1705 просмотров
schedule 01.12.2022

Сохранение Akka.Net с MongoDB
Я пытаюсь реализовать Akka Persistence с помощью Mongodb и получаю сообщение об ошибке "Method 'DeleteAsync' in type 'Akka.Persistence.MongoDb.Snapshot.MongoDbSnapshotStore' from assembly 'Akka.Persistence.MongoDb, Version=1.0.4.1,...
880 просмотров
schedule 19.03.2023

AKKA.Net Кластеризация и общий ресурс
Эй, я читаю и смотрю видео на AKKA.Net, и мне нравится то, что я вижу. Я хочу попробовать AKKA.net в имеющемся у меня приложении, но мне нужна помощь, чтобы прояснить некоторые моменты Сценарий Я хочу создать кластер Akka.net с: 3...
269 просмотров
schedule 09.11.2022

Какой метод Actor.Tell предпочтительнее и почему?
Мне интересно, какой метод Tell следует использовать по умолчанию? Документы на http://getakka.net/docs/working-with-actors/sending-messages подсказка, что Tell(message, sender) является предпочтительным способом отправки сообщения, однако,...
220 просмотров
schedule 01.06.2022

Как сделать WaitAll с помощью Akka.Net?
У меня есть иерархия субъектов в Akka.Net, и мне интересно, правильно ли я выбрал способ что-то сделать, или есть лучшие / более простые способы достичь того, чего я хочу. Мой конкретный пример: я создаю субъект User в ответ на вход пользователя...
548 просмотров
schedule 14.02.2024

Обработка избыточности и отказоустойчивости в Akka.Net
Я реализовал акторную систему Akka.Net в службе, которая принимает удаленные запросы, выполняет обработку и отправляет ответы. Состояние некоторых участников системы сохраняется в базе данных. Когда система акторов запускается, эти акторы...
443 просмотров
schedule 27.06.2023

Как ограничить потребление памяти для системы Akka.net?
У нас есть служба Windows, использующая Akka.net для обработки сообщений. В частности, у нас есть 10 идентичных частных очередей MSMQ и 10 участников-координаторов. Мы назначили каждому актеру обработку одной очереди и отправку сообщений о...
683 просмотров
schedule 27.12.2023

Время жизни системы актеров в WPF
В прошлом, используя консольные приложения, я поддерживал системы акторов Akka.NET следующим образом: class Program { static void Main(string[] args) { using (var actorSystem = ActorSystem.Create("ExampleSystem")) { var...
330 просмотров
schedule 14.10.2022

Повторить/воспроизвести неудачные сообщения в AKKA
Я использую AKKA.NET в своем текущем проекте .NET. Мой вопрос заключается в следующем: как опытные разработчики AKKA реализуют шаблон повторного сообщения о сбое, используя последние библиотеки AKKA для Java или .NET? Вот еще некоторые...
1646 просмотров
schedule 16.10.2022

Как протестировать DistributedPubSub с помощью TestKit в Akka.net?
Я выполняю модульное тестирование актера, использующего инструмент Cluster DistributedPubSub . Для тестов я использую TestKit Akka.net. Судя по всему, в TestKit системный актор Sys не имеет инструмента DistributedPubSub и при доступе к нему...
488 просмотров
schedule 01.08.2022

Есть ли способ дождаться полной остановки актера?
Насколько я знаю, все операции в Akka.Net асинхронны, и Context.Stop() просто отправляет сообщение Stop актору. Это означает, что актор будет жить некоторое время, прежде чем он полностью отключится. И если я позвоню Context.Child() сразу...
1066 просмотров
schedule 18.11.2023

Как добавить акторов во время выполнения в группу или пул в akka.net при использовании ConsistentHashmapping?
Я хочу добавлять и удалять участников в пул (группу?), Которые должны получать сообщения через маршрутизатор с использованием согласованного сопоставления хэшей (сообщение имеет идентификатор, соответствующий пути объекта). Но после создания пула...
678 просмотров
schedule 22.06.2022

Шардинг кластера Akka.net: невозможно зарегистрировать координатора
Я пытаюсь настроить сегментирование кластера akka.net, создав простой проект . Макет проекта: Актеры  — библиотека классов, определяющая одного актера и сообщение. Является ссылкой на другие проекты Входящие — запускает ShardedRegion и...
617 просмотров

Обработка исключений с помощью akka.net PipeTo() в задаче
Ссылаясь на документацию Akka.Net, использование PipeTo() предпочтительнее при работе с асинхронными заданиями. Имея дело с функцией, возвращающей Task<T> , я могу обработать событие отказа без проблем. Проблема в том, что при работе с...
1238 просмотров
schedule 27.12.2022

Akka.net Hyperion IgnoringDataMember
Я использую akka.net в схеме кластера. (n) узлы обработки, в настоящее время 1 маяк. Один из пакетов, который перемещается по сети, предоставляет информацию о языке. /// <summary> /// Define scored a suite of token info ///...
178 просмотров
schedule 16.07.2022

Некоторые проблемы с тестированием Akka.net
Версия Akka.NET v1.3.8 Версия Akka.TestKit.NUnit3 v1.3.2 Версия NUnit v3.10.1 Платформа Windows 10 У меня есть такой актер: public class BranchUsersActor : ReceiveActor { public BranchUsersActor() {...
158 просмотров
schedule 13.10.2022

Не удалось присоединиться к кластеру Akka.NET
У меня проблема с присоединением и отладкой присоединения к кластеру Akka.NET. Я использую версию 1.3.8. Моя установка следующая: Маяк Почти дефолтный код с гитхаба. Выполняется в консоли akka.hocon следующим образом: lighthouse {...
977 просмотров