1、正常dubbo调用流程
引入dubbo依赖
引入他人提供的clinet依赖包;
配置相同的注册中心，使用@Reference注解注入对应的service接口（注意是Reference是dubbo包下的，不是spring那个）
2、如果想在不引用他人jar包的情况下如何调用呢
dubbo泛化调用-dubbo原生支持的优雅方法
使用场景：
消费者不希望引入生产者提供的clinet依赖；
例如：消费者是一个基础服务，需要调用很多生产者的dubbo方法，那他就要引入很多的jar包；
消费者不使用java语言，而是使用其他的语言（例如：Python）；
如何使用：
1.需要知道对方方法的全路径名称（interfaceName）
2.如果对方的dubbo有指定的版本号（version）和组（group）要指定一下，不然有很大可能会调用不通
3.要知道对方的注册中心地址和连接方式（如果是在同一个zk注册中心就更好了）
1.获取泛化对象
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 |
private GenericService getGenericService(String interfaceName, String version, String group) { ReferenceConfig<GenericService> reference = new ReferenceConfig<GenericService>(); // set application ApplicationConfig applicationConfig = new ApplicationConfig(); applicationConfig.setId(APPLICATION_ID); applicationConfig.setName(APPLICATION_ID); reference.setApplication(applicationConfig); // 通过zookeeper连接 RegistryConfig registryConfig = new RegistryConfig(); registryConfig.setAddress(zkAddress); registryConfig.setProtocol(ZOOKEEPER); registryConfig.setCheck( false ); reference.setRegistry(registryConfig); // set timeout reference.setTimeout(syncForwardTimeout); // set retry times reference.setRetries(syncRetries); // set check reference.setCheck( false ); // set generic reference.setGeneric( true ); // set interface version if (version != null && version.length() != 0 ) { reference.setVersion(version); } // set interface name reference.setInterface(interfaceName); // set service id reference.setId(interfaceName); // set dubbo protocol reference.setProtocol(DUBBO); // if (group != null && group.length() != 0 ) { reference.setGroup(group); } // 从zookeeper获取缓存，从缓存中获取泛化 return ReferenceConfigCache.getCache().get(reference); } |
2.泛化调用入参处理
|
1 2 3 4 5 6 7 8 9 |
private ResponseDataDto<R> invoke(GenericService genericService, UpDataReqDto upDataReqDto, String method) { String[] paramTypes = new String[ 1 ]; Object[] paramValues = new Object[ 1 ]; int i = 0 ; paramTypes[i] = upDataReqDto.getClass().getTypeName(); paramValues[i] = upDataReqDto; Object object = genericService.$invoke(method, paramTypes, paramValues); return JSON.parseObject(JSON.toJSONString(object), new TypeReference<ResponseDataDto<R>>(){}); } |
实现原理：
泛化调用的实现主要涉及两个filter
com.alibaba.dubbo.rpc.filter.GenericFilter
com.alibaba.dubbo.rpc.filter.GenericImplFilter
复制代码
泛化调用的流程:
调用 <-> GenericImplFilter <-> 网络（RPC） <-> GenericFilter <-> 服务实现
泛化调用的核心源码:
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 |
GenericImplFilter: //判断是不是泛化调用 if (isCallingGenericImpl(generic, invocation)) { RpcInvocation invocation2 = new RpcInvocation(invocation); /** * Mark this invocation as a generic impl call, this value will be removed automatically before passing on the wire. * See {@link RpcUtils#sieveUnnecessaryAttachments(Invocation)} */ invocation2.put(GENERIC_IMPL_MARKER, true ); String methodName = invocation2.getMethodName(); Class<?>[] parameterTypes = invocation2.getParameterTypes(); Object[] arguments = invocation2.getArguments(); String[] types = new String[parameterTypes.length]; for ( int i = 0 ; i < parameterTypes.length; i++) { types[i] = ReflectUtils.getName(parameterTypes[i]); } Object[] args; if (ProtocolUtils.isBeanGenericSerialization(generic)) { args = new Object[arguments.length]; for ( int i = 0 ; i < arguments.length; i++) { args[i] = JavaBeanSerializeUtil.serialize(arguments[i], JavaBeanAccessor.METHOD); } } else { args = PojoUtils.generalize(arguments); } if (RpcUtils.isReturnTypeFuture(invocation)) { invocation2.setMethodName($INVOKE_ASYNC); } else { invocation2.setMethodName($INVOKE); } invocation2.setParameterTypes(GENERIC_PARAMETER_TYPES); invocation2.setParameterTypesDesc(GENERIC_PARAMETER_DESC); invocation2.setArguments( new Object[]{methodName, types, args}); return invoker.invoke(invocation2); } // 普通服务进行通用调用 else if (isMakingGenericCall(generic, invocation)) { Object[] args = (Object[]) invocation.getArguments()[ 2 ]; if (ProtocolUtils.isJavaGenericSerialization(generic)) { for (Object arg : args) { if ( byte []. class != arg.getClass()) { error(generic, byte []. class .getName(), arg.getClass().getName()); } } } else if (ProtocolUtils.isBeanGenericSerialization(generic)) { for (Object arg : args) { if (!(arg instanceof JavaBeanDescriptor)) { error(generic, JavaBeanDescriptor. class .getName(), arg.getClass().getName()); } } } invocation.setAttachment( GENERIC_KEY, invoker.getUrl().getParameter(GENERIC_KEY)); } GenericFilter： if ((inv.getMethodName().equals($INVOKE) || inv.getMethodName().equals($INVOKE_ASYNC)) && inv.getArguments() != null && inv.getArguments().length == 3 && !GenericService. class .isAssignableFrom(invoker.getInterface())){ .......泛化调用处理逻辑...... } |
3、总结
从源码设计来看泛化调用提供了在没有接口依赖的情况下进行调用的解决方案；
从扩展上来看泛化调用的侵入性不强，可以很好的用于框架扩展；
到此这篇关于详解Java如何优雅的调用dubbo同时不使用其它jar包的文章就介绍到这了,更多相关Java调用dubbo内容请搜索以前的文章或继续浏览下面的相关文章希望大家以后多多支持！
原文链接：https://blog.csdn.net/jcc4261/article/details/129096869
查看更多关于详解Java如何优雅的调用dubbo同时不使用其它jar包的详细内容...