Ma/origin
1
0
Fork 0
mirror of https://github.com/duanhf2012/origin.git synced 2026-03-06 22:27:36 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

注册本机消息判断

Browse Source
This commit is contained in:
boyce
2019-03-20 14:51:23 +08:00
parent 671159cc87
commit 9bf79f7175
2 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
originnode/node.go
View File

@@ -63,6 +63,10 @@ func (s *COriginNode) SetupService(services ...service.IService) {
continue continue
} }
if cluster.InstanceClusterMgr().HasLocalService(services[j].GetServiceName()) == false {
continue
}
if services[i].GetServiceName() == services[j].GetServiceName() { if services[i].GetServiceName() == services[j].GetServiceName() {
continue continue
} }

5
sysservice/httpserverervice.go
View File

@@ -118,8 +118,11 @@ func (slf *HttpServerService) httpHandler(w http.ResponseWriter, r *http.Request
request := HttpRequest{r.Header, string(msg)} request := HttpRequest{r.Header, string(msg)}
var resp HttpRespone 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") w.Header().Set("Content-Type", "application/json;charset=utf-8")
if err != nil {
resp.Respone = []byte(fmt.Sprint(err))
}
w.Write([]byte(resp.Respone)) w.Write([]byte(resp.Respone))
} }