java – Akka和Spring集成

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了java – Akka和Spring集成，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含4507字，纯文字阅读大概需要7分钟。

内容图文

我想让akka使用spring应用程序.这是一款完全符合akka模型的搜索应用程序.关于此集成的大多数在线示例和类型安全示例都讨论了使用akka扩展来注入spring应用程序上下文.但是,它们都使用ActorSystem.actorOf()方法来创建已知昂贵操作的actor.

ActorSystem system = ctx.getBean(ActorSystem.class);
system.actorOf(.....)

见 – https://github.com/typesafehub/activator-akka-java-spring/blob/master/src/main/java/sample/Main.java

我想使用actor来处理每个通过身份验证的Web请求.使用上面的代码,我将最终为每个不理想的请求创建root actor.

任何指针都会非常感激.

解决方法:

下面没有回答原始问题,这个问题是关于减少通常在请求进入Web应用程序时需要创建的新actor的数量.

要使用Akka路由器,它可以像下面的代码一样简单：

getContext().actorOf(SpringExtProvider.get(getContext().system()).props("AnotherActor.").withRouter(new RoundRobinPool(100)), "another");

Akka文档提供了有关配置的更多细节,但值得一看http://doc.akka.io/docs/akka/snapshot/java/routing.html.最好通过Akka配置文件定义它们的行为,而不是硬编码到应用程序中.你可以这样称呼它：

getContext().actorOf(SpringExtProvider.get(getContext().system()).props("AnotherActor.").withRouter(new FromConfig()), "another");

..并在application.conf文件中定义路由器的类型和行为.

如果您还没有考虑过它,那么还有必要查看如何使您的Web重新请求异步.一种方法是使用Spring的DeferredResult并将其实例传递给您的actor,并在完成搜索请求时设置结果.

– 更新20 / 11–

我认为为什么演员选择不适合你是因为你试图使用bean名称,而不是演员名称作为演员选择的pacth.在创建路由器时,您没有指定一个actor名称,所以Akka会在内部给它一个名字,比如“$a”.

为了说明,如果你创建你的演员：

actorSystem.actorOf(this.get(actorSystem).props(applicationContext, "bean_name"), "actorName");

然后你应该能够执行一个演员选择：

actorSystem.actorSelection("actorName");

或者创建上面的路由器actor一次,然后在每个对Spring MVC Web服务的请求中重用它,你可以在Spring @Configuration类中创建它,并将ActorRef作为bean公开,这样你就可以注入你的Spring @Controller类.以下是我创建的内存的快速示例,因此请确保它已经过测试/编译等.

@Configuration
public class Config {

   @Autowired
   private ActorSystem actorSystem;

   @Bean(name = "routerActorRef")
   public ActorRef routerActorRef() { 
      getContext().actorOf(SpringExtProvider.get(actorSystem).props("AnotherActor").withRouter(new RoundRobinPool(100)), "another");
   }

}

然后你可以通过写下这样的东西将它注入另一个Spring bean：

@Autowired
@Qualifier("routerActorRef")
private ActorRef routerActorRef;

应该注意的是,这对于顶级演员来说才真正可行,对于较低级别的演员来说这是可能的,但是有效管理会变得非常棘手.

– 原始答案 –

您链接到的Main方法中的示例显示了如何创建初始顶级actor,该actor将由基于系统的“user”actor监督.这是一个非常简单的示例,演示如何创建一个名为CountingActor的Spring托管actor,其中注入了一个名为CountingService的Spring托管bean.

为了进一步采用这个例子,你可以定义另一个类似于CountingActor的actor,例如

@Named("AnotherActor")
@Scope("prototype")
class AnotherActor extends UntypedActor {

  // the service that will be automatically injected
  final AnotherService anotherService;

  @Inject
  public AnotherActor(@Named("AnotherService") AnotherService anotherService) {
    this.anotherService = anotherService;
  }    

  @Override
  public void onReceive(Object message) throws Exception {
    if (message == "doSomething") {
      anotherService.doSomething();
    } else {
      unhandled(message);
    }
  }
}

我假设有另一个名为AnotherService的Spring服务bean,它有一个方法doSomething(),它将在创建AnotherActor时注入.

然后在CountingActor中你可以像这样创建AnotherActor：

@Named("CountingActor")
@Scope("prototype")
class CountingActor extends UntypedActor {

  public static class Count {}
  public static class Get {}

  // the service that will be automatically injected
  final CountingService countingService;

  @Inject
  public CountingActor(@Named("CountingService") CountingService countingService) {
    this.countingService = countingService;
  }

  private int count = 0;

  @Override
  public void onReceive(Object message) throws Exception {
    if (message instanceof Count) {
      count = countingService.increment(count);
      // Create AnotherActor here as a child of CountingActor by using the CountingActor's context
      ActorRef anotherActor = getContext().actorOf(SpringExtProvider.get(system).props("AnotherActor"), "another");
      anotherActor.tell("doSomething", getSelf());
    } else if (message instanceof Get) {
      getSender().tell(count, getSelf());
    } else {
      unhandled(message);
    }
  }
}

这里的actor创建和主要的主要区别是使用getContext().actorOf(…)而不是system.actorOf(…).使用getContext()会将新actor创建为CounterActor的子级,而不是顶级“user”actor.

在Akka官方文档中有一个很好的描述这种行为：http://doc.akka.io/docs/akka/snapshot/java/untyped-actors.html#creating-actors-with-props

内容总结

以上是互联网集市为您收集整理的java – Akka和Spring集成全部内容，希望文章能够帮你解决java – Akka和Spring集成所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端