2015-03-20 25 views
5

Klasik programlamada, gözlemcilerle ilgili değişiklikleri bildirmek istiyorum.Akka ile aktörler arasındaki iletişim gibi bir gözlemci nasıl oluşturulur?

Akka'da eşdeğer desen nedir?

Kullanım örneği:

  • Bir aktör (PropertyServiceActor) okuma ve önbelleğe alma özellikleri
  • Farklı aktörler PropertyServiceActor
  • bir özellik değişirse için kayıt olabilirsiniz DB oluştururlar, PropertyServiceActor kayıtlı aktörleri bildirir değişiklikle ilgili

cevap

5

BroadcastGroup

01 bir göz atın
//Create group 
val paths = List("/user/workers/w1", "/user/workers/w2", "/user/workers/w3") 
val observers: ActorRef = context.actorOf(BroadcastGroup(paths).props(), "observers") 

Tüm gözlemcileri bilgilendirmek için sadece observers ActorRef'e mesaj gönderin. Ayrıca, akka.routing.AddRoutee ve akka.routing.RemoveRoutee göndererek gözlemcileri ekleyebilir ve kaldırabilirsiniz.

Diğer routing belgelerini de bulabilirsiniz.

İlgili konular