akka

4ısı

1cevap

Akka Streams kullanarak basit bir TCP protokolü nasıl uygulanır?

Akka Streams ile mesaj alışverişi yapmak için basit bir TCP-tabanlı protokolün uygulanmasında bir saplama yaptım (aşağıya bakınız). Ancak, gelen iletilerin hemen işlenmemiş gibi görünüyor; yani iki me

1ısı

1cevap

GraphStage ile denetim stratejisini kullanmıyor

Denetim durumlarını kullanarak kurtarmaya çalışıyorum, harita kullanarak Akış aşamaları yazdığımda çalışır, ancak grafik aşamasını kullanırsam, hiçbir zaman yakalanmaz ve tüm boru hattı başarısız olur

0ısı

1cevap

Aktör Kalıbı (Akka.Net) - Aktörler Sabitler veya Dinamik olmalı

Aktörlerim için ne kullandığınıza karar vermem arasında karışıklık var. Çalışan Yönetim Sistemi ( 1Multiple çalışanlar) yapıyorum diyoruz. 2.Her birinin her gün çalışmaya gelmesi beklenir. 3.İşletmeni

2ısı

1cevap

Akka Aktör isTerminated Sadece bir aktör belirli koşullar altında kapanır sağlamak için bir birim testi yazma

kullanımdan kaldırıldı, bu yüzden bir test gibi vardır: Ben isTerminated kullanımdan kaldırıldı belirten bir uyarı algılıyorum val tddTestActor = TestActorRef[MyActor](Props(classOf[MyActor], "param1"

2ısı

1cevap

Bu örnek için Akka Aktör Yolu

Java Play Framework kullanıyorum. İstemci sunucu etkileşimi için web yuvaları kullanıyorum. Sunucu tarafında, istemci isteğine yanıt veren aka aktörlerimiz var. Karşı karşıya olduğum sorun: İstemci, s

1ısı

1cevap

Neden bu inatçı aktör İşte

çalışma kodudur değildir: import akka.persistence._ import akka.actor.{Actor, ActorRef, ActorSystem, Props, ActorLogging} class Counter extends PersistentActor with ActorLogging { import Cou

1ısı

1cevap

Tam olarak ne akka.dispatch.Dispatcher $$ anon $ 1 nedir?

Uygulama sunucularımızdan biri bellek dolduğunda bir Java yığın dökümü analiz ediyordum. Eclipse Memory Analyzer kullanıyordum. Aşağıdakileri rapor etti. tarafından yüklenen "akka.dispatch.Dispatcher

2ısı

1cevap

Akka Uzak: otomatik oluşturulmuş bağlantı noktası olsun

Otomatik olarak oluşturulmuş bir bağlantı noktası olan bir Java istemcim var. Aktör sistemini başlattıktan sonra, limana erişmek istiyorum. [INFO] [03/31/2016 14:11:32.042] [main] [akka.remote.Remotin

3ısı

1cevap

Scala + Slick + MySQL + Akka + Aktarımı Kullanırken Karşılaşılan Sorun Sorun Giderme

Sorun Bildirimi: MySQL DB tablosunda belirli bir modül için kullanıcının tüm gelen istek parametrelerini satır olarak ekliyoruz (bu büyük bir veri). Şimdi, bu tablodan her kaydı okuyacak ve üçüncü tar

1ısı

1cevap

Scala Akka Streams Birleştirme Filtresi Ve Harita

Aşağıdaki Scala kodunu optimize etmenin herhangi bir yolu olup olmadığını merak ediyorum çünkü çok verimli görünmüyor. Temel olarak, Tweet olmayan herhangi bir nesneyi akıştan kaldırmak ve Any yerine