A client sends the DRPC server the name of the function to execute and the arguments to that function. The topology implementing that function uses a DRPCSpout to receive a function invocation stream from the DRPC server. Each function invocation is tagged with a unique id by the DRPC server. The topology then computes the result and at the end of the topology a bolt called ReturnResults connects to the DRPC server and gives it the result for the function invocation id. The DRPC server then uses the id to match up that result with which client is waiting, unblocks the waiting client, and sends it the result.
DRPC topologies type
- Linear DRPC topologies:
LinearDRPCTopologyBuilderat org.apache.storm.drpc - Non-linear DRPC topologies:
CoordinatedBoltat org.apache.storm.coordination
DRPC usage
-
Launching a DRPC server can be done with the storm script and is just like launching Nimbus or the UI:
1bin/storm drpc -
Configuring this through the
storm.yaml:123drpc.servers:- "drpc1.foo.com"- "drpc2.foo.com" -
Launching DRPC topologies using StormSubmitter:
12StormSubmitter.submitTopology("exclamation-drpc", conf,builder.createRemoteTopology());
See more in Apache Storm DRPC
近期评论