Dubbo-go 泛化调用
Dubbo-go 泛化调用
此文档已经不再维护。您当前查看的是快照版本。如果想要查看最新版本的文档，请参阅最新版本。
Dubbo-go 泛化调用
1. Dubbo-go 泛化调用 Java Server
使用 Triple 协议 + hessian2 序列化方案
可参考Dubbo-go 3.0 泛化调用文档
1.1 Java-Server启动
- 传输结构定义
package org.apache.dubbo;
import java.io.Serializable;
import java.util.Date;
public class User implements Serializable {
private String id;
private String name;
private int age;
private Date time = new Date();
}
- 接口定义
package org.apache.dubbo;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
//import org.apache.dubbo.rpc.filter.GenericFilter;
public interface UserProvider {
User GetUser1(String userId);
}
1.2 Go-Client 泛化调用
此处展示以 API 的形式构造泛化接口引用
// 初始化 Reference 配置
refConf := config.NewReferenceConfigBuilder().
SetInterface("org.apache.dubbo.UserProvider").
SetRegistryIDs("zk").
SetProtocol(tripleConst.TRIPLE).
SetGeneric(true).
SetSerialization("hessian2").
Build()
// 构造 Root 配置，引入注册中心模块
rootConfig := config.NewRootConfigBuilder().
AddRegistry("zk", config.NewRegistryConfigWithProtocolDefaultPort("zookeeper")).
Build()
// Reference 配置初始化，因为需要使用注册中心进行服务发现，需要传入经过配置的 rootConfig
if err := refConf.Init(rootConfig); err != nil{
panic(err)
}
// 泛化调用加载、服务发现
refConf.GenericLoad(appName)
time.Sleep(time.Second)
// 发起泛化调用
resp, err := refConf.GetRPCService().(*generic.GenericService).Invoke(
context.TODO(),
"getUser1",
[]string{"java.lang.String"},
[]hessian.Object{"A003"},
)
if err != nil {
panic(err)
}
logger.Infof("GetUser1(userId string) res: %+v", resp)
GenericService 的 Invoke 方法包括三个参数：context.Context, []string, []hessian.Object,
其中第二个参数为对应参数的 Java 类名，例如java.lang.String、org.apache.dubbo.User，第三个参数为参数列表，hessian.Object 即为 interface。第二、第三个参数应与方法签名一致，按顺序对应。
获得map结构的返回结果
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?
Glad to hear it! Please tell us how we can improve.
Sorry to hear that. Please tell us how we can improve.
