如何在不使用他人jar包的情况下优雅的进行dubbo调用

待我称王封你为后i 2023-09-27 14:38 100阅读 0赞

## 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.获取泛化对象

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.泛化调用入参处理

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

1.  com.alibaba.dubbo.rpc.filter.GenericFilter
2.  com.alibaba.dubbo.rpc.filter.GenericImplFilter  
    复制代码

泛化调用的流程:  
调用 <-> GenericImplFilter <-> 网络（RPC） <-> GenericFilter <-> 服务实现

泛化调用的核心源码:

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、总结 ##

从源码设计来看泛化调用提供了在没有接口依赖的情况下进行调用的解决方案；  
从扩展上来看泛化调用的侵入性不强，可以很好的用于框架扩展；