commit c6de30d2e7246008a8815e754a37fbe6496f0fb4
author Yan0613 <1020303879@qq.com> Sat Mar 23 14:20:14 2024 +0800
committer Yan0613 <1020303879@qq.com> Sat Mar 23 14:20:14 2024 +0800
tree 90e3dde4c1ffff8e157e76ecda023142afc2ac14
parent 41c79301f70d77251efad41674b8bd53bf67910e

[feat]: add new sample multirpc

multirpc/go-client/cmd/main.go

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
 	}

multirpc/go-server/cmd/main.go

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)
 	}
 }