[feat]: add new sample multirpc
diff --git a/multirpc/go-client/cmd/main.go b/multirpc/go-client/cmd/main.go
index aa591cd..05960b1 100644
--- a/multirpc/go-client/cmd/main.go
+++ b/multirpc/go-client/cmd/main.go
@@ -43,8 +43,8 @@
panic(err)
}
- //Triple
client.WithProtocolTriple()
+ //Triple
svc, err := greet.NewGreetService(cli)
if err != nil {
panic(err)
@@ -64,7 +64,7 @@
panic(err)
}
var respDubbo string
- if err := connDubbo.CallUnary(context.Background(), []interface{}{"hello", "new", "dubbo"}, &respDubbo, "Greet"); err != nil {
+ if err := connDubbo.CallUnary(context.Background(), []interface{}{"hello", "new", "dubbo"}, &respDubbo, "SayHello"); err != nil {
logger.Errorf("GreetProvider.Greet err: %s", err)
return
}
@@ -78,7 +78,7 @@
panic(err)
}
var respJsonRpc string
- if err := connJsonRpc.CallUnary(context.Background(), []interface{}{"hello", "new", "dubbo"}, &respJsonRpc, "Greet"); err != nil {
+ if err := connJsonRpc.CallUnary(context.Background(), []interface{}{"hello", "new", "dubbo"}, &respJsonRpc, "SayHello"); err != nil {
logger.Errorf("GreetProvider.Greet err: %s", err)
return
}
diff --git a/multirpc/go-server/cmd/main.go b/multirpc/go-server/cmd/main.go
index d53df1c..03e2a16 100644
--- a/multirpc/go-server/cmd/main.go
+++ b/multirpc/go-server/cmd/main.go
@@ -38,7 +38,7 @@
type GreetProvider struct {
}
-func (*GreetProvider) Greet(req string, req1 string, req2 string) (string, error) {
+func (*GreetProvider) SayHello(req string, req1 string, req2 string) (string, error) {
return req + req1 + req2, nil
}
@@ -98,7 +98,7 @@
srvDubbo, err := insDubbo.NewServer(
server.WithServerProtocol(
protocol.WithDubbo(),
- protocol.WithPort(20000),
+ protocol.WithPort(20001),
),
//server.WithServerProtocolIDs(protocols),
)
@@ -110,7 +110,7 @@
panic(err)
}
// 运行
- if err := srv.Serve(); err != nil {
+ if err := srvDubbo.Serve(); err != nil {
logger.Error(err)
}
@@ -132,7 +132,7 @@
srvJsonRpc, err := insJsonRpc.NewServer(
server.WithServerProtocol(
protocol.WithJSONRPC(),
- protocol.WithPort(20000),
+ protocol.WithPort(20002),
),
//server.WithServerProtocolIDs(protocols),
)
@@ -144,7 +144,7 @@
panic(err)
}
// 运行
- if err := srv.Serve(); err != nil {
+ if err := srvJsonRpc.Serve(); err != nil {
logger.Error(err)
}
}