oyuncu ile guice enjeksiyonu kullanarak

Question

null işaretçisi atar Akka aktör olarak başlatılan bir sunucunun alan enjeksiyonu üzerine boş işaretçi istisnası alıyorum.

Schedular kısmı:

private ActorRef myActor = Akka.system().actorOf(
     new Props(Retreiver.class)); 

@Override 
public void onStart(Application app) { 
    log.info("Starting schedular.....!"); 
    Akka.system() 
      .scheduler() 
      .schedule(Duration.create(0, TimeUnit.MILLISECONDS), 
        Duration.create(30, TimeUnit.MINUTES), myActor, "tick", 
        Akka.system().dispatcher()); 

} 

Retreiver sınıfı kısmı:

public class Retreiver extends UntypedActor { 

private Logger.ALogger log = Logger.of(Retreiver .class); 

@Inject 
private myDataService dataService; 

@Override 
public void onReceive(Object arg0) throws Exception { 

    if (0 != dataService.getDataCount()) { 
    .... 
    .... 
    .... 
    } 

}

Ben DataService için boş alıyorum. Lütfen bana bu konuda tavsiyede bulunun.

Teşekkürler.

Answer 1

Akka, Retriever aktörünü değil Guice'yi başlattığınız için NullPointerException alıyorsunuz. Eğer örneğini oluşturmak ve sonra Akka için, IndirectActorProducer bunu elde yardımcı olabilir geçmek Guice almak gerekir, örneğin:

produce() zahmete çağrılır her zaman yeni bir Actor örneğini oluşturmalısınız

class RetrieverDependencyInjector implements IndirectActorProducer { 
    final Injector injector; 

    public RetrieverDependencyInjector(Injector injector) { 
     this.injector = injector; 
    } 

    @Override 
    public Class<? extends Actor> actorClass() { 
     return Retriever.class; 
    } 

    @Override 
    public Retriever produce() { 
     return injector.getInstance(Retriever.class); 
    } 
} 

Not olduğunu aynı örneği geri dönemez.

Ardından Akka, RetrieverDependencyInjector aracılığıyla aktör almak için alabilirsiniz mesela:

ActorRef myActor = Akka.system().actorOf(
    Props.create(RetrieverDependencyInjector.class, injector) 
); 

seni düşündüm

fazla yorum GÜNCELLEME, bir GenericDependencyInjector içine RetrieverDependencyInjector çevirmek mümkün olabilir Actor sınıfının bir yapıcı parametresi olarak olmasını sağlayarak, belki de aşağıdaki gibi bir şey yapmanıza izin verir:

Props.create(GenericDependencyInjector.class, injector, Retriever.class) 

Bunu denemedim, ancak size bir başlangıç ​​noktası verebilir. Bu ihtiyaç duyan herkes için

Answer 2

:

public class GuiceInjectedActor implements IndirectActorProducer { 

final Injector injector; 
final Class<? extends Actor> actorClass; 

public GuiceInjectedActor(Injector injector, Class<? extends Actor> actorClass) { 
    this.injector = injector; 
    this.actorClass = actorClass; 
} 

@Override 
public Class<? extends Actor> actorClass() { 
    return actorClass; 
} 

@Override 
public Actor produce() { 
    return injector.getInstance(actorClass); 
} 

}

VE

Akka.system().actorOf(Props.create(GuiceInjectedActor.class, INJECTOR,Retreiver.class)) 

sne bunu ... !!!

Answer 3

Orada, başka yollar olabilir, örneğin sen Boot statik enjektör kolu veya bazı-Enjektör-Tutucu-sınıfı koyabilirsiniz ve çağrı miras yöntemini aktör oluştururken enjekte Ön çalıştırma (

)

public class Retreiver extends UntypedActor { 

    private Logger.ALogger log = Logger.of(Retreiver .class); 

    @Override 
    public void preStart() { 
     super.preStart(); 
     Boot.injector.injectMembers (this); 
     //Some-Injector-holder.injectMembers (this); 
    } 

    @Inject 
    private myDataService dataService; 

    @Override 
    public void onReceive(Object arg0) throws Exception { 

     if (0 != dataService.getDataCount()) { 
     .... 
     .... 
     .... 
     } 
    } 

ve ayrıca, aynı zamanda UntypedActorFactory bir kapsamda enjektör tarafından aktörü başlatmak için aktör sağlayıcısı enjektörü enjekte edebilir ve asla bunun için herhangi bağlamalar yok

public class InjectingActorProvider implements Provider<ActorRef> { 
    @Inject 
    private Injector injector; 

    @SuppressWarnings("serial") 
    @Override 
    public final ActorRef get() { 
      Props props = new Props(new UntypedActorFactory() { 
       @Override 
       public Actor create() { 
        return injector.getInstance(actorClass); 
       } 
      }); 

      props = props.withRouter(...); 
      props = props.withDispatcher(...); 
      actor = system.actorOf(props, actorName); 
      return actor; 
    } 
}