1 import java.lang.reflect.InvocationHandler;
 2 import java.lang.reflect.Method;
 3 import java.lang.reflect.Proxy;
 4 import java.util.HashMap;
 5 import java.util.Map;
 6
 7 /**
 8  * 动态代理在RPC中的使用
 9  *
10  * @author syj
11  */
12 public class JDKProxyTest {
13
14     // ---------------------------  模拟RPC客户端  ---------------------------
15
16     // 客户端依赖服务端的接口(实现类在服务端)
17     private static IUserService userService;
18
19     public static void main(String[] args) {
20         // 根据接口创建代理对象
21         userService = (IUserService) Proxy.newProxyInstance(
22                 JDKProxyTest.class.getClassLoader(),
23                 new Class[]{IUserService.class},
24                 new InvocationHandler() {
25                     // 在回调方法模拟进行RPC调用(通过http或者tcp与服务端通信)
26                     @Override
27                     public Object invoke(Object proxy, Method method, Object[] params) throws Throwable {
28                         return rpcInvoke(IUserService.class.getSimpleName(), method.getName(), method.getParameterTypes(), params);
29                     }
30                 }
31         );
32         // 本地调用
33         String result = userService.sayHello("hello");
34         System.out.println(">>>> result =" + result);
35     }
36
37
38     // ---------------------------  模拟RPC服务端  ---------------------------
39
40     /**
41      * 反射调用
42      *
43      * @param methodName     方法名称
44      * @param parameterTypes 方法参数类型
45      * @param parameters     方法参数
46      * @return
47      */
48     private static Object rpcInvoke(String interfaceName, String methodName, Class<?>[] parameterTypes, Object[] parameters) {
49         Object result = null;
50         try {
51             // 根据接口名称从Bean容器中获取Bean实例
52             Object serviceBean = beanMap.get(interfaceName);
53             // 反射调用
54             Class<?> serviceClass = serviceBean.getClass();
55             Method method = serviceClass.getMethod(methodName, parameterTypes);
56             method.setAccessible(true);
57             // 得到调用结果
58             result = method.invoke(serviceBean, parameters);
59         } catch (Exception e) {
60             e.printStackTrace();
61         }
62         return result;
63     }
64
65     // 模拟Bean容器, key为接口名称, value为bean实例
66     private static Map<String, Object> beanMap = new HashMap<String, Object>() {{
67         put("IUserService", new UserServiceImpl());
68     }};
69 }

1 public interface IUserService {
2     String sayHello(String content);
3 }

public class UserServiceImpl implements IUserService {@Overridepublic String sayHello(String content) {return content + "::" + System.currentTimeMillis();}
}