Dubbo泛化调用

泛化调用示例：

ApplicationConfig applicationConfig = new ApplicationConfig();
applicationConfig.setName(genericInvokeDTO.getApplication());

RegistryConfig registryConfig = new RegistryConfig();
registryConfig.setAddress(registryAddress);

applicationConfig.setRegistry(registryConfig);
// 引用远程服务 
ReferenceConfig<GenericService> referenceConfig = new ReferenceConfig<>();
referenceConfig.setApplication(applicationConfig);
referenceConfig.setInterface(genericInvokeDTO.getService());
// 声明为泛化接口
referenceConfig.setGeneric(true);
referenceConfig.setUrl(genericInvokeDTO.getTargetProvider());
// 用org.apache.dubbo.rpc.service.GenericService可以替代所有接口引用 
GenericService genericService = referenceConfig.get();
genericService.$invoke(genericInvokeDTO.getMethod(),
    new String[]{genericInvokeDTO.getClassName()}, 
    new Object[]{genericInvokeDTO.getParams()});
    

原理：
泛化调用本质是在filter过滤链上执行的序列化和反序列化操作
消费者端对应的过滤器是GenericImplFilter
生产者端对应的过滤器是GenericFilter

在消费者端，通过GenericImplFilter类，在调用的invocation对象中设置generic为true

((RpcInvocation)invocation).setAttachment(
        Constants.GENERIC_KEY, invoker.getUrl().getParameter(Constants.GENERIC_KEY));

在生产者端，通过GenericFilter类，发现invocation对象中的generic为true时，会反序列化参数

String generic = inv.getAttachment(Constants.GENERIC_KEY);
if (StringUtils.isEmpty(generic)
            || ProtocolUtils.isDefaultGenericSerialization(generic)) {
    args = PojoUtils.realize(args, params, method.getGenericParameterTypes());
}