| Blog信息 |
|
blog名称:
日志总数:1304
评论数量:2242
留言数量:5
访问次数:7625787
建立时间:2006年5月29日 |
| |
|
 [Apache(jakarta)]Hadoop系列－IPC之代码实现
软件技术
lhwork 发表于 2006/12/13 15:32:41 |
| * 整体结构：在IPC包中，最重要的3个类是Server，Client和RPC，它们具有层次化的结构。
1. RPC
类是对Server、Client的具体化。在RPC类中规定，客户程序发出请求调用时，参数类型必须是Invocation；从服务器返回的值类型必须
是ObjectWritable。为了加强理解，可以查看测试类TestIPC。在那里，规定的参数类型与返回值类型都是LongWritable。
2. RPC
类是对Server、Client的包装，简化用户的使用。如果一个类需充当服务器，只需通过RPC类的静态方法getServer获得Server实
例，然后start。同时此类提供协议接口的实现。如果一个类充当客户端，可以通过getProxy或者waitForProxy获得一个实现了协议接口
的proxy object，与服务器端交互。为了加强理解，可以查看测试类TestRPC，在那里，实现的协议接口为TestProtocol。
* Server类
1.
启动Listener进程。如果收到需要建立连接的请求，将建立连接，然后在上面捕获读操作的命令。收到命令之后，将把解析客户端发过来信息的工作委派给
Connection。Connection把信息封装到Call对象中，放入队列中，待Handler处理。
2. 启动指定数目的Handler线程，处理客户端对指定方法调用的请求，然后把结果返回给客户端。
* Client类
1. 用Call封装好调用信息，然后借助从连接池中取出的Connection向服务器端发送，等待结果。如果到指定服务器的Connection不存在，将马上建立。Connection线程读取服务器方法调用的返回信息。完成之后，通知主线程。
* RPC类
1. 对外使用的窗口，隐藏了Server和Client的背后细节，验证RPC协议版本。
BTW:http://asmallbird.blogspot.com/ |
|
|