Hai, miliki konfigurasi typesafe di bawah ini dalam file application-typed.conf. akka { loggers = ["akka.event.slf4j.Slf4jLogger"] loglevel = "DEBUG" logging-filter = "akka.event.slf4j.Slf4jLoggingFilter" actor { provider = "local" } } custom-th....
6 Mei 2021, 23:33
Saya memiliki sejumlah kecil aktor (ditulis dalam Java, menggunakan API yang diketik Akka), yang menggunakan TimerScheduler untuk menjadwalkan pesan ke diri mereka sendiri. Saya ingin menulis tes yang memeriksa interaksi mereka. Saat menggunakan ActorTestKit disarankan dalam dokumentasi a>, ia dapa....
3 Mei 2021, 01:21
Pertanyaannya cukup jelas. Saat ini webapp saya sedang membuat sistem aktor di startup, dan menelurkan beberapa aktor tingkat atas menggunakan SpawnProtocol. Selain itu, startup juga dapat mengirim beberapa pesan ke aktor-aktor ini selama start up. Saat membuat aktor tingkat atas, akka mengembalika....
20 Maret 2021, 17:35
Saya mencoba ask aktor yang akan membalas dengan Coba: val reply = actor.ask[Try[MyReply]](MyCommand) Namun ketika balasan datang dari aktor di node lain di cluster saya mendapatkan kesalahan berikut di log: Failed to serialize message [scala.util.Success]. Cukup menarik, jika saya menggunakan Opt....
8 Desember 2020, 18:42
Judul cukup jelas, saya ingin dapat mengirim pesan ke aktor induk (artinya saya ingin ActorRef orang tua). Di Akka Classic (tidak diketik), ActorRef untuk aktor induk dapat diperoleh dari ActorContext anak melalui: context.parent (lihat, misalnya, pertanyaan ini (di Jawa)). Namun, akka.actor.typ....
7 Desember 2020, 04:40
Bisakah seseorang membagikan contoh logging yang diketik akka minimal? Di akka classic saya menggunakan LoggingReceive dan mengatur di src/main/resources/application.conf akka { loglevel = DEBUG actor { debug { receive=on } } } Tapi di Akka diketik saya tidak jelas apa yang har....
4 Desember 2020, 02:06
Kode ini dari dokumentasi akka. Ini mengimplementasikan aktor menggunakan gaya fungsional yang direkomendasikan: import akka.actor.typed.Behavior import akka.actor.typed.scaladsl.ActorContext import akka.actor.typed.scaladsl.Behaviors object Counter { sealed trait Command case object Increment....
23 November 2020, 19:55
Pada JVM yang sama dari kode contoh Akka dapat kita atur "replyTo" via context.self. final case class Greet(whom: String, replyTo: ActorRef[Greeted]) Tetapi untuk dapat menangani aktor di JVM lain, apakah saya mengharapkan ActorRef seperti: Actor[akka://shakto@172.31.19.110:25520/user/supervisor#....
3 September 2020, 15:02
Apa praktik yang diterima untuk menerapkan batasan modul antara kelompok aktor dalam tipe akka? TL/DR Berikut repo kerja dari contoh di bawah ini. Bagaimana cara mengimplementasikan satu aktor yang menerima pesan (pra-) yang ditentukan dalam dua protokol berbeda, analog dengan mengimplementasikan d....
10 Juli 2020, 21:25
Perhatikan diagram berikut: Dalam skenario ini kami memiliki dua Manajer. ManagerA dan ManagerB, keduanya dilahirkan oleh ayah yang sama pada waktu yang sama. ManagerB juga segera memunculkan 3 anak yang mulai memproses beberapa data. Ketika pekerja selesai memproses dan mendapatkan hasilnya, di....
7 Juli 2020, 14:46
Saya mencoba mempelajari aliran akka menggunakan akka yang diketik, dokumentasinya agak abstrak ketika menyangkut akka yang diketik Sink.actorRefWithBackpressure contohnya cukup mudah dan mudah dipahami dimana sebagai ActorSink.actorRefWithBackpressure contoh abstrak Dalam contoh pertama kami memi....
18 Juni 2020, 15:47
Saya baru di aliran akka dan akka mengetik kode saya berfungsi dengan baik dengan akka klasik di sini adalah apa yang saya lakukan class FlowActor extends Actor{ val log = LoggerFactory.getLogger(this.getClass) def receive: Receive = { case word: String => val replyTo = word.capitaliz....
16 Juni 2020, 15:01