Topologías DRPC en Storm

Storm ofrece un tipo especial de Topología denominada Distributed Remote Procedure Call (DRPC).

Estas topologías permiten ejecutar Remote Procedure Calls (RPC)usando las capacidades distribuidas de Storm.

Para ejecutar estas RPCs Storm ofrece un Servidor DRPC que actúa como conector entre el Cliente y la topología Storm: es por tanto una fuente para los spouts, recibe la función a ejecutar y sus parámetros.

· Para cada pieza pasada a este Servidor este asigna un Request ID para identificar la petición RPC.

· Cuando la topología ejecuta el último Bolt emite el RPC Request ID y el resultado para que el servidor DRPC devuelva el resultado al cliente.

· Un Servidor DRPC puede ejecutar muchas funciones, cada una tiene un nombre único.

· El Servidor DRPC expone un API Thrift que puede ser usados por muchos lenguajes.

Storm ofrece además una abstracción para ayudar a crear topologías DRPC, esta topología crea DRPCSpouts que conectan con los servidores DRPC y emiten datos. Todos los Bolts en esta topología se ejecutan en orden secuencial.