上一章我们了解了dubbo最核心的一块，就是数据传输和调用，我们知道真正调用的原理。以及更早的时候还介绍注册中心的实现，用来管理每一个服务提供者的信息，供消费者路由到相关的服务提供者上去。这个过程细想，做的事情还挺多的。dubbo不可能为每一个服务都去实现从注册中心拿到提供者，负载均衡后调用指定的提供者，而且这个给框架使用者去实现也不合适。那么dubbo解决这一问题的方案就是动态代理。
在更早之前也有提到过这一块,感兴趣可以先了解:谈谈mybatis、dubbo基础原理
这章基本内容就是为提供的api接口,生成代理类,在代理类中实现上述所说的,调用注册中心、负载均衡、远程调用等等
项目结构介绍
本节涉及博客中代码的两个module，farpc-rpc（远程调用）、farpc-demo。
代理实现
ConsumerProxy需要做的事情,上面讲的很详细了,这里罗列一下.
- 生成代理类
- 调用注册中心
- 远程调用
public class ConsumerProxy {
private static final Logger logger = LoggerFactory.getLogger(ConsumerProxy.class);
public static <T> T create(final Class<T> interfaceClass) {
Object o = Proxy.newProxyInstance(interfaceClass.getClassLoader(), new Class[]{interfaceClass}
, new InvocationHandler() {
public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
// 封装调用参数
RequestDTO requestDTO = new RequestDTO();
requestDTO.setClassName(method.getDeclaringClass().getName());
requestDTO.setMethodName(method.getName());
requestDTO.setTypes(method.getParameterTypes());
requestDTO.setParams(args);
// 获取服务提供者
IRegistrar registrar = RegistrarFactory.getRegistrar();
String service = interfaceClass.getName();
String serivceAddress = registrar.discover(service);
// 调用上一章写的远程调用
Object result = RpcFactory.getConsumerService().execute(serivceAddress, requestDTO);
return result;
}
});
return (T) o;
}
}由于这里实现只是rpc调用,没有完整的生命周期,也就是说在消费者调用这里还可以优化.比如像dubbo一样在项目启动时去解析xml或者扫描Reference注解.这一块是本系列博客所缺少的.
测试
在启动服务端后,我们再测试直接调用接口的代理对象,对于扫描Reference注解,然后像spring那样注入到具体对象中,也可以再做更深的了解。
代码语言：javascript复制@Test
public void consumerTest(){
IWelcome welcome = ConsumerProxy.create(IWelcome.class);
String far = welcome.greet("far");
System.out.println(far);
}至于上面的运行结果,也肯定是令人满意的,期待各位自己测试.
