[feat]: add new sample multirpc
diff --git a/multirpc/go-client/cmd/main.go b/multirpc/go-client/cmd/main.go
index ac6904b..1b9eee0 100644
--- a/multirpc/go-client/cmd/main.go
+++ b/multirpc/go-client/cmd/main.go
@@ -38,50 +38,65 @@
if err != nil {
panic(err)
}
+ err = nil
cli, err := ins.NewClient(
client.WithClientProtocolTriple())
if err != nil {
panic(err)
}
+ err = nil
//Triple
svc, err := greet.NewGreetService(cli)
if err != nil {
panic(err)
}
+ err = nil
respTriple, err := svc.Greet(context.Background(), &greet.GreetRequest{Name: "hello world"})
if err != nil {
logger.Error(err)
}
logger.Infof("Greet triple response: %s", respTriple.Greeting)
+ err = nil
//Duboo
cliDubbo, err := ins.NewClient(
client.WithClientProtocolTriple(),
client.WithClientSerialization(constant.Hessian2Serialization),
)
+ if err != nil {
+ panic(err)
+ }
+ err = nil
connDubbo, err := cliDubbo.Dial("GreetProvider")
if err != nil {
panic(err)
}
+ err = nil
var respDubbo string
if err := connDubbo.CallUnary(context.Background(), []interface{}{"hello", "new", "dubbo"}, &respDubbo, "SayHello"); err != nil {
logger.Errorf("GreetProvider.Greet err: %s", err)
return
}
logger.Infof("Get dubbo Response: %s", respDubbo)
+ err = nil
//JsonRpc
cliJsonRpc, err := ins.NewClient(
client.WithClientProtocolJsonRPC(),
client.WithClientSerialization(constant.Hessian2Serialization),
)
+ if err != nil {
+ panic(err)
+ }
+ err = nil
connJsonRpc, err := cliJsonRpc.Dial("GreetProvider")
if err != nil {
panic(err)
}
+ err = nil
var respJsonRpc string
if err := connJsonRpc.CallUnary(context.Background(), []interface{}{"hello", "new", "dubbo"}, &respJsonRpc, "SayHello"); err != nil {
logger.Errorf("GreetProvider.Greet err: %s", err)
diff --git a/multirpc/go-server/cmd/main.go b/multirpc/go-server/cmd/main.go
index 03e2a16..384b470 100644
--- a/multirpc/go-server/cmd/main.go
+++ b/multirpc/go-server/cmd/main.go
@@ -57,6 +57,7 @@
if err != nil {
panic(err)
}
+ err = nil
//var protocols []string
//protocols = append(protocols, "tri", "dubbo", "jsonrpc")
srv, err := ins.NewServer(
@@ -69,16 +70,19 @@
if err != nil {
panic(err)
}
+ err = nil
// 利用生成代码注册业务逻辑(GreetTripleServer)
// service配置，可以在此处覆盖server注入的默认配置
// 若观察RegisterGreetServiceHandler的代码，会发现本质上是调用Server.Register
if err := greet.RegisterGreetServiceHandler(srv, &GreetMultiRPCServer{}); err != nil {
panic(err)
}
+ err = nil
// 运行
if err := srv.Serve(); err != nil {
logger.Error(err)
}
+ err = nil
//dubbo
insDubbo, err := dubbo.NewInstance(
@@ -94,6 +98,7 @@
if err != nil {
panic(err)
}
+ err = nil
srvDubbo, err := insDubbo.NewServer(
server.WithServerProtocol(
@@ -105,14 +110,16 @@
if err != nil {
panic(err)
}
-
+ err = nil
if err := srvDubbo.Register(&GreetProvider{}, nil, server.WithInterface("GreetProvider")); err != nil {
panic(err)
}
+ err = nil
// 运行
if err := srvDubbo.Serve(); err != nil {
logger.Error(err)
}
+ err = nil
//JsonRpc
insJsonRpc, err := dubbo.NewInstance(
@@ -129,6 +136,7 @@
panic(err)
}
+ err = nil
srvJsonRpc, err := insJsonRpc.NewServer(
server.WithServerProtocol(
protocol.WithJSONRPC(),
@@ -139,10 +147,11 @@
if err != nil {
panic(err)
}
-
+ err = nil
if err := srvJsonRpc.Register(&GreetProvider{}, nil, server.WithInterface("GreetProvider")); err != nil {
panic(err)
}
+ err = nil
// 运行
if err := srvJsonRpc.Serve(); err != nil {
logger.Error(err)
