¿Cuál es la mejor manera de implementar un protocolo de solicitud/respuesta utilizando akka y scala?

Question

He estado estudiando cómo podría desarrollar una arquitectura distribuida que implemente la solicitud/respuesta de protocolo utilizando el concepto de concurrencia a través de actores.

Llegué a la conclusión de que la mejor manera de hacerlo es creando un sistema de respuesta con manejo sincrónico de futuros/promesas, y poco después de la respuesta, dejando un canal abierto para recibir notificaciones.

Por lo tanto, una arquitectura que funcionaría exactamente como un mensaje de la bandeja de entrada.

Tiene algunos problemas.

Por lo tanto, tendría que mantener dos puntos finales (actores en las dos capas)?

El problema: El módulo de vista solicita que se procese un elemento en particular. Ella envía este comando para ser procesado a través de RemoteActor en el servidor de aplicaciones. Este servidor debe devolver inmediatamente la promesa de que le notificará cuando se procese el elemento. Después de esto, el módulo de vista estará esperando la notificación de finalización del procesamiento.

¿Cómo ves este problema?

Estoy usando Scala, Akka y Google Guice.

Creo que es un problema genérico que cualquiera puede hacer uso de sus soluciones. Disculpe si estoy lastimando los términos del sitio de stackoverflow.

Gracias de antemano

Answer 1

no quiero distraer la atención de cualquier buenas respuestas que puede conseguir en Akka, porque por desgracia no sé mucho acerca de Akka y se distribuye actores características, pero me gustaría pregunta si has considerado alguna alternativa.

Parece que básicamente necesita una biblioteca RPC asíncrona. Hay dos poderosas bibliotecas escritas en Scala que sé que pueden satisfacer sus requisitos: http://sna-projects.com/norbert/ y http://twitter.github.com/finagle/. Finagle ofrece algunos combinadores realmente potentes para expresar dependencias de cómputo asíncronas y registrar oyentes en futuros. Actualmente estoy manteniendo Norbert, que utilizamos en LinkedIn para algunos de nuestros sistemas distribuidos, como la búsqueda.

Answer 2

//On "server" node 
class SomeActor extends Actor { 
    def receive = { 
    case messageToRemoteActor => self reply_? TypeOfResponseMessage() 
    } 
} 

Actor.remote.register("myRemoteActor", actorOf[SomeActor]) 

//On "client" node 
val remoteActor = Actor.remote.actorFor("myRemoteActor", "hostnameOrIpOfNodeContainingTheActorAbove", port) 

val f: Future[TypeOfResponseMessage] = remoteActor !!! messageToRemoteActor 

f.onComplete(_.value.get match { 
    case Left(exception) => handle(exception) 
    case Right(result) => handle(result) 
}) 

Answer 3

¿Por qué no usar solo uno de los enchufes REQ-REP de 0MQ?

https://github.com/zcox/akka-zeromq-java

esa manera a resolver su problema inmediato y, al mismo tiempo, aprender de comenzar una arquitectura que le llevará un largo camino y es compatible con las comunicaciones con los clientes escritos en muchos idiomas.

Para un ejemplo de que esto podría conducir vistazo a http://blog.getintheloop.eu/2009/05/22/lift-amqp-with-rabbitmq-and-scala-tutorial-and-screencast/

en cuenta que estoy NO lo que sugiere que utilice AMQP hoy, ya que un corredor RabbitMQ pueden ser excesivos para su problema inmediato. Más bien, sugiero que invierta su tiempo en utilizar una arquitectura (generación de mensajes) que le pague dividendos a largo plazo.