12
ответов
AKKA-Java NullPointerExeption [дубликат]
Я делаю первые шаги в AKKA, следуя этому руководству: есть тестовый файл J-unit и класс для Актера. Вы можете увидеть весь код по ссылке, это всего лишь куча строк. Однако тест не удается ...
вопрос задан: 26 May 2016 16:15
6
ответов
Лучшие практики для развертывания инструментов и сценариев к производству?
У меня есть много пакетных обработок, которые работают негласно за веб-сайтом Linux/PHP. Они начинают расти в числе и сложности, таким образом, я хочу принести небольшое количество процесса для влияния...
вопрос задан: 30 May 2009 10:05
4
ответа
Создание агентов
Я реализовал Приятную для слуха черту / черту Слушателя, которая может быть добавлена к Агентам. Я задаюсь вопросом, возможно ли присоединить этот стиль черты к агенту без него имеющий необходимость явно звонить...
вопрос задан: 9 March 2010 20:31
3
ответа
Есть ли способ получить сопоставляемый элемент, когда генерируется исключение akka streams?
Я хочу иметь возможность регистрировать определенные атрибуты сопоставляемого элемента, если возникает исключение, поэтому мне было интересно, есть ли способ получить сопоставляемый элемент при создании исключения akka ...
вопрос задан: 17 January 2019 15:43
3
ответа
Другой обзор реализаций агента Scala
Я пытаюсь найти 'правильную' реализацию агента. Я понял, что существует набор их, и это немного сбивает с толку для выбора того. Лично я особенно интересуюсь удаленными агентами, но я предполагаю...
вопрос задан: 22 August 2012 18:15
3
ответа
Который ThreadPool в Java я должен использовать?
Существует огромное количество задач. Каждая задача, принадлежат единственной группе. Требование является каждой группой задач, должен выполняемый последовательно, точно так же, как выполняется в единственном потоке, и пропускная способность должна...
вопрос задан: 14 October 2010 08:33
2
ответа
Получить Seq сущностей из ответа akka http на основе массива json
Я пытаюсь использовать Flow как http-клиент Akka, и у меня возникли проблемы с получением Seq объектов класса case из массива json в ответе http. HTTP-ответ: {"bars": [], "foos": [{"id": ...
вопрос задан: 20 January 2019 16:23
2
ответа
Агенты Scala - худшие методы? [закрытый]
Я чувствую себя немного небезопасным об использовании агентов в Scala. Я прочитал документацию о том, как сделать материал, но я предполагаю, что мне также было бы нужно, некоторые не ДЕЛАЮТ правил, чтобы не стесняться использовать их. Я думаю, что я...
вопрос задан: 1 February 2018 16:49
2
ответа
Как масштабировать мое приложение REST Scala, которое использует Akka?
У меня есть приложение Scala, использующее Akka, которое получает запросы REST, выполняет некоторые операции с базой данных и отвечает некоторой информацией клиенту. Как так, мои операции с БД занимают много времени ...
вопрос задан: 8 October 2014 12:25
2
ответа
Как я переписываю для цикла с общей зависимостью с помощью агентов
У нас есть некоторый код, который должен работать быстрее. Его уже представленный, таким образом, мы хотели бы использовать несколько потоков. Обычно я устанавливал бы в очереди памяти и имел бы много потоков, устраивающихся на работу...
вопрос задан: 22 March 2010 19:05
1
ответ
Полнофункциональное планирование Cron потоков akka
В потоках akka можно сделать следующее: Source.tick (0.seconds, 15.seconds, «Hello»), и ваш поток будет получать тиковый элемент «Hello» каждые 15 секунд. То, что я ищу, это ...
вопрос задан: 5 March 2019 19:04
1
ответ
Поведение Akka Supervision по умолчанию
Я пытаюсь узнать нашу стратегию надзора Акки. Когда у меня есть код, подобный приведенному ниже, я получаю java.lang.ArithmeticException: / с нулевым регистром объекта Create Children case class ...
вопрос задан: 17 January 2019 02:01
1
ответ
Как часто мы должны использовать фьючерсов и актеров? Есть альтернативы? [закрыто]
Я решил создать физический движок с помощью scala, используя параллелизм. Я знаю, что для большого числа вычислений можно распараллелить (что важно для оптимизации вещей). Однако я знаю ...
вопрос задан: 16 January 2019 07:58
1
ответ
Как исправить Dropping Close, так как соединение SSL уже закрывает ошибку в спрее
Я звоню в API, но большую часть времени получаю сообщение об ошибке: «Отключение закрытия, так как соединение SSL уже закрывается» и «Преждевременное соединение закрывается (сервер, похоже, не ...
вопрос задан: 20 March 2018 14:35
1
ответ
Документ дизайна агента Scala 2.8? Akka разрабатывают документ?
Существует ли документ дизайна для агентов Scala 2.8, как он для 2,7? Агенты Scala: Объединение Основанного на потоке и Основанного на событии Программирования там один для Akka? "Библиотека Документов Улучшения Scala"...
вопрос задан: 28 May 2010 12:04
0
ответов
Акка Реквизит существующего Актера
Я новичок в мире Play / Akka / Actor. Я реализую сервис WebSocket, который ожидает получить реквизит от созданного актера. вернуть WebSocket.withActor (actorRef - > service.handle (...
вопрос задан: 30 June 2019 04:47
0
ответов
Настройки таймаута HttpClient Akka
Я пытаюсь реализовать HTTP-клиент в своем приложении Akka для использования стороннего API. Я пытаюсь настроить время ожидания и количество повторных попыток в случае сбоя. Это ниже ...
вопрос задан: 27 March 2019 20:51
0
ответов
Ошибка при попытке сделать постоянным действующим лицом требуемый почтовый ящик с обязательной очередью сообщений
Я пытаюсь следующее: класс ClientActor (stockActor: ActorSelection, paymentActor: ActorSelection) расширяет PersistentActor с AtLeastOnceDelivery с akka.actor.ActorLogging с ...
вопрос задан: 17 March 2019 23:16
0
ответов
Datadog представляет странную встречную строку Камона
Я использую Камона, чтобы собрать мои метрики, и Датадога, чтобы представить их. В своем приложении playframework я просто добавил счетчики для некоторого статуса, например: Kamon.metrics.counter ("status-counter", tags = Map ("status" ...
вопрос задан: 26 February 2019 21:56
0
ответов
Запуск задания в автономном режиме Apache Flink на Zeppelin У меня есть эта ошибка & ldquo; TooLongFrameException: скорректированная длина кадра превышает & ldquo;
Я пытаюсь запустить простую работу в Apache Flink с помощью Zeppelin. Я создал Docker-контейнер с запущенным zeppelin 0.8.0. В этом же контейнере у меня работает apache flink 1.6.1. Когда я бегу ...
вопрос задан: 18 January 2019 16:13
0
ответов
Регистрация в Akka вне Актера
У меня есть Актер Akka, который вызывает MyObject.foo(). MyObject не является Актером. Как мне настроить вход в него? С Актером все просто, потому что я могу просто микшировать ActorLogging. В MyObject я не...
вопрос задан: 18 April 2018 17:09
0
ответов
Заменить экземпляр объекта другим в C#
В этом вопросе я хотел бы узнать, если и как это возможно. Этот метод может показаться крайне плохой практикой, но похоже, что API (UnityEditor ), который я использую, делает что-то вроде...
вопрос задан: 11 September 2017 12:19
0
ответов
Загрузка файла с использованием Akka HTTP
Я пытаюсь реализовать функцию загрузки файлов в моем приложении, используя Akka HTTP. Я использую akka-stream версию 2.4.4. Вот код (измененный из akka-doc) путь ("fileupload") {post {...
вопрос задан: 14 August 2017 16:25
0
ответов
Хороший вариант использования для Akka [закрыто]
Я слышал много восторженных отзывов об инфраструктуре Akka (сервисной платформе Java / Scala), но до сих пор не видел много реальных примеров использования, для которых это было бы полезно. Так что мне было бы интересно услышать ...
вопрос задан: 23 July 2017 23:09
0
ответов
Как Scala достигает параллелизма?
Я беру курс по распределенным системам, и мы должны сделать наш проект, используя Scala. Наш инструктор сказал нам, что Scala хорош в том смысле, что он использует несколько ядер для вычислений и ...
вопрос задан: 11 July 2017 13:41
0
ответов
Высокочастотный трейдинг в JVM с помощью Scala/Akka
Давайте представим гипотетическую HFT-систему на Java, требующую (очень) малой задержки, с большим количеством недолговечных маленькие объекты несколько из-за неизменяемости (Scala?), тысячи подключений в секунду и...
вопрос задан: 23 May 2017 12:17
0
ответов
Должны ли мои актеры Akka' свойства будут помечены @volatile?
Этот вопрос похож на вопрос Должны ли мои актеры Scala' свойства будут помечены @volatile? но не уверен, что ответ будет таким же. Например, в случае, если был настроен диспетчер fork-join...
вопрос задан: 23 May 2017 12:16
0
ответов
Scala - перечисление против case-классов
Я создал актера под названием LogActor. Метод приема LogActors обрабатывает сообщения от других участников и регистрирует их до указанного уровня журнала. Я могу различить разные уровни ...
вопрос задан: 23 May 2017 12:10
0
ответов
Как мне настроить отказоустойчивость akka Actor?
Я пытаюсь добиться отказоустойчивого поведения в akka Actors. Я работаю над некоторым кодом, который зависит от того, чтобы Актеры в системе были доступны для длительной обработки. Я обнаружил, что мои ...
вопрос задан: 23 May 2017 12:01
0
ответов
Как реализовать запланированное задание на определенную дату в Play 2.0?
Где поддержка профессий в Play 2.0? Я прочитал эту ветку и нашел способ реализовать запланированные задания с интервалами, используя Global и Akka. Но до сих пор понятия не имею с запланированным заданием на ...
вопрос задан: 23 May 2017 11:51