深入解析MapReduce架构设计与实现原理–读书笔记(7)hadoopRPC反
hadoop RPC 中用到的JDK开发工具包中的一些类。 主要包括java.lang. reflect 反射机制和动态代理相关类。java.net网络编程库,java.nio(NIO) 1.java反射机制和动态代理 反射机制是java语言的一个重要特性,它允许用户动态获取类的信息和动态调用对象的方法
hadoop RPC中用到的JDK开发工具包中的一些类。
主要包括java.lang.reflect反射机制和动态代理相关类。java.net网络编程库,java.nio(NIO)
1.java反射机制和动态代理
反射机制是java语言的一个重要特性,它允许用户动态获取类的信息和动态调用对象的方法。
Class类 代表一个java类
Field类 代表Java类的属性
Method类 代表Java类的方法
Constructor类 代表java类的构造函数
Array类 提供了动态创建数组,以及访问数组元素的静态方法
Proxy类和InvocationHandler接口 提供了动态生成代理类以及实例的方法。
代理是一种常用的设计模式,其目的是为其他对象提供一种代理以控制对这个对象的访问。代理类负责为委托类进行预处理,或者执行完后的后续处理。
java.lang.reflect.Proxy
这是java动态代理机制的主类,它提供了一组静态方法,用于为一组接口动态地生成代理类及对象。
- static InvocationHandler getInvocationHandler(Object proxy) //获取指定代理对象所关联的调用处理器
- static Class getProxyClass(ClassLoader loader,Class[] interfaces) //获取关联于指定的类装载器和一组接口的动态代理类的对象
- static boolean isProxyClass(Class cl) //判断指定的类对象是否一个动态代理类
- static Object newProxyInstance(ClassLoader loader,Class[] interfaces,InvocationHandler h) //为指定类装载器,一组接口及调用处理器生成动态代理类实例
java.lang.reflect.InvocationHandler
这是调用处理器接口。它定义了一个invoke方法,用于处理在动态代理类对象上的方法调用。开发人员需要实现该接口,并在invoke方法中实现对委托类的代理访问。
- //下方法负责处理动态代理类上的所有方法调用。三个参数:代理类实例,被调用的方法,调用参数。
- Object invoke(Object proxy,Method method,Objects[] args)
- 示例如下:
- package com.sw.testproxy;
- import java.lang.reflect.InvocationHandler;
- import java.lang.reflect.Proxy;
- import java.lang.reflect.Method;
- interface CalculatorProtocol {
- public int add (int a,int b);
- public int subtract(int a,int b);
- }
- class Server implements CalculatorProtocol{
- @Override
- public int add(int a, int b) {
- return a+b;
- }
- @Override
- public int subtract(int a, int b) {
- return a-b;
- }
- }
- class CalculatorHandler implements InvocationHandler{
- private Object objOriginal ;
- public CalculatorHandler(Object obj){
- this.objOriginal = obj ;
- }
- @Override
- public Object invoke(Object proxy, Method method, Object[] args)
- throws Throwable {
- Object result = method.invoke(this.objOriginal,args);
- return result;
- }
- }
- public class DynamicProxyExample {
- public static void main(String[] args) {
- CalculatorProtocol server = new Server();
- InvocationHandler handler = new CalculatorHandler(server);
- CalculatorProtocol client = (CalculatorProtocol)Proxy.newProxyInstance(server.getClass().getClassLoader(),
- server.getClass().getInterfaces(),handler);
- int r = client.add(5,3);
- System.out.println(r);
- }
- }
原文地址:深入解析MapReduce架构设计与实现原理–读书笔记(7)hadoopRPC反射原理, 感谢原作者分享。
推荐阅读
-
深入解析MapReduce架构设计与实现原理–读书笔记(5)hadoop工作流
-
深入解析MapReduce架构设计与实现原理–读书笔记(4)MR及Partitio
-
深入解析MapReduce架构设计与实现原理–读书笔记(6)HadoopRPC概
-
深入解析MapReduce架构设计与实现原理–读书笔记(6)HadoopRPC概
-
深入解析MapReduce架构设计与实现原理–读书笔记(2)作业配置及In
-
深入解析MapReduce架构设计与实现原理–读书笔记(2)作业配置及In
-
深入解析MapReduce架构设计与实现原理–读书笔记(1)概述
-
深入解析MapReduce架构设计与实现原理–读书笔记(7)hadoop 网络
-
深入解析MapReduce架构设计与实现原理–读书笔记(7)hadoop 网络
-
深入解析MapReduce架构设计与实现原理–读书笔记(7)hadoopRPC反