[HBase] Hadoop RPC 动态代理
2013-01-29 20:50
316 查看
[HBase] Hadoop RPC 动态代理
分类:hadoop
HBase
Java 2013-01-29 20:50
174人阅读 评论(0)
收藏
举报
hadoopHadoophbaseHBASEHBaseproxyProxyRPCrpc动态代理
本文来自:逸情公子的博客http://weixiaolu.iteye.com/blog/1477774
前言:
最近一直在分析hadoop的RPC机制。在hadoop中,DataNode和NameNode之间的控制信息的交流是通过RPC机制完成的,采用的是动态代理和java NIO(参考博客:http://weixiaolu.iteye.com/blog/1479656 )
的方式。DataNode端是通过获得NameNode的代理,通过该代理和NameNode进行通信的,为了更好的分析hadoop的RPC机制我想先分析一下动态代理是怎么实现。下面就是动态代理的最最简单的代码实现,我们一起来看看吧。
代码如下:
[java]
view plaincopy
package rpc.proxy;
import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
/**
* 动态代理类使用到了一个接口InvocationHandler和一个代理类Proxy ,这两个类配合使用实现了动态代理的功能。
* 那么什么是动态代理呢?
* 我们平常说的代理类是指: 给每个具体类写一个代理类,以后要使用某个具体类时,只要创建它的代理类的对象,然后调用代理类的方法就可以了。
* 可是如果现在有许多的具体类,那就需要有许多的代理类才可以,这样很显然不合适。所以动态代理就应运而生了,我们只要写一个类实现
* InvocationHandler 并实现它的invoke方法,然后再用Proxy的工厂方法newProxyInstance()创建一个代理对象,这个对象同样可以实现对具体类的代理功能。
* 而且想代理哪个具体类,只要给Handler(以下代码中的Invoker)的构造器传入这个具体对象的实例就可以了。感觉是不是自己为该具体类造了一个代理类呢?呵呵~
*/
//接口类
interface AbstractClass {
public String show();
}
// 具体类A
class ClassA implements AbstractClass {
//@Override
public String show() {
// TODO Auto-generated method stub
System.out.println("我是A类!");
return new String("A");
}
}
// 具体类B
class ClassB implements AbstractClass {
@Override
public String show() {
// TODO Auto-generated method stub
System.out.println("我是B类!");
return "B";
}
}
//动态代理类,实现InvocationHandler接口
class Invoker implements InvocationHandler {
AbstractClass ac;
public Invoker(AbstractClass ac) {
this.ac = ac;
}
@Override
public Object invoke(Object proxy, Method method, Object[] arg)
throws Throwable {
//调用之前可以做一些处理
Object result=method.invoke(ac, arg);
//调用之后也可以做一些处理
return result;
}
}
/**
* 测试类
* @author 小路
*/
class DynamicProxyTest {
public static void main(String[] args) {
String result=null;
//创建具体类ClassB的处理对象
Invoker invoker1=new Invoker(new ClassA());
//获得具体类ClassA的代理
AbstractClass ac1 = (AbstractClass) Proxy.newProxyInstance(
AbstractClass.class.getClassLoader(),
new Class[] { AbstractClass.class }, invoker1);
//调用ClassA的show方法。
result=ac1.show();
System.out.println("result="+result);
//创建具体类ClassB的处理对象
Invoker invoker2=new Invoker(new ClassB());
//获得具体类ClassB的代理
AbstractClass ac2 = (AbstractClass) Proxy.newProxyInstance(
AbstractClass.class.getClassLoader(),
new Class[] { AbstractClass.class }, invoker2);
//调用ClassB的show方法。
result=ac2.show();
System.out.println("result="+result);
}
}<strong>
</strong>
程序运行后的结果如下:
我是A类!
result=A
我是B类!
result=A
很快我会写一篇关于hadoop RPC机制分析的博客,博客地址:http://weixiaolu.iteye.com/blog/1504898 ,希望大家继续关注。
相关文章推荐
- 6.hadoop中rpc中的动态代理的理解
- HadoopRPC机制分析系列之一: 动态代理
- alljoyn:基于java动态代理的RPC实现原理分析
- hadoop-0.20.2 & hbase-0.90.1 集群启动错误“org.apache.hadoop.ipc.RPC$VersionMismatch: Protocol org.apache.hadoop.hdfs.protocol.ClientP
- Hadoop技术内幕HDFS-笔记5之动态代理
- RPC中用到的 *动态代理,反射机制,NIO
- 老王讲自制RPC框架.(二.动态代理)
- Hadoop和Hbase动态扩展
- 简单的RPC(未用动态代理)
- 【远程调用框架】如何实现一个简单的RPC框架(三)优化一:利用动态代理改变用户服务调用方式
- 如何写一个RPC框架(二):利用Bean容器和动态代理简化客户端代码
- RPC、HSF、bubbo、java动态代理
- 理解动态代理及动态代理在RPC中的应用
- [hadoop源码阅读][6]-org.apache.hadoop.ipc-基础知识点(nio,动态代理)
- java Rpc之java动态代理
- RPC动态代理
- JAX-RPC学习笔记(2)-通过动态代理客户端访问webservice
- JAX-RPC学习笔记(2)-通过动态代理客户端访问webservice
- hadoop源码研读之路(五)----Java动态代理
- 《Hadoop技术内幕》学习笔记——RPC和动态代理