最近一直都在看徐鹏写的《hadoop 2.X HDFS源码剖析》的第二章关于RPC的部分，表示java这块的编程功底差的实在是太多了，动态代理勉强还算明白，proto buffer、nio还有java的annotation差的实在太多了，好多地方都看得不是很懂。决定暂时放下这块，把整本书看完再多写几篇关于hadoop RPC的文章了。但是还是写一写最近的读书笔记吧。
RPC全名remote procedure call，即远程调用，就像生产上经常用的dubbo一样，本地进程通过RPC可以像调用本地方法一样调用远程的服务。
下面通过介绍一个自认为比较完整的RPC流程，谈谈自己对hadoop RPC 的理解：
1.首先定义好通信两端的协议（protocol），其实就是定义好调用的接口，这样调用者（client）可以知道，应该通过什么样的函数，传递什么样的参数来发起一个RPC请求，既然是通过网络传输到另一个jvm，那么就需要进行一次序列化，这里hadoop RPC的实现支持多种序列化，有自身提供的序列化方法跟proto buffer的序列化方法，听说还可以支持其他的序列化方法，例如namenode 与 客户端通信的ClientProtocol就是使用的后者；
2.Client端有一个叫做server的ClientNameNodeProtocolTranslatorPB实例，这个类“实现”了ClientProtocol，其实就是将不支持proto buffer的ClientProtocol，转化成了支持这种序列化方式的ClientNamenodeProtocolPB协，当然这中间涉及到了很多动态代理，过程十分复杂，现在也看的不是很懂；
3.请求不会这么简单的发送出去，从hadoop2.X开始namenode就支持高可用了，所以server对象在实例化的时候就要根据配置文件，考虑是否支持高可用，其实就是在active namenode失效的时候可以主动failover到standby 的namenode上，向备用的namenode发送RPC请求；
4.既然请求是序列化过了的，通过socket传输，到了Server端，肯定就要有一次反序列化的过程，就是讲ClientNamenodeProtocolPB协议转化为对应的ClientProtocol协议，然后在调用真正实现了ClientProtocol接口的NameNodeRPCServer的对应方法进行需要的操作，这里Server端使用了nio的编程方式来处理RPC请求。感觉所谓nio就是有一些监听进程在监听连接事件，然后将PRC请求放入一个队列，接着又有很多handler处理队列中的RPC请求，当然为了网络传输，所有handler的执行结果都是由一个Responder进程完成的。
以上就是对一次RPC目前能够做的尽可能详细的分析了，下面配上一副自己的画的图：
基础差太多，写的很渣，希望以后能够来打自己的脸吧！
2017.2.13
今天二逼节，明天虐狗节，学得又很渣，不开心￣へ￣
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
