Generic Invocation

Generic Invocation

1. Dubbogo Generic Invocation to Java Server

Using Triple protocol + hessian2 serialization scheme

Refer to Dubbogo 3.0 Generic Invocation Documentation

1.1 Java Server Startup

  1. Transmission structure definition
  1. package org.apache.dubbo;
  3. import java.io.Serializable;
  4. import java.util.Date;
  6. public class User implements Serializable {
  7.     private String id;
  9.   private String name;
  11.   private int age;
  13.   private Date time = new Date();
  14. }
  1. Interface definition
  1. package org.apache.dubbo;
  3. import java.util.ArrayList;
  4. import java.util.List;
  5. import java.util.Map;
  6. //import org.apache.dubbo.rpc.filter.GenericFilter;
  8. public interface UserProvider {
  9.     User GetUser1(String userId);
  10. }

1.2 Go-Client Generic Invocation

Here is the construction of the generic interface reference in the form of API

  1. // Initialize Reference configuration
  2. refConf := config.NewReferenceConfigBuilder().
  3.   SetInterface("org.apache.dubbo.UserProvider").
  4.   SetRegistryIDs("zk").
  5.   SetProtocol(tripleConst.TRIPLE).
  6.   SetGeneric(true).
  7.   SetSerialization("hessian2").
  8.   Build()
  10. // Construct Root configuration, introducing the registry module
  11. rootConfig := config.NewRootConfigBuilder().
  12.   AddRegistry("zk", config.NewRegistryConfigWithProtocolDefaultPort("zookeeper")).
  13.   Build()
  15. // Reference configuration initialization, as service discovery requires the configured rootConfig
  16. if err := refConf.Init(rootConfig); err != nil{
  17.   panic(err)
  18. }
  20. // Generic invocation loading, service discovery
  21. refConf.GenericLoad(appName)
  23. time.Sleep(time.Second)
  25. // Initiate generic invocation
  26. resp, err := refConf.GetRPCService().(*generic.GenericService).Invoke(
  27.   context.TODO(),
  28.   "getUser1",
  29.   []string{"java.lang.String"},
  30.   []hessian.Object{"A003"},
  31. )
  33. if err != nil {
  34.   panic(err)
  35. }
  36. logger.Infof("GetUser1(userId string) res: %+v", resp)

The Invoke method of GenericService includes three parameters: context.Context, []string, []hessian.Object,

where the second parameter corresponds to the Java class names such as java.lang.String, org.apache.dubbo.User, and the third parameter is the parameter list, hessian.Object as the interface. The second and third parameters should match the method signature in order.

Obtained a map structure return result

  1. INFO    cmd/client.go:89        GetUser1(userId string) res: map[age:48 class:org.apache.dubbo.User id:A003 name:Joe sex:MAN time:2021-10-04 14:03:03.37 +0800 CST]

Feedback

Was this page helpful?

Yes No

Last modified September 30, 2024: Update & Translate Overview Docs (#3040) (d37ebceaea7)