泛化調(diào)用示例:
ApplicationConfig applicationConfig = new ApplicationConfig();
applicationConfig.setName(genericInvokeDTO.getApplication());
RegistryConfig registryConfig = new RegistryConfig();
registryConfig.setAddress(registryAddress);
applicationConfig.setRegistry(registryConfig);
// 引用遠(yuǎn)程服務(wù)
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()});
原理:
泛化調(diào)用本質(zhì)是在filter過濾鏈上執(zhí)行的序列化和反序列化操作
消費(fèi)者端對(duì)應(yīng)的過濾器是GenericImplFilter
生產(chǎn)者端對(duì)應(yīng)的過濾器是GenericFilter
在消費(fèi)者端,通過GenericImplFilter類,在調(diào)用的invocation對(duì)象中設(shè)置generic為true
((RpcInvocation)invocation).setAttachment(
Constants.GENERIC_KEY, invoker.getUrl().getParameter(Constants.GENERIC_KEY));
在生產(chǎn)者端,通過GenericFilter類,發(fā)現(xiàn)invocation對(duì)象中的generic為true時(shí),會(huì)反序列化參數(shù)
String generic = inv.getAttachment(Constants.GENERIC_KEY);
if (StringUtils.isEmpty(generic)
|| ProtocolUtils.isDefaultGenericSerialization(generic)) {
args = PojoUtils.realize(args, params, method.getGenericParameterTypes());
}