Публикации по теме 'akka'
Как создать Актера в Акке
В Scala мы можем создать Актера, расширив класс akka.actor.Actor и написав метод получения в этом классе. Обычно мы пишем метод получения, используя оператор case, который позволяет актору отвечать на различные типы получаемых им сообщений.
давайте сначала создадим проект, используя имя SBT HelloAkka. Давайте определим информацию о нашем необходимом преобразователе и преобразователе зависимостей в файле build.sbt, который выглядит следующим образом.
имя := «Привет Акка»
версия :=..
Тур к актеру Akka внизу
Akka Actor - это среда параллелизма, построенная на Scala и Java, цель которой - предоставить простую и понятную абстракцию для моделирования ваших компонентов, отделяя многопоточность от бизнес-логики.
С помощью Akka Actor вы можете моделировать свои компоненты естественно и просто, точно так же, как проектируете роль в реальном мире, которая может получать набор определенных сообщений, реагировать на каждое сообщение соответственно и, при необходимости, отправлять одно или несколько..
Вопросы по теме 'akka'
Akka супервайзер, управляющий супервайзерами
Я полагаю, что здесь может быть более широкий вопрос о разработке приложений с использованием Akka, но я спрошу, как настроить дерево наблюдения, где «ядро» или «верхний» руководитель может контролировать детей, которые являются другими...
1533 просмотров
schedule
06.11.2022
Чем отличается реализация нескольких акторов в Scala?
С выпуском Scala 2.9.0 был также анонсирован Typesafe Stack, который объединяет язык Scala с фреймворком Akka. Теперь, хотя в стандартной библиотеке Scala есть акторы, Akka использует собственную реализацию. И, если мы поищем другие реализации, мы...
7222 просмотров
schedule
28.03.2022
Ошибки при компиляции кода AKKA под 2.7.7
Я очень новичок в scala. Итак, я загружаю исходный код AKKA и устанавливаю плагин для eclipse (2.7.7 final). Когда я открываю проект, он показывает 29 ошибок компиляции. Я знаю, что это может быть несоответствие версии или проблема с настройками...
181 просмотров
schedule
17.08.2023
Как создать scala.collection.immutable.Seq из списка Java в Java?
Я пытаюсь заставить Akka работать в моем проекте Java, и я застрял на небольшой проблеме с типом (ами) Seq из Scala. Я могу преобразовать свой Java-список ActorRef в scala.collection.Seq, но API Akka, который я пытаюсь использовать, требует...
25547 просмотров
schedule
03.05.2022
Получить параметры формы из почтового запроса, используя спрей/скала
Я действительно новичок во всем этом Scala/Spray. После некоторого тестирования мне удалось получить параметры из запроса Get с помощью функции параметров. Однако я пытаюсь получить некоторые параметры, отправленные из запроса POST в теле запроса....
7127 просмотров
schedule
08.10.2022
Отвечаете удаленному клиенту только через ответ?
Согласно документации по актору akka, можно ответить, используя self.channel ! Message , поэтому код будет работать локально. Я хотел бы сделать то же самое с удаленными актерами.
У меня есть:
class ServerActor extends Actor {
def...
439 просмотров
schedule
10.06.2022
Akka TypedActor с абстрактными членами из типажа вызывает java.lang.AbstractMethodError
Учитывая следующий код:
import akka.actor._
object TraitTest {
trait A {
def something()
}
trait B extends A
class C extends TypedActor with B {
override def something() {
println("Why am I not implemented?")
}
}...
469 просмотров
schedule
14.07.2023
Сканирование актеров Akka
У меня есть узел, на котором может быть запущено несколько экземпляров сервера (удаленный актер Akka). Я хотел бы, чтобы клиенты могли сканировать диапазон портов на заданном узле в поисках работающих серверов.
Я написал этот метод в своем...
432 просмотров
schedule
12.05.2023
Поддержка платформы Akka для поиска повторяющихся сообщений
Я пытаюсь построить высокопроизводительную распределенную систему с Akka и Scala.
Если приходит сообщение с запросом на дорогостоящее (и свободное от побочных эффектов) вычисление, а точно такое же вычисление уже было запрошено ранее, я хочу...
1330 просмотров
schedule
21.11.2022
Составление поведения признаков в Scala в методе получения Akka
Рассмотрим эти две черты:
trait Poked extends Actor {
override def receive = {
case Poke(port, x) => ReceivePoke(port, x)
}
def ReceivePoke(port: String, x: Any)
}
trait Peeked extends Actor {
override def receive = {
case...
4481 просмотров
schedule
29.12.2023
Сжатие больше не поддерживается в Akka 2.0?
Я использовал сжатие zlib для сообщений в Akka 1.3. Сейчас я перехожу на Akka 2.0 RC2, и кажется, что сжатие сообщений больше не упоминается в документации Akka (для Akka 2.0 RC2).
Означает ли это, что сжатие сообщений больше не поддерживается в...
425 просмотров
schedule
24.06.2023
Блокировка ввода-вывода в Akka
В последнее время я использую Akka и задаюсь вопросом: могу ли я заблокировать ввод-вывод в Akka, не создавая больших проблем? Допустим, у нас есть Actor, который выполняет некоторую блокировку ввода-вывода, потому что он использует устаревшую...
2842 просмотров
schedule
15.09.2022
перегрузка конструктора класса case с неявным параметром?
Я пытаюсь определить класс case с некоторыми параметрами, которые имеют значение по умолчанию, но для значения по умолчанию требуется неявный параметр. Я пробовал что-то вроде этого:
case class ChannelLatches(started: TestLatch, stopped:...
2170 просмотров
schedule
02.07.2023
Тайм-аут Akka FSM из-за меры, которая не является временем (в Scala)
Я пытался использовать FSM в Akka для моделирования состояний протокола (рукопожатие, передача, декодирование полезной нагрузки...). Я хочу определить что-то вроде тайм-аута, но с точки зрения «обработанных байтов» (например, если я остаюсь в том же...
336 просмотров
schedule
25.10.2022
Странное поведение try/catch со Scala + Akka
Я пытаюсь использовать Akka для реализации TCP-сервера для пользовательского протокола приложения. Я пытаюсь следовать приведенному здесь примеру: http://doc.akka.io/docs/akka/2.0/scala/io.html для выполнения неблокирующего ввода-вывода внутри...
1168 просмотров
schedule
07.07.2022
Акка Логинг вне актера
У меня есть Akka Actor, который звонит MyObject.foo() . MyObject не актер. Как мне настроить Вход в систему? С Актером это просто, потому что я могу просто подмешать ActorLogging. В MyObject у меня нет доступа к context.system. Могу ли я...
11700 просмотров
schedule
04.04.2022
Akka: Как запланировать повторные попытки при сбое с растущими интервалами задержки?
Каков хороший способ заставить актера повторить что-то в случае неудачи, но с увеличивающимися временными интервалами между повторными попытками? Скажем, я хочу, чтобы актер повторил попытку через 15 секунд, затем через 30 секунд, затем каждую минуту...
5706 просмотров
schedule
29.04.2023
Проверка доступности удаленного актера Akka
Как я могу проверить, жив ли удаленный актор, для которого я получил actRef через ActorFor? Буду признательна за любую ссылку на документацию. Я использую Akka из Scala.
Я видел ссылки на супервайзеров и Deathwatch, но на самом деле не чувствую,...
4110 просмотров
schedule
27.12.2022
по запросу актор получить или создать
Я могу создавать актеров с помощью actorOf и смотреть их с помощью actorFor . Теперь я хочу получить актера с помощью некоторого id:String , и если он не существует, я хочу, чтобы он был создан. Что-то вроде этого:
def getRCActor(id:...
6184 просмотров
schedule
04.04.2022
Akka Scheduling в Heroku с Play 2 Framework
Я не могу заставить метод расписания Akka работать должным образом в Heroku. Он отлично работает локально и распечатывает «Heartbeat» в журнале.
Вот этот файл: https://github.com/magnusart/actor-test/blob/master/app/Global.scala и фрагмент ниже....
1109 просмотров
schedule
24.11.2022
