前言
在现代软件开发中，微服务架构已经成为了一种流行的解决方案。而 Dubbo 作为一种优秀的微服务框架，其强大的功能和灵活性备受开发者青睐。然而，在实际的微服务开发中，我们经常面临着一个挑战：如何在不依赖具体接口的情况下实现动态的远程调用？这就是我们引入 Dubbo 中的泛化调用（Generic Invocation）的时刻！
泛化调用的概念
泛化调用是一种软件设计和编程范式，其核心思想是编写可以适用于多种类型或多种情况的通用代码，从而提高代码的复用性和灵活性。在泛化调用中，通过参数化或抽象化的方式实现通用性，使得代码可以适应不同的数据类型、操作或场景。
具体来说，泛化调用通常通过以下方式实现：
- 参数化：通过参数将特定值或行为传递给泛化的代码，使其能够处理不同的输入。这些参数可以是函数、类型、配置选项等。
- 抽象化：通过定义抽象接口或抽象类，使得泛化代码能够与不同的实现进行交互，而不需要直接依赖于具体的实现细节。
泛化调用的优势和适用场景包括：
- 复用性：泛化调用可以使得代码更加通用，从而可以在不同的上下文中被重复使用，减少代码的重复编写，提高开发效率。
- 灵活性：通过泛化调用，可以使得代码更加灵活和可扩展，因为它可以适应不同的需求、数据类型或业务逻辑。
- 解耦：泛化调用可以帮助将代码解耦，降低代码之间的依赖关系，使得代码更容易维护和测试。
- 适用于多样化的需求：在需要处理多种类型数据或实现多种操作的情况下，泛化调用可以提供一种统一的解决方案，减少代码的复杂度和重复性。
- 框架和库的设计：在设计框架或库时，泛化调用是一种常见的设计模式，可以使得框架或库更加通用和灵活，以满足不同用户的需求。
总之，泛化调用是一种强大的编程范式，可以提高代码的复用性、灵活性和可维护性，适用于各种需要通用解决方案的场景。
Dubbo 中泛化调用的工作原理
在 Dubbo 中，泛化调用是指客户端调用服务端的方法时，可以不依赖于服务端接口的具体定义，而是通过指定方法名和参数来实现调用。这种泛化调用的实现原理涉及到 Dubbo 的动态代理机制以及序列化与反序列化过程。
下面是 Dubbo 中泛化调用的工作原理：
- 动态代理：
- Dubbo 使用 Java 的动态代理技术，在客户端生成一个代理类，用于与服务端进行通信。
- 代理类通过拦截客户端的方法调用，并将调用转发给底层的网络通信组件，完成远程调用的过程。
- 序列化与反序列化：
- 在泛化调用中，客户端需要将方法名和参数序列化为字节流，并发送给服务端。
- 服务端接收到字节流后，需要进行反序列化，还原出方法名和参数，并根据方法名执行对应的方法。
- Dubbo 使用了不同的序列化协议（如 Hessian、JSON、Protobuf 等）来实现序列化和反序列化的过程。
- 泛化调用实现：
- Dubbo 提供了
GenericService接口，用于实现泛化调用。这个接口定义了invoke方法，允许客户端传入方法名和参数进行调用。 - 客户端可以通过获取服务端的
GenericService对象来实现泛化调用。在 Dubbo 的客户端代理中，可以通过调用invoke方法来实现对应的泛化调用。
- 服务端实现：
- 在服务端，Dubbo 提供了
GenericService的实现类，用于处理泛化调用。 - 这个实现类可以通过反射机制，根据传入的方法名找到对应的实现方法，并调用执行。
总的来说，Dubbo 中泛化调用的实现原理主要涉及动态代理、序列化与反序列化以及泛化调用的实现类。通过这些机制，Dubbo 可以实现对服务端接口定义的解耦，使得客户端可以通过指定方法名和参数来进行调用，从而实现泛化调用的功能。
泛化实现动态RPC
在 Dubbo 中使用泛化调用实现动态 RPC 调用的过程涉及到配置服务提供者和消费者，以及编写示例代码来进行远程调用。
首先，我们来配置 Dubbo 的服务提供者和消费者，使其支持泛化调用：
- 服务提供者配置：
在服务提供者的配置文件（比如 dubbo-provider.xml）中，需要添加如下配置来开启泛化调用支持：
<dubbo:protocol name="dubbo" port="20880"/> <dubbo:service interface="com.example.SomeService" ref="someServiceImpl" generic="true"/>
在这里，generic="true" 表示服务提供者将支持泛化调用，并且指定了服务接口 SomeService 的实现类为 someServiceImpl。
- 服务消费者配置：
在服务消费者的配置文件（比如 dubbo-consumer.xml）中，需要添加如下配置来开启泛化调用支持：
<dubbo:reference id="someService" interface="com.example.SomeService" generic="true"/>
在这里，generic="true" 表示服务消费者将支持泛化调用，并且指定了需要引用的服务接口为 SomeService。
接下来，我们通过示例代码来演示如何使用泛化调用进行远程调用：
import org.apache.dubbo.config.ApplicationConfig; import org.apache.dubbo.config.ReferenceConfig; import org.apache.dubbo.config.RegistryConfig; import org.apache.dubbo.rpc.service.GenericService; public class GenericConsumer { public static void main(String[] args) { // 配置应用信息 ApplicationConfig application = new ApplicationConfig(); application.setName("generic-consumer"); // 配置注册中心信息 RegistryConfig registry = new RegistryConfig(); registry.setAddress("zookeeper://127.0.0.1:2181"); // 配置泛化调用 ReferenceConfig<GenericService> reference = new ReferenceConfig<>(); reference.setApplication(application); reference.setRegistry(registry); reference.setInterface("com.example.SomeService"); // 接口名 reference.setGeneric(true); // 获取 GenericService 对象 GenericService someService = reference.get(); // 使用泛化调用进行远程调用 Object result = someService.$invoke("methodName", new String[] {"java.lang.String"}, new Object[] {"parameter"}); System.out.println("Result: " + result); } }
在这个示例代码中，我们使用 Dubbo 提供的 ReferenceConfig 和 GenericService 类来实现泛化调用。在调用 $invoke 方法时，需要传入方法名、参数类型和参数值来执行远程调用。
需要注意的是，在上面的示例代码中，com.example.SomeService 表示远程服务接口的全限定名，methodName 表示远程方法名，java.lang.String 表示参数类型，parameter 表示参数值。
通过以上配置和示例代码，就可以实现 Dubbo 中的动态 RPC 调用。
泛化调用的高级用法
泛化调用是 Dubbo 提供的一种特殊调用方式，允许调用者以通用的方式调用 Dubbo 服务，而无需事先了解具体的服务接口。在泛化调用中，参数和返回值都是通过序列化和反序列化实现的，因此参数和返回值的处理略有不同于常规的 Dubbo 调用。
参数和返回值处理
- 参数处理： 在泛化调用中，参数通常是一个对象数组，对应于方法的参数列表。参数的顺序必须与方法的参数顺序相匹配，并且每个参数的类型必须与方法参数的类型相匹配。参数可以是基本类型、包装类型、字符串、集合等常见类型，也可以是自定义类型。在发起泛化调用时，需要将参数按照方法的参数列表顺序打包成一个对象数组，然后传递给
$invoke方法。 - 返回值处理： 泛化调用的返回值通常是一个对象，可以是基本类型、包装类型、字符串、集合、Map 等常见类型，也可以是自定义类型。在调用
$invoke方法后，将得到一个 Object 类型的返回值，需要根据实际情况进行类型转换。
异常处理和错误处理策略
- 异常处理： 在泛化调用中，如果 Dubbo 服务出现异常，将会抛出 RpcException 异常。因此，在进行泛化调用时，通常需要捕获 RpcException 异常，并根据具体情况进行处理。可以选择将异常信息返回给调用方，或者进行相应的错误处理。
- 错误处理策略： 泛化调用中的错误处理策略通常与常规的 Dubbo 调用相同。可以根据业务需求定义错误处理策略，例如重试、回退、降级等。Dubbo 提供了丰富的配置选项，可以灵活地配置错误处理策略，以满足不同的业务场景需求。
总的来说，泛化调用的参数和返回值处理方式与常规 Dubbo 调用类似，但需要注意参数顺序和类型匹配的问题。在异常处理和错误处理方面，需要根据具体情况进行灵活处理，以确保系统的稳定性和可靠性。
controller实践
package fun.bo.controller; import com.alibaba.fastjson.JSON; import org.apache.dubbo.config.ApplicationConfig; import org.apache.dubbo.config.ReferenceConfig; import org.apache.dubbo.config.RegistryConfig; import org.apache.dubbo.config.bootstrap.DubboBootstrap; import org.apache.dubbo.rpc.service.GenericService; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RestController; import java.lang.reflect.InvocationTargetException; @RestController public class CommonController { // 定义URL地址 @GetMapping("/gateway/{className}/{mtdName}/{parameterTypeName}/{reqBody}") public String commonRequest(@PathVariable String className, @PathVariable String mtdName, @PathVariable String parameterTypeName, @PathVariable String reqBody){ // 将入参的req转为下游方法的入参对象，并发起远程调用 return commonInvoke(className, mtdName, parameterTypeName, reqBody); } /** * <h2>模拟公共的远程调用方法.</h2> * * @param className：下游的接口归属方法的全类名。 * @param mtdName：下游接口的方法名。 * @param parameterTypeName：下游接口的方法入参的全类名。 * @param reqParamsStr：需要请求到下游的数据。 * @return 直接返回下游的整个对象。 * @throws InvocationTargetException * @throws IllegalAccessException */ public static String commonInvoke(String className, String mtdName, String parameterTypeName, String reqParamsStr) { // 然后试图通过类信息对象想办法获取到该类对应的实例对象 ReferenceConfig<GenericService> referenceConfig = createReferenceConfig(className); // 远程调用 GenericService genericService = referenceConfig.get(); Object resp = genericService.$invoke( mtdName, new String[]{parameterTypeName}, new Object[]{reqParamsStr}); // new Object[]{JSON.parseObject(reqParamsStr, Map.class)}); return JSON.toJSONString(resp); } private static ReferenceConfig<GenericService> createReferenceConfig(String className) { DubboBootstrap dubboBootstrap = DubboBootstrap.getInstance(); // 设置应用服务名称 ApplicationConfig applicationConfig = new ApplicationConfig(); applicationConfig.setName(dubboBootstrap.getApplication().getName()); // 设置注册中心的地址 // ApplicationConfig application = dubboBootstrap.getApplication(); RegistryConfig registryConfig = new RegistryConfig("zookeeper://localhost:2181"); ReferenceConfig<GenericService> referenceConfig = new ReferenceConfig<>(); referenceConfig.setApplication(applicationConfig); referenceConfig.setRegistry(registryConfig); referenceConfig.setInterface(className); // 设置泛化调用形式 referenceConfig.setGeneric("true"); // 设置默认超时时间5秒 referenceConfig.setTimeout(6 * 1000); return referenceConfig; } }
