package hdfs.proxy;public interface MyService {public void method1();public void method2();
}

package hdfs.proxy;public class MyServiceImpl implements MyService {@Overridepublic void method1() {System.out.println("************ method1  ***************");}@Overridepublic void method2() {System.out.println("************ method2  ***************");}}

package hdfs.proxy;import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;public class TestMain {public static void main(String[] args) {//创建真正的对象MyService obj = new MyServiceImpl();//obj.method1();  ---> 都是直接调用真正对象//obj.method2();  ---> 都是直接调用真正对象/** Object Proxy.newProxyInstance(ClassLoader loader, 类加载器，代理对象跟真正对象是同一个类加载器Class<?>[] interfaces, 真正对象实现的接口InvocationHandler h) 如何处理客户端的调用返回一个代理对象         *///生成obj的代理对象，并且重新method2的逻辑MyService proxy = (MyService) Proxy.newProxyInstance(TestMain.class.getClassLoader(), obj.getClass().getInterfaces(), new InvocationHandler() {@Overridepublic Object invoke(Object proxy, Method method, Object[] args) throws Throwable {// 如何处理客户端的调用if(method.getName().equals("method2")){//客户端调用了method2System.out.println("in proxy method2");return null;}else{//其他方法不感兴趣return method.invoke(obj, args);}}});//通过代理对象进行调用
        proxy.method1();proxy.method2();}}

package demo.proxy.rpc.server;import org.apache.hadoop.ipc.VersionedProtocol;public interface MyBusiness extends VersionedProtocol{//指定一个版本号，使用这个版本号来创建签名public static long versionID = 1l;//定义自己的业务方法public String sayHello(String name);
}

package demo.proxy.rpc.server;import java.io.IOException;import org.apache.hadoop.ipc.ProtocolSignature;public class MyBusinessImpl implements MyBusiness{@Overridepublic ProtocolSignature getProtocolSignature(String arg0, long arg1, int arg2) throws IOException {//使用versionID创建签名return new ProtocolSignature(versionID, null);}@Overridepublic long getProtocolVersion(String arg0, long arg1) throws IOException {// 返回IDreturn versionID;}@Overridepublic String sayHello(String name) {System.out.println("*****调用Server端的方法******");//业务方法return "Hello" + name;}}

package demo.proxy.rpc.server;import java.io.IOException;import org.apache.hadoop.HadoopIllegalArgumentException;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.ipc.RPC;
import org.apache.hadoop.ipc.RPC.Server;public class MyRPCServer {public static void main(String[] args) throws HadoopIllegalArgumentException, IOException {//ʹ创建一个RPC ServerRPC.Builder builder = new RPC.Builder(new Configuration());//指定Server的地址接口builder.setBindAddress("localhost");builder.setPort(7788);//发布程序builder.setProtocol(MyBusiness.class);//定义的接口builder.setInstance(new MyBusinessImpl());//发布的接口的实现//创建RPC ServerServer server = builder.build();server.start();}
}

package demo.proxy.rpc.client;import java.net.InetSocketAddress;import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.ipc.RPC;import demo.proxy.rpc.server.MyBusiness;public class MyRPCClient {public static void main(String[] args) throws Exception {//调用Server的功能MyBusiness proxy = RPC.getProxy(MyBusiness.class,//调用的接口MyBusiness.versionID,//版本的ID，必须跟服务器一致new InetSocketAddress("localhost", 7788), //服务器的地址ַnew Configuration());//调用服务器端的方法System.out.println(proxy.sayHello("梦里南柯"));}}