前边我们基Hadoop实现了RPC，下面将一下Storm中的DRPC

DRPC：分布式RPC，Storm中的DRPC是使用Storm实时并行计算真正强大的函数，Storm拓扑作为输入接收函数参数流，并为每个函数调用发出结果的输出流

DRPC不是Storm的一个特征，因为它是Storm的streams spouts bolts和topologies表示的模式，DRPC本可以打包成Storm独立的库，但它与Storm捆绑在一起非常有用

分布式RPC由“DRPC服务器”协调，DRPC服务器协调接收RPC请求，将请求发送到Storm拓扑，从Storm拓扑接收结果，并将结果发送回等待的客户端，从客户端的角度来看，分布式RPC调用看起来就像常规的RPC调用

如下图所示：



客户端向DRPC服务器发送要执行的函数的名称以及该函数的参数，实现该功能的拓扑使用DRPCSpout从DRPC服务器接收功能调用流，每个函数调用都由DRPC服务器标记为唯一ID，然后拓扑计算结果，并在拓扑结束时调用一个bolt ReturnResults连接到DRPC服务器并为其提供函数调用id的结果，然后，DRPC服务器使用id来匹配客户端正在等待的结果，取消阻塞等待的客户端，并将结果发送给它
---------------------
作者：ysjh0014
来源：CSDN
原文：https://blog.csdn.net/ys_230014/article/details/84073172
版权声明：本文为博主原创文章，转载请附上博文链接！