From 949537c960994a06346028d3c0fff7c5ddb74b93 Mon Sep 17 00:00:00 2001 From: boyce Date: Thu, 9 May 2019 18:07:48 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8A=A8=E6=80=81Call=E8=BF=9C=E7=A8=8BRPC?= =?UTF-8?q?=E6=9C=8D=E5=8A=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- cluster/cluster.go | 15 +++++++++++++++ 1 file changed, 15 insertions(+) diff --git a/cluster/cluster.go b/cluster/cluster.go index 5a03777..eaf921b 100644 --- a/cluster/cluster.go +++ b/cluster/cluster.go @@ -499,3 +499,18 @@ func GetNodeName(nodeid int) string { // return _self.cfg.GetNodeNameByNodeId(nodeid) } + +func DynamicCall(address string, serviceMethod string, args interface{}, reply interface{}) error { + //conn, err := rpc.DialHTTP("tcp", "127.0.0.1:8095") + rpcClient, err := rpc.Dial("tcp", address) + if err != nil { + return err + } + defer rpcClient.Close() + err = rpcClient.Call(serviceMethod, args, reply) + if err != nil { + return err + } + + return nil +}