泛化调用

客户端在不需要依赖服务端的接口情况下就能够发起调用。

  1. ConsumerConfig<GenericService> consumerConfig = new ConsumerConfig<GenericService>()
  2.            .setInterfaceId("com.alipay.sofa.rpc.quickstart.HelloService")
  3.            .setGeneric(true);
  4. GenericService testService = consumerConfig.refer();
  6. String result = (String) testService.$invoke("sayHello", new String[] { "java.lang.String" },new Object[] { "1111" });

如上通过 setGeneric 设置该服务为泛化服务，设置服务方的接口名。以 GenericService 作为泛化服务，通过 GenericService 就能够发起泛化调用了。发起调用时，需要传入方法名，方法类型，方法参数。

如果参数或者返回结果在客户端也需要泛化表示。可以通过 GenericObject 来实现。

  1. GenericObject genericObject = new GenericObject("com.alipay.sofa.rpc.invoke.generic.TestObj");
  3. genericObject.putField("str", "xxxx");
  4. genericObject.putField("num", 222);
  6. GenericObject result = (GenericObject) testService.$genericInvoke("echoObj",
  7.                     new String[] { "com.alipay.sofa.rpc.invoke.generic.TestObj" },
  8.                     new Object[] { genericObject });
  10. String str = result.getField("str");
  11. String num = result.getField("num");

如上就能获得序列化结果。完整的泛化调用方式使用说明如下：

  1. /**
  2. * Java Bean
  3. */
  4. public class People {
  5.     private String name;
  6.     private int    age;
  8.     // getters and setters
  9. }
  12. /**
  13.  * 服务方提供的接口
  14.  */
  15. interface SampleService {
  16.    String hello(String arg);
  17.    People hello(People people);
  18.    String[] hello(String[] args);
  19. }
  21. /**
  22.  * 客户端
  23.  */
  24. public class ConsumerClass {
  25.    GenericService genericService;
  27.    public void do() {
  28.       // 1. $invoke仅支持方法参数类型在当前应用的 ClassLoader 中存在的情况
  29.       genericService.$invoke("hello", new String[]{ String.class.getName() }, "I'm an arg");
  31.       // 2. $genericInvoke支持方法参数类型在当前应用的 ClassLoader 中不存在的情况。
  32.       // 2.1 构造参数
  33.       GenericObject genericObject = new GenericObject("com.alipay.sofa.rpc.test.generic.bean.People"); // 构造函数中指定全路径类名
  34.       genericObject.putField("name", "Lilei"); // 调用putField，指定field值
  35.       genericObject.putField("age", 15);
  37.       // 2.2 进行调用，不指定返回类型，返回结果类型为GenericObject
  38.       Object obj = genericService.$genericInvoke("hello", new String[]{"com.alipay.sofa.rpc.test.generic.bean.People"}, new Object[] { genericObject });
  39.       Assert.assertTrue(obj.getClass == GenericObject.class);
  41.       // 2.3 进行调用，指定返回类型
  42.       People people = genericService.$genericInvoke("hello", new String[]{"com.alipay.sofa.rpc.test.generic.bean.People"}, new Object[] { genericObject }, People.class);
  44.       // 2.4 进行调用，参数类型是数组类型
  45.       String[] result = (String[]) proxy.$genericInvoke("hello", new String[]{new String[0].getClass().getName()}, new Object[]{ new String[]{"args"} });
  46.    }
  47. }