[HBase] Hadoop RPC 动态代理

深藏阁楼爱情的钟 2022-08-27 12:58 108阅读 0赞

# [\[HBase\] Hadoop RPC 动态代理 ][HBase_ Hadoop RPC _] #

分类： [ hadoop][hadoop] [ HBase][HBase] [ Java][Java] 2013-01-29 20:50  174人阅读 [评论][Link 1](0) 收藏 [举报][Link 2]

[hadoop][hadoop 1] [Hadoop][] [hbase][] [HBASE][] [HBase][HBase 1] [proxy][] [Proxy][] [RPC][] [rpc][] [动态代理][Link 3]

本文来自：逸情公子的博客[http://weixiaolu.iteye.com/blog/1477774][http_weixiaolu.iteye.com_blog_1477774]

**前言：**   
  
最近一直在分析hadoop的RPC机制。在hadoop中，DataNode和NameNode之间的控制信息的交流是通过RPC机制完成的，采用的是动态代理和java NIO(参考博客：[http://weixiaolu.iteye.com/blog/1479656][http_weixiaolu.iteye.com_blog_1479656] ) 的方式。DataNode端是通过获得NameNode的代理，通过该代理和NameNode进行通信的，为了更好的分析hadoop的RPC机制我想先分析一下动态代理是怎么实现。下面就是动态代理的最最简单的代码实现，我们一起来看看吧。  
  
**代码如下：**

**\[java\]** [ view plain][view plain] [copy][view plain]

1.  package rpc.proxy;  
2.    
3.  import java.lang.reflect.InvocationHandler;  
4.  import java.lang.reflect.Method;  
5.  import java.lang.reflect.Proxy;  
6.    
7.  /\*\* 
8.   \* 动态代理类使用到了一个接口InvocationHandler和一个代理类Proxy ，这两个类配合使用实现了动态代理的功能。 
9.   \* 那么什么是动态代理呢？ 
10.  \* 我们平常说的代理类是指： 给每个具体类写一个代理类，以后要使用某个具体类时，只要创建它的代理类的对象，然后调用代理类的方法就可以了。 
11.  \* 可是如果现在有许多的具体类，那就需要有许多的代理类才可以，这样很显然不合适。所以动态代理就应运而生了，我们只要写一个类实现 
12.  \* InvocationHandler 并实现它的invoke方法，然后再用Proxy的工厂方法newProxyInstance（）创建一个代理对象，这个对象同样可以实现对具体类的代理功能。 
13.  \* 而且想代理哪个具体类，只要给Handler（以下代码中的Invoker）的构造器传入这个具体对象的实例就可以了。感觉是不是自己为该具体类造了一个代理类呢？呵呵~ 
14.  \*/  
15.   
16. //接口类  
17. interface AbstractClass \{  
18.   
19.     public String show();  
20.   
21. \}  
22.   
23. // 具体类A  
24. class ClassA implements AbstractClass \{  
25.   
26.     //@Override  
27.     public String show() \{  
28.         // TODO Auto-generated method stub  
29.         System.out.println("我是A类！");  
30.         return new String("A");  
31.     \}  
32. \}  
33.   
34. // 具体类B  
35. class ClassB implements AbstractClass \{  
36.   
37.     @Override  
38.     public String show() \{  
39.         // TODO Auto-generated method stub  
40.         System.out.println("我是B类！");  
41.         return "B";  
42.     \}  
43. \}  
44. //动态代理类，实现InvocationHandler接口  
45. class Invoker implements InvocationHandler \{  
46.     AbstractClass ac;  
47.   
48.     public Invoker(AbstractClass ac) \{  
49.         this.ac = ac;  
50.     \}  
51.   
52.     @Override  
53.     public Object invoke(Object proxy, Method method, Object\[\] arg)  
54.             throws Throwable \{  
55.         //调用之前可以做一些处理  
56.          Object result=method.invoke(ac, arg);  
57.         //调用之后也可以做一些处理  
58.         return result;  
59.     \}  
60. \}  
61.   
62. /\*\* 
63.  \* 测试类 
64.  \* @author 小路 
65.  \*/  
66. class DynamicProxyTest \{  
67.   
68.     public static void main(String\[\] args) \{  
69.           
70.         String result=null;  
71.           
72.         //创建具体类ClassB的处理对象  
73.         Invoker invoker1=new Invoker(new ClassA());  
74.         //获得具体类ClassA的代理  
75.         AbstractClass ac1 = (AbstractClass) Proxy.newProxyInstance(  
76.                 AbstractClass.class.getClassLoader(),  
77.                 new Class\[\] \{ AbstractClass.class \}, invoker1);  
78.         //调用ClassA的show方法。  
79.           
80.         result=ac1.show();  
81.         System.out.println("result="\+result);  
82.           
83.           
84.         //创建具体类ClassB的处理对象  
85.         Invoker invoker2=new Invoker(new ClassB());  
86.         //获得具体类ClassB的代理  
87.         AbstractClass ac2 = (AbstractClass) Proxy.newProxyInstance(  
88.                 AbstractClass.class.getClassLoader(),  
89.                 new Class\[\] \{ AbstractClass.class \}, invoker2);  
90.         //调用ClassB的show方法。  
91.         result=ac2.show();  
92.         System.out.println("result="\+result);  
93.   
94.     \}  
95. \}<strong>  
96. </strong>

程序运行后的结果如下：

1.  我是A类！
2.  result=A 
3.  我是B类！ 
4.  result=A

很快我会写一篇关于hadoop RPC机制分析的博客，博客地址：[http://weixiaolu.iteye.com/blog/1504898][http_weixiaolu.iteye.com_blog_1504898] ，希望大家继续关注。

[HBase_ Hadoop RPC _]: http://blog.csdn.net/mango_song/article/details/8554007
[hadoop]: http://blog.csdn.net/mango_song/article/category/1307468
[HBase]: http://blog.csdn.net/mango_song/article/category/1334276
[Java]: http://blog.csdn.net/mango_song/article/category/1307467
[Link 1]: http://blog.csdn.net/mango_song/article/details/8554007#comments
[Link 2]: http://blog.csdn.net/mango_song/article/details/8554007#report
[hadoop 1]: http://www.csdn.net/tag/hadoop
[Hadoop]: http://www.csdn.net/tag/Hadoop
[hbase]: http://www.csdn.net/tag/hbase
[HBASE]: http://www.csdn.net/tag/HBASE
[HBase 1]: http://www.csdn.net/tag/HBase
[proxy]: http://www.csdn.net/tag/proxy
[Proxy]: http://www.csdn.net/tag/Proxy
[RPC]: http://www.csdn.net/tag/RPC
[rpc]: http://www.csdn.net/tag/rpc
[Link 3]: http://www.csdn.net/tag/%e5%8a%a8%e6%80%81%e4%bb%a3%e7%90%86
[http_weixiaolu.iteye.com_blog_1477774]: http://weixiaolu.iteye.com/blog/1477774
[http_weixiaolu.iteye.com_blog_1479656]: http://weixiaolu.iteye.com/blog/1479656
[view plain]: http://blog.csdn.net/mango_song/article/details/8554007#
[http_weixiaolu.iteye.com_blog_1504898]: http://weixiaolu.iteye.com/blog/1504898