我正在使用Scalatra构建一个REST服务端点,当被调用时,它将从多个源中提取图像,操纵它们并返回它们.这可能是一个相当长的运行过程,并且可能会更长,然后单个http请求/响应周期可以接受.

我的想法是,当调用时,我将启动一堆akka Actors来提取图像资源,让他们将结果交给Image处理Actors进行扩展等.初始请求本身会立即返回某种形式处理ID,可用于对后续轮询调用另一个端点,该端点将在处理结果时返回结果,并带有一个标志,用于确定是否有更多结果可供客户端知道停止轮询.

我的问题如下：

>从设计的角度来看,这是否有意义？
>如果我使用这种方法,那么检索已处理图像的每个后续请求都必须具有某种状态感知,以便知道客户端已经接收了哪些图像.你会如何管理这种状态？
>我从来没有看过这个,但是在这种情况下,长时间运行的彗星风格的HTTP请求会比轮询更有意义吗？

实施部分

假设我最终得到了类似于上面的设计,我对Scalatra& amp; Akka(或任何演员范例)和我有几个问题.

好的,第一个是我认为的Scala / Scalatra特定问题.好的,我查看了akka http://www.scalatra.org/guides/async/akka.html上的Scalatra文档,在这个例子中,他们设置了应用程序引导程序,如下所示：

// Get a handle to an ActorSystem and a reference to one of your actors
  val system = ActorSystem()
  val myActor = system.actorOf(Props[MyActor])

  // In the init method,mount your servlets with references to the system
  // and/or ActorRefs,as necessary.
  override def init(context: ServletContext) {
    context.mount(new PageRetriever(system),"/*")
    context.mount(new MyActorApp(system,myActor),"/actors/*")
  }

我假设scalatra的bootstraping在应用程序启动时发生一次,system.actorOf(Props [MyActor])是否为每个请求创建一个实例或一个实例？

其次,说我的MyActor类(或更明智的名字)做了以下事情：

class MyActor extends Actor {
  def receive = {
    //Find the [ImageSearchingActor] actor in akka registry and send search message
    case initiateSearchRequest: InitiateSearchRequestMessage => TODO

    //Find free [ImageProcessingActors] in akka registry and send each Image url to process  
    case imageInformationFound : ImageInformationFoundMessage => TODO

    //Persist the result to a cache,or data store with the ProcessingId that all message will pass  
    case imageProcessed : ImageProcessedMessage =>  TODO
  }
}

现在,在这种情况下,多个地方我将检索图像,因此几个Actors将抓取这些数据.当他们找到合适的图像时,将使用几个Actors来处理图像.如果我使用我的设计,那么我需要标记某个地方,对于给定的ProcessingId,没有更多处理过的图像可用.这意味着我需要知道所有图像搜索和图像处理参与者何时完成给定的ProcessingId.我该怎么做呢？

所以这是一个很大的问题,消费的信息我希望它有意义.

干杯.克里斯.