Описание тега akka-remoting
Akka - это библиотека для создания параллельных масштабируемых приложений с использованием модели акторов. Удаленное взаимодействие Akka предназначено для одноранговой связи. Возможности удаленного взаимодействия в Akka 2.0 действительно мощные.
0
ответов
Как сохранить акторы Java Akka живыми на удаленных системах, готовых получать сообщения о развертывании?
Я пытаюсь создать актерские кластеры АККА в распределенных системах с помощью JAVA. Я могу использовать их в одной машине. Просто интересно, предположим, я держу актеров в разных машинах, как мне сохранить их живыми, чтобы быть готовыми к получению …
06 июн '18 в 00:34
1
ответ
Получение Akka.NET для подключения к удаленным адресам
Все демонстрации, которые я нашел, демонстрирующие, как начать работу с удаленным взаимодействием в Akka.NET, демонстрируют простейший вариант использования, когда два участника работают на одной машине с использованием localhost. Я пытаюсь заставит…
09 ноя '17 в 16:12
1
ответ
Предупреждение сериализатора по умолчанию
Я не хочу отключать предупреждающие сообщения, так как хочу знать, как выполнить предложение по определению сериализатора для повышения производительности? [INFO] [06/24/2016 19:28:34.659] [main] [akka.remote.Remoting] Starting remoting [INFO] [06/2…
24 июн '16 в 11:38
2
ответа
Ошибка при использовании akka remoting с артерией над экземплярами докера
Прежде всего, извините за мой английский. Гугл переводчик мне очень помогает, хаха. Моя проблема заключается в следующем: У меня есть два примера проектов, разработанных с akka а также java: example-remote-client.jar и example-remote-server.jar Я ис…
04 июл '17 в 14:29
1
ответ
Иногда узел не присоединяется к кластеру Akka.Net после перезапуска IIS AppPool
Мы создали инфраструктуру кластера Akka для SMS-сообщений, электронной почты и push-уведомлений. В системе существует 3 вида узлов: клиент, отправитель и маяк. Роль клиента используется веб-приложением и приложением API (веб-интерфейс и API размещаю…
07 июн '16 в 13:35
0
ответов
Akka Remoting: множественное развертывание с использованием Props.withDeploy(...).
Я создаю образец с Akka Remote Actor с RemoteLookupProxyForwarder как определено в книге "Акка в действии". Мои требования - создать актера удаленно, но с использованием конфигурации кода. RemoteLookupProxyForwarder Это похоже на поиск удаленной сис…
08 мар '17 в 06:32
0
ответов
Акка удаленное не начнется
Я новичок в Akka и работаю над хорошо написанной книгой Джейсона Гудвина Learning Akka. Однако в его примерах используется активатор, и, поскольку активатор пропал, я воссоздаю его примеры из главы 2 без активатора. Проблема в том, что мой код (без …
22 окт '18 в 15:30
0
ответов
Protobuf добавляет "реализующий интерфейс" к сгенерированным классам для маршрутизации их через кластер Akka
Мне нужны сгенерированные классы protobuf для реализации интерфейса akka.routing.ConsistentHashingRouter.ConsistentHashable из удаленной библиотеки Akka. Это возможно? Мне нужны мои сообщения для маршрутизации через кластер Akka, но сообщения должны…
22 ноя '17 в 13:58
1
ответ
Настройки конфигурации Akka.NET для удаленного взаимодействия
Я использую пример на github Akka.NET, чтобы поиграть с базовым удаленным взаимодействием. В примере удаленного взаимодействия, доступном на GitHub, есть следующий раздел в строке конфигурации для Akka.NET. deployment { /localactor { router = round-…
08 ноя '17 в 14:18
1
ответ
Akka.Net Потоки и удаленное взаимодействие (Sink.ActorRefWithAck)
Я сделал довольно простую реализацию с помощью Akka.net Streams, используя Sink.ActorRefWithAck: подписчик запрашивает большую строку у издателя, который отправляет ее по частям. Он отлично работает локально (UT), но не удаленно. И я не могу понять,…
19 мар '18 в 09:58
1
ответ
Akka remote: возможно ли работать с классами из двух разных приложений, которые не имеют одинаковое имя пакета?
У меня есть два приложения, которые общаются через пульт Akka. У меня есть один класс в моей первой заявке в pachage a: @SerialVersionUID(42L) case class A() и то же самое в моем втором приложении, но в другой упаковке b: @SerialVersionUID(42L) case…
21 окт '16 в 08:00
0
ответов
Как изменить удаленную конфигурацию akka с GuiceApplicationBuilder в Play?
Мне не удается изменить конфигурацию пульта akka в тестах моего Play! скала приложение. В моем application.conf файл, я установил удаленный порт akka следующим образом, и он работает хорошо: akka.remote.netty.tcp.port = 2552 В моих интеграционных те…
29 апр '16 в 08:39
2
ответа
Как справиться с несвежим akka.net удаленным iactorref
Я использую удаленных актеров в akka.net в Windows-сервисе, который работает долго. Я получаю IActorRef для удаленного субъекта, используя ActorSelection, и поддерживаю этот IActorRef в течение продолжительного периода времени в службе. IActorRef ук…
22 дек '16 в 22:40
0
ответов
Akka Remote - предотвращение диссоциации на стороне слушателя
Допустим, у нас есть A и B, настроенный удаленно (netty.udp) (без кластера). Оба запускались на разных портах. Актер в A отправляет сообщения актерам в B посредством маршрутизации (используя RemoteRouterConfig и по адресу). Они все получают это и от…
03 фев '17 в 11:42
1
ответ
Могу ли я перезапустить удаленный Akka Actor?
Я предполагаю, что Актер-супервайзер контролирует удаленного актера. Есть ли способ перезапустить удаленного субъекта, если этот субъект потерпел неудачу во время обработки запроса. И если это невозможно, может кто-нибудь предложить мне способ решит…
26 апр '18 в 09:31
0
ответов
Akka - маршрутизатор с поддержкой кластера не запускает узлы
Мне нужно создать кластер из 3 узлов, где каждый узел будет запускать один экземпляр актера -TestActor, Я хочу, чтобы маршрутизатор сам создал узлы (пул), но первый созданный им узел будет начальным, поскольку маршруты будут первыми участниками, соз…
08 янв '17 в 11:32
1
ответ
Как правильно использовать DI для внедрения конструктора контроллера Play?
Я перевожу приложение Play 2.3.x в Play 2.5.x и у меня возникают некоторые проблемы с использованием внедрения зависимостей. В 2.3 у меня появилась черта HasRemoteActor который контроллер будет смешивать, чтобы иметь ссылку на некоторый удаленный су…
14 фев '17 в 13:20
2
ответа
ByteBuffer сериализации akka - java.lang.UnsupportedOperationException
Мне нужна некоторая помощь для сериализации сущности, чтобы отправить ее через Akka Remote. Это класс сериализатора: @Override public void toBinary(Object o, ByteBuffer buf) { byte[] bytes = null; ByteArrayOutputStream bos = null; ObjectOutputStream…
27 июн '17 в 18:39
1
ответ
АККА: Путаница в отношении программного удаленного развертывания
Я использую удаленное развертывание akka. Я использовал ведение журнала, чтобы убедиться, что субъект успешно развернут удаленно. Вот мой лог [adaptiveCEP-akka.actor.default-dispatcher-18] [akka.tcp://adaptiveCEP@127.0.0.1:2555/remote/akka.tcp/adapt…
15 июн '17 в 18:30
1
ответ
Почему Akka не возвращает адрес / информацию о хосте?
Акка 2.5 здесь. У меня есть необходимость определить, является ли конкретный ActorRef находится на той же JVM, что и мое приложение. Моя лучшая попытка: someActor.path().address().host().isEmpty() ... возвращается true для меня (пусто; адрес / инфор…
29 ноя '18 в 01:52