From 9bf79f7175b6d1762408402bc55a7a54c213f3b4 Mon Sep 17 00:00:00 2001 From: boyce Date: Wed, 20 Mar 2019 14:51:23 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B3=A8=E5=86=8C=E6=9C=AC=E6=9C=BA=E6=B6=88?= =?UTF-8?q?=E6=81=AF=E5=88=A4=E6=96=AD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- originnode/node.go | 4 ++++ sysservice/httpserverervice.go | 5 ++++- 2 files changed, 8 insertions(+), 1 deletion(-) diff --git a/originnode/node.go b/originnode/node.go index e948bf6..e192906 100644 --- a/originnode/node.go +++ b/originnode/node.go @@ -63,6 +63,10 @@ func (s *COriginNode) SetupService(services ...service.IService) { continue } + if cluster.InstanceClusterMgr().HasLocalService(services[j].GetServiceName()) == false { + continue + } + if services[i].GetServiceName() == services[j].GetServiceName() { continue } diff --git a/sysservice/httpserverervice.go b/sysservice/httpserverervice.go index 236d3da..c15ccdb 100644 --- a/sysservice/httpserverervice.go +++ b/sysservice/httpserverervice.go @@ -118,8 +118,11 @@ func (slf *HttpServerService) httpHandler(w http.ResponseWriter, r *http.Request request := HttpRequest{r.Header, string(msg)} var resp HttpRespone - cluster.InstanceClusterMgr().Call(strCallPath, &request, &resp) + err = cluster.InstanceClusterMgr().Call(strCallPath, &request, &resp) w.Header().Set("Content-Type", "application/json;charset=utf-8") + if err != nil { + resp.Respone = []byte(fmt.Sprint(err)) + } w.Write([]byte(resp.Respone)) }