Публикации по теме 'akka'


Доводы в пользу неблокирующего JDBC - Часть вторая
Задний план Это серия из трех частей Часть первая - нажмите на ссылку Часть вторая - эта страница Часть третья - обновление от начала 2021 года В первой части мы рассмотрели неблокирующие звонки и системы на основе событий. Разделы на этой странице Мы постараемся понять Java NIO на высоком уровне Мы объясним важность курсоров / соединений в базе данных. Мы сделаем аргумент в пользу неблокирования JDBC Java IO NIO и NIO2 Ключевые аспекты У Java IO был поток на..
Мониторинг приложений Akka с помощью Mesmer и OpenTelemetry
Мониторинг и наблюдаемость Термины «мониторинг» и «наблюдаемость» в последнее время часто используются в запутанных взаимозаменяемых контекстах. Они тесно связаны, но по существу подходят к проблемам с разных сторон. Короче говоря, мониторинг — это акт сбора данных, а наблюдаемость — это свойство (и мера https://en.wikipedia.org/wiki/Observability ) системы, которая позволяет нам делать выводы о внутреннем состоянии исключительно на основе внешний вывод. Можно сказать, что..

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

Как реализовать запланированное задание на определенную дату в Play 2.0?
Где поддержка заданий в Play 2.0? Я прочитал эту ветку и нашел способ реализовать запланированные задания через определенные интервалы с использованием Global и Akka. Но до сих пор понятия не имею о запланированном задании на определенную...
3531 просмотров
scala akka playframework-2.0
schedule 05.05.2024
Akka ZeroMQ — есть ли способ получить адрес сокета?
Предположим, что следующий фрагмент кода: class MQActor extends Actor { // Bind on port 0... Technically this should pick a free port val pubSocket = context.system.newSocket(SocketType.Pub, Bind("tcp://127.0.0.1:0")) def receive =...
854 просмотров
sockets port scala akka zeromq
schedule 27.11.2023
Параллельная обработка файлов в Scala
Предположим, мне нужно параллельно обрабатывать файлы в заданной папке. В Java я бы создал поток FolderReader для чтения имен файлов из папки и пул потоков FileProcessor . FolderReader считывает имена файлов и передает функцию обработки файлов...
5990 просмотров
scala actor akka
schedule 17.02.2024
Ошибка с маршрутами
Я новичок в игре, scala и akka, и я получаю сообщение об ошибке при использовании sbt для его сборки и компиляции путем загрузки localhost в веб-браузере. Ошибка в браузере, которую я получаю: Ссылка ошибки компиляции на маршруты неоднозначна; он...
1354 просмотров
routes scala model-view-controller akka playframework
schedule 13.03.2024
Акка с игровым фреймворком
все еще учусь осваивать akka java с игровым фреймворком. У меня есть фрагмент кода ниже. Он работал нормально, но решил дать некоторые головные боли. public class Application extends Controller { static ActorRef masterActor; RubineActor...
864 просмотров
java akka playframework
schedule 25.11.2023
akka Actors — Реализация рабочих процессов, действий или диалогов
Допустим, я хочу реализовать ProgrammableRemote в акке — ProgrammableRemote - WatchMovie 1. Tv ! PowerOn 1.1 Tv ! ChangeInput 3 2. DVD ! PowerOn 3. AVReceiver ! PowerOn 3.1 AVReceiver !...
905 просмотров
dialog workflow actor akka
schedule 17.03.2024
Scala - перечисление против классов случаев
Я создал акка-актера под названием LogActor. LogActors получает метод, обрабатывающий сообщения от других субъектов и регистрирующий их на указанном уровне журнала. Я могу различать разные уровни двумя способами. Первый: import LogLevel._...
6639 просмотров
enums scala actor case-class akka
schedule 05.03.2024
странное сообщение об ошибке: неверная символическая ссылка. Подпись в package.class относится к термину apache в package org, который недоступен.
Когда я попытался скомпилировать простую программу akka с безопасным типом (scala 2.10, akka, 2.1.0): scalac -cp "akka-actor_2.10-2.1.0.jar:akka-camel_2.10-2.1.0.jar" write2.scala error: bad symbolic reference. A signature in package.class...
24649 просмотров
scala akka
schedule 04.01.2024
Возникли проблемы с планировщиком Akka 2.1.2 («система» не распознана)
Я пытаюсь запустить очень простой цикл повторяющихся функций, согласно этим примерам: http://doc.akka.io/docs/akka/2.1.2/scala/scheduler.html Код: import akka.actor.Actor import akka.actor.Props import scala.concurrent.duration._ object...
6009 просмотров
scala akka
schedule 08.06.2024
Как использовать фьючерсы с Akka для асинхронных результатов
Я пытаюсь одновременно писать в несколько файлов, используя инфраструктуру Akka. Сначала я создал класс с именем MyWriter, который записывает в файл, а затем, используя фьючерсы, я дважды вызываю объект, прыгая, что для меня будут созданы 2 файла, но...
1018 просмотров
multithreading future scala actor akka
schedule 24.11.2022
Akka Microkernel на Heroku
У меня есть Akka 2.1.0, работающая на микроядре. На моей локальной машине я запускаю sbt dist для сборки exec, а затем cd target/dist и bin/akka sample.kernel.hello.HelloKernel . Heroku использует автоматическую команду sbt clean compile...
186 просмотров
heroku akka microkernel
schedule 14.03.2024
Ограничение количества потоков в фреймворке Play 2.1
Я использую Play 2.1 со Scala для непрерывного запуска нескольких тестов. Я делаю Future.traverse(tests)(test => Future(runTest(test)) . Я хочу ограничить количество параллельных тестов, поэтому я хочу ограничить количество потоков в...
1646 просмотров
scala akka playframework playframework-2.1
schedule 01.11.2022
Akka: Что происходит, когда вы говорите ActorRef, а он ожидает, что вы спросите?
У меня есть следующее: val future = myActor ? Message И в моем актере мое сообщение о получении имеет что-то вроде этого: sender ! Response Если я сделаю следующее и проигнорирую ответ, будут ли какие-либо негативные последствия?...
2848 просмотров
future scala actor akka
schedule 04.11.2022
Фьючерсы в Scala и Akka
Чем Scala Futures отличается от Akka Futures, один из них лучше другого? Концептуально они кажутся похожими, что упрощает неблокирующее асинхронное программирование.
451 просмотров
future asynchronous scala akka
schedule 21.10.2022
Тупик потока с play 2.2.1 и JPA
Я нахожу какое-то странное поведение с JPA. В некоторых случаях мы получили ошибку "Timed out waiting for a free available connection." at com.jolbox.bonecp.DefaultConnectionStrategy.getConnectionInternal(DefaultConnectionStrategy.java:88)...
805 просмотров
akka playframework playframework-2.0
schedule 27.09.2022
conf/reference.conf не работает в dist zip в Play 2.2.1 с Akka 2.2.3
Я пишу приложение P2P на Scala, которое работает в Play 2.2.1 с Akka 2.2.3. Когда я распространяю свой проект Play, my project/conf/reference.conf будет включен в dist zip. Это нормально. Затем я распаковал ZIP и перезаписал...
275 просмотров
scala akka playframework
schedule 02.12.2023
Как регистрировать все входящие сообщения от Akka (Java)
В Scala вы можете обернуть функцию получения с помощью LoggingReceive. Как добиться того же от Java API? def receive = { LoggingReceive { case x ⇒ // do something } }
2214 просмотров
java scala actor akka
schedule 30.01.2024
Контроль появления актеров в Akka, которые потребляют заметное количество памяти
Я построил распределенную модель потокового машинного обучения, используя модель актера akka. Обучение модели происходит асинхронно путем отправки экземпляра обучения (данные для обучения) актеру. Обучение на этих данных занимает время вычислений и...
791 просмотров
machine-learning concurrency scala akka
schedule 24.12.2023
Исключения сломанных каналов от клиента Redis Jedis
У нас есть вызовы клиента Redis из приложения Play Framework. Эти вызовы Redis выполняются от Актера с использованием Akka Schedular. Этот планировщик запускается каждые 60 секунд, что делает вызовы Redis вместе с другими вызовами JDBC. После того,...
5200 просмотров
redis scala akka playframework jedis
schedule 25.12.2023
Что означает стрелка тильды в этом контексте?
Это код с https://github.com/eigengo/activator-spray-twitter/blob/master/src/main/scala/core/tweetstream.scala Что делает оператор ~>(тильда)? Я думаю, что это должен быть оператор HttpRequest, но я не смог найти такой оператор в API спрея. Я...
3672 просмотров
scala akka spray
schedule 29.03.2024